- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 127 for octicons (0.16 sec)
-
cmd/namespace-lock.go
lockSource := getSource(2) start := UTCNow() newCtx, cancel := context.WithCancel(ctx) if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{ Timeout: timeout.Timeout(), RetryInterval: timeout.RetryInterval(), }) { timeout.LogFailure() defer cancel() if err := newCtx.Err(); err == context.Canceled {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cmd/etcd.go
etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func saveKeyEtcd(ctx context.Context, client *etcd.Client, key string, data []byte, opts ...options) error { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() if len(opts) > 0 { return saveKeyEtcdWithTTL(ctx, client, key, data, opts[0].ttl) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type BucketOptions struct { Name string ReplicationARN string // This is optional, and not mandatory. } // MonitorReaderOptions provides configurable options for monitor reader implementation. type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
istioctl/pkg/clioptions/central.go
// limitations under the License. package clioptions import ( "fmt" "time" "github.com/spf13/cobra" "github.com/spf13/viper" ) // CentralControlPlaneOptions holds options common to all subcommands // that invoke Istiod via xDS REST endpoint type CentralControlPlaneOptions struct { // Xds is XDS endpoint, e.g. localhost:15010. Xds string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jun 06 03:39:27 GMT 2022 - 3.2K bytes - Viewed (0) -
cmd/warm-backend-minio.go
} u, err := url.Parse(conf.Endpoint) if err != nil { return nil, err } creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "") opts := &minio.Options{ Creds: creds, Secure: u.Scheme == "https", Transport: globalRemoteTargetTransport, TrailingHeaders: true, } client, err := minio.New(u.Host, opts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
if err != nil { return err } s := scheme.Scheme s.AddKnownTypes(v1alpha1.SchemeGroupVersion, &v1alpha1.IstioOperator{}) testClient, err = client.New(testRestConfig, client.Options{Scheme: s}) if err != nil { return err } return nil } var interceptorFunc = interceptor.Funcs{Patch: func( ctx context.Context, clnt client.WithWatch, obj client.Object,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
internal/cachevalue/cache.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cachevalue import ( "sync" "sync/atomic" "time" ) // Opts contains options for the cache. type Opts struct { // When set to true, return the last cached value // even if updating the value errors out. // Returns the last good value AND the error. ReturnLastGood bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/batch-rotate.go
// BatchJobKeyRotateEncryption defines key rotation encryption options passed type BatchJobKeyRotateEncryption struct { Type BatchKeyRotationType `yaml:"type" json:"type"` Key string `yaml:"key" json:"key"` Context string `yaml:"context" json:"context"` kmsContext kms.Context `msg:"-"` } // Validate validates input key rotation encryption options. func (e BatchJobKeyRotateEncryption) Validate() error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/bucket/lifecycle/transition.go
// encodes empty string otherwise func (tDays TransitionDays) MarshalXML(e *xml.Encoder, startElement xml.StartElement) error { return e.EncodeElement(int(tDays), startElement) } // Transition - transition actions for a rule in lifecycle configuration. type Transition struct { XMLName xml.Name `xml:"Transition"` Days TransitionDays `xml:"Days,omitempty"` Date TransitionDate `xml:"Date,omitempty"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 10 17:07:49 GMT 2022 - 5.1K bytes - Viewed (0) -
internal/http/listener.go
listeners := make([]net.Listener, 0, len(serverAddrs)) listenErrs = make([]error, len(serverAddrs)) // Unix listener with special TCP options. listenCfg := net.ListenConfig{ Control: setTCPParametersFn(opts), } for i, serverAddr := range serverAddrs { l, e := listenCfg.Listen(ctx, "tcp", serverAddr) if e != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0)