Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 1,387 for funcs (0.03 sec)

  1. cni/pkg/nodeagent/net_test.go

    	netServer.netnsRunner = func(fdable NetnsFd, toRun func() error) error {
    		return toRun()
    	}
    	netServer.Start(ctx)
    	return netTestFixture{
    		netServer:            netServer,
    		podNsMap:             podNsMap,
    		ztunnelServer:        ztunnelServer,
    		iptablesConfigurator: iptablesConfigurator,
    		nlDeps:               nlDeps,
    	}
    }
    
    func buildConvincingPod(v6IP bool) *corev1.Pod {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. cmd/admin-handler-utils.go

    }
    
    // AdminError - is a generic error for all admin APIs.
    type AdminError struct {
    	Code       string
    	Message    string
    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    		return noError
    	}
    
    	var apiErr APIError
    	switch e := err.(type) {
    	case policy.Error:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. internal/s3select/simdj/reader.go

    	decoded chan simdjson.Object
    
    	// err will only be returned after decoded has been closed.
    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    			return nil, errJSONParsingError(*r.err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. istioctl/pkg/tag/util.go

    		nsNames[i] = ns.Name
    	}
    	return nsNames, nil
    }
    
    // GetWebhookTagName extracts tag name from webhook object.
    func GetWebhookTagName(wh admitv1.MutatingWebhookConfiguration) string {
    	return wh.ObjectMeta.Labels[label.IoIstioTag.Name]
    }
    
    // GetWebhookRevision extracts tag target revision from webhook object.
    func GetWebhookRevision(wh admitv1.MutatingWebhookConfiguration) (string, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/config/identity/plugin/config.go

    	currentMinute    serviceRTTMinuteStats
    }
    
    func (h *metrics) setConnSuccess(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckSuccess = reqStartTime
    }
    
    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/callhome.go

    )
    
    var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    // initCallhome will start the callhome task in the background.
    func initCallhome(ctx context.Context, objAPI ObjectLayer) {
    	if !globalCallhomeConfig.Enabled() {
    		return
    	}
    
    	go func() {
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		// Leader node (that successfully acquires the lock inside runCallhome)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  7. tests/tracer_test.go

    )
    
    type Tracer struct {
    	Logger logger.Interface
    	Test   func(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)
    }
    
    func (S Tracer) LogMode(level logger.LogLevel) logger.Interface {
    	return S.Logger.LogMode(level)
    }
    
    func (S Tracer) Info(ctx context.Context, s string, i ...interface{}) {
    	S.Logger.Info(ctx, s, i...)
    }
    
    func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Oct 18 09:28:06 UTC 2022
    - 830 bytes
    - Viewed (0)
  8. cmd/bucket-replication-metrics_gen.go

    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z ActiveWorkerStat) Msgsize() (s int) {
    	s = 1 + 5 + msgp.IntSize + 4 + msgp.Float32Size + 4 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *InQueueMetric) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  9. cmd/metrics-v2_gen.go

    func (z MetricName) Msgsize() (s int) {
    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z MetricNamespace) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendString(o, string(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  10. internal/kms/kes.go

    	"github.com/minio/kms-go/kes"
    	"github.com/minio/madmin-go/v3"
    )
    
    type kesConn struct {
    	defaultKeyID string
    	client       *kes.Client
    }
    
    func (c *kesConn) Version(ctx context.Context) (string, error) {
    	return c.client.Version(ctx)
    }
    
    func (c *kesConn) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	APIs, err := c.client.APIs(ctx)
    	if err != nil {
    		if errors.Is(err, kes.ErrNotAllowed) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top