- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 563 for init (0.16 sec)
-
internal/once/init.go
// initialized when the provided function returns nil. // Init represents the structure. type Init struct { done uint32 m sync.Mutex } // Do is similar to sync.Once.Do - makes one successful // call to the function. ie, it invokes the function // if it is not successful yet. func (l *Init) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.do(f) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 09 04:20:31 GMT 2023 - 2.1K bytes - Viewed (0) -
internal/init/init.go
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 04 23:44:38 GMT 2022 - 874 bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
} func operatorInitCmd(ctx cli.Context, rootArgs *RootArgs, oiArgs *operatorInitArgs) *cobra.Command { return &cobra.Command{ Use: "init", Short: "Installs the Istio operator controller in the cluster.", Long: "The init subcommand installs the Istio operator controller in the cluster.", Args: cobra.ExactArgs(0), PreRunE: func(cmd *cobra.Command, args []string) error {
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0) -
internal/init/init_darwin_amd64.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package init import ( "os" "github.com/klauspost/cpuid/v2" ) func init() { // All MinIO operations must be under UTC. os.Setenv("TZ", "UTC") // Temporary workaround for // https://github.com/golang/go/issues/49233
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 04 23:44:38 GMT 2022 - 1.3K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
} baseTestCases := []TestSuiteCommon{ // Init and run test on ErasureSD backend with signature v4. {serverType: "ErasureSD", signer: signerV4}, // Init and run test on ErasureSD backend, with tls enabled. {serverType: "ErasureSD", signer: signerV4, secure: true}, // Init and run test on Erasure backend. {serverType: "Erasure", signer: signerV4}, // Init and run test on ErasureSet backend.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
internal/event/target/redis.go
return fmt.Errorf("expected type %v does not match with available type %v", expectedType, typeAvailable) } } return nil } // RedisTarget - Redis target. type RedisTarget struct { initOnce once.Init id event.TargetID args RedisArgs pool *redis.Pool store store.Store[event.Event] firstPing bool loggerOnce logger.LogOnce quitCh chan struct{} }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/constants/constants.go
RepairNodeName = "repair-node-name" RepairSidecarAnnotation = "repair-sidecar-annotation" RepairInitContainerName = "repair-init-container-name" RepairInitTerminationMsg = "repair-init-container-termination-message" RepairInitExitCode = "repair-init-container-exit-code" RepairLabelSelectors = "repair-label-selectors" RepairFieldSelectors = "repair-field-selectors" ) // Internal constants
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2.7K bytes - Viewed (0) -
cmd/server-main.go
}) // Initialize site replication manager after bucket metadata bootstrapTrace("globalSiteReplicationSys.Init", func() { globalSiteReplicationSys.Init(GlobalContext, newObject) }) // Initialize quota manager. bootstrapTrace("globalBucketQuotaSys.Init", func() { globalBucketQuotaSys.Init(newObject) }) // Populate existing buckets to the etcd backend if globalDNSConfig != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
internal/config/lambda/target/webhook.go
// Close the target. Will cancel all active requests. func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.lazyInit.Do(target.initWebhook) } // Only called from init() func (target *WebhookTarget) initWebhook() error { args := target.args transport := target.transport if args.ClientCert != "" && args.ClientKey != "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Nov 17 20:02:26 GMT 2023 - 6.7K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
sys.Unlock() return meta, true, nil } // Init - initializes bucket metadata system for all buckets. func (sys *BucketMetadataSys) Init(ctx context.Context, buckets []BucketInfo, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized } sys.objAPI = objAPI // Load bucket metadata sys. sys.init(ctx, buckets) return nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0)