Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,387 for funcs (0.04 sec)

  1. cmd/event-notification.go

    func NewEventNotifier(ctx context.Context) *EventNotifier {
    	// targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets()
    	return &EventNotifier{
    		targetList:     event.NewTargetList(ctx),
    		bucketRulesMap: make(map[string]event.RulesMap),
    	}
    }
    
    // GetARNList - returns available ARNs.
    func (evnot *EventNotifier) GetARNList() []string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. internal/config/identity/openid/jwt_test.go

    			}
    			if err == nil && testCase.expectedFailure {
    				t.Error("Expected failure, got success")
    			}
    		})
    	}
    }
    
    func initJWKSServer() *httptest.Server {
    	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		const jsonkey = `{"keys":
           [
             {"kty":"RSA",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. cmd/bitrot.go

    		return nil
    	}
    }
    
    // Available reports whether the given algorithm is available.
    func (a BitrotAlgorithm) Available() bool {
    	_, ok := bitrotAlgorithms[a]
    	return ok
    }
    
    // String returns the string identifier for a given bitrot algorithm.
    // If the algorithm is not supported String panics.
    func (a BitrotAlgorithm) String() string {
    	name, ok := bitrotAlgorithms[a]
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    		}
    	}
    }
    
    func (s *erasureSets) GetLockers(setIndex int) func() ([]dsync.NetLocker, string) {
    	return func() ([]dsync.NetLocker, string) {
    		lockers := make([]dsync.NetLocker, len(s.erasureLockers[setIndex]))
    		copy(lockers, s.erasureLockers[setIndex])
    		return lockers, s.erasureLockOwner
    	}
    }
    
    func (s *erasureSets) GetEndpointStrings(setIndex int) func() []string {
    	return func() []string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. internal/s3select/sql/value.go

    	v.value = f
    }
    
    func (v *Value) setString(s string) {
    	v.value = s
    }
    
    func (v *Value) setBool(b bool) {
    	v.value = b
    }
    
    func (v *Value) setTimestamp(t time.Time) {
    	v.value = t
    }
    
    func (v Value) String() string {
    	return fmt.Sprintf("%#v", v.value)
    }
    
    // CSVString - convert to string for CSV serialization
    func (v Value) CSVString() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  6. cmd/metrics-v2_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgMetricDescription(b *testing.B) {
    	v := MetricDescription{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgMetricDescription(b *testing.B) {
    	v := MetricDescription{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/monitor.go

    func SelectBuckets(buckets ...string) SelectionFunction {
    	if len(buckets) == 0 {
    		return func(bucket string) bool {
    			return true
    		}
    	}
    	return func(bucket string) bool {
    		for _, bkt := range buckets {
    			if bkt == bucket {
    				return true
    			}
    		}
    		return false
    	}
    }
    
    // Details for the measured bandwidth
    type Details struct {
    	LimitInBytesPerSecond            int64   `json:"limitInBits"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. istioctl/pkg/describe/describe.go

    func asMyProtoValue(s *structpb.Struct) *myProtoValue {
    	return &myProtoValue{
    		&structpb.Value{
    			Kind: &structpb.Value_StructValue{
    				StructValue: s,
    			},
    		},
    	}
    }
    
    func (v *myProtoValue) keyAsString(key string) string {
    	s := v.keyAsStruct(key)
    	return s.GetStringValue()
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    // waitForHTTPResponse should be used to the receiving side.
    func keepHTTPReqResponseAlive(w http.ResponseWriter, r *http.Request) (resp func(error), body io.ReadCloser) {
    	bodyDoneCh := make(chan struct{})
    	doneCh := make(chan error)
    	ctx := r.Context()
    	go func() {
    		canWrite := true
    		write := func(b []byte) {
    			if canWrite {
    				n, err := w.Write(b)
    				if err != nil || n != len(b) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/table/writer.go

    		output = append(output, row.Cells)
    	}
    	return output
    }
    
    func (c *ColoredTableWriter) SetAddRowFunc(f func(obj interface{}) Row) {
    	c.addRowFunc = f
    }
    
    func (c *ColoredTableWriter) AddHeader(names ...string) {
    	cells := make([]Cell, 0)
    	for _, name := range names {
    		cells = append(cells, NewCell(name))
    	}
    	c.header = Row{Cells: cells}
    }
    
    func (c *ColoredTableWriter) AddRow(obj interface{}) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 09:43:25 UTC 2024
    - 2.7K bytes
    - Viewed (0)
Back to top