Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for Constructor (0.27 sec)

  1. internal/config/dns/etcd_dns.go

    // client setting, note this will fail if set to empty when
    // constructor initializes.
    func DomainNames(domainNames []string) EtcdOption {
    	return func(args *CoreDNS) {
    		args.domainNames = domainNames
    	}
    }
    
    // DomainIPs set a list of custom domain IPs, note this will
    // fail if set to empty when constructor initializes.
    func DomainIPs(domainIPs set.StringSet) EtcdOption {
    	return func(args *CoreDNS) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  3. cmd/data-scanner.go

    					globalScannerMetrics.incTime(scannerMetricYield, wantSleep)
    				}
    				return
    			}
    		}
    	}
    }
    
    // Update the current settings and cycle all waiting.
    // Parameters are the same as in the constructor.
    func (d *dynamicSleeper) Update(factor float64, maxWait time.Duration) error {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	if math.Abs(d.factor-factor) < 1e-10 && d.maxSleep == maxWait {
    		return nil
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/value_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package sql
    
    import (
    	"fmt"
    	"math"
    	"strconv"
    	"testing"
    	"time"
    )
    
    // valueBuilders contains one constructor for each value type.
    // Values should match if type is the same.
    var valueBuilders = []func() *Value{
    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 12.5K bytes
    - Viewed (0)
  5. internal/grid/README.md

            // Do something with payload
            return NewMSSWith(map[string]string{"result": "ok"}), nil
        }
    	
        // Create a typed handler.
        // Due to current generics limitations, a constructor of the empty type must be provided.
        instance := grid.NewSingleHandler[*grid.MSS, *grid.MSS](h, grid.NewMSS, grid.NewMSS)
    	
        // Register the handler on the manager
        instance.Register(manager, handler)
    	
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  6. internal/logger/target/kafka/kafka_scram_client_contrib.go

    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    // factory receiver.  This constructor will normalize the username, password
    // and authzID via the SASLprep algorithm, as recommended by RFC-5802.  If
    // SASLprep fails, the method returns an error.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.3K bytes
    - Viewed (1)
  7. internal/hash/reader_test.go

    	r, err := NewReader(context.Background(), src, size, md5Hex, sha256Hex, actualSize)
    	if err != nil {
    		t.Fatal(err)
    	}
    	return r
    }
    
    // Tests NewReader() constructor with invalid arguments.
    func TestHashReaderInvalidArguments(t *testing.T) {
    	testCases := []struct {
    		desc              string
    		src               io.Reader
    		size              int64
    		actualSize        int64
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.3K bytes
    - Viewed (0)
Back to top