- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 289 for Store (0.15 sec)
-
cmd/iam-object-store.go
if listKey == iamFormatFile { continue } res[listKey] = append(res[listKey], trimmedItem) } // Store the listing for later re-use. iamOS.cachedIAMListing.Store(res) return res, nil } // PurgeExpiredSTS - purge expired STS credentials from object store. func (iamOS *IAMObjectStore) PurgeExpiredSTS(ctx context.Context) error { if iamOS.objAPI == nil { return errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/iam-etcd-store.go
var p MappedPolicy err := ies.loadIAMConfig(ctx, &p, getMappedPolicyPath(name, userType, isGroup)) if err != nil { if err == errConfigNotFound { return errNoSuchPolicy } return err } m.Store(name, p) return nil } func getMappedPolicy(kv *mvccpb.KeyValue, m *xsync.MapOf[string, MappedPolicy], basePrefix string) error { var p MappedPolicy err := getIAMConfig(&p, kv.Value, string(kv.Key))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/object_store_immutable_days.png
object_store_immutable_days.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jul 17 00:16:53 GMT 2020 - 12.6K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/1_add_object_store.png
1_add_object_store.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 17 00:36:14 GMT 2020 - 42.6K bytes - Viewed (0) -
docs/integrations/veeam/screenshots/6_add_sobr_with_object_store.png
6_add_sobr_with_object_store.png...
PNG Image - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 17 00:36:14 GMT 2020 - 31.5K bytes - Viewed (0) -
internal/event/target/kafka.go
type KafkaTarget struct { initOnce once.Init id event.TargetID args KafkaArgs client sarama.Client producer sarama.SyncProducer config *sarama.Config store store.Store[event.Event] batch *store.Batch[string, *sarama.ProducerMessage] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *KafkaTarget) ID() event.TargetID {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
return nil, fmt.Errorf("unable to initialize the queue store of NATS `%s`: %w", id, err) } } target := &NATSTarget{ id: event.TargetID{ID: id, Name: "nats"}, args: args, loggerOnce: loggerOnce, store: queueStore, quitCh: make(chan struct{}), } if target.store != nil { store.StreamItems(target.store, target, target.quitCh, target.loggerOnce) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
func (target *ElasticsearchTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *ElasticsearchTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *ElasticsearchTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/event/target/amqp.go
connMutex sync.Mutex store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns TargetID. func (target *AMQPTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *AMQPTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
internal/event/target/postgresql.go
} // Name - returns the Name of the target. func (target *PostgreSQLTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *PostgreSQLTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *PostgreSQLTarget) IsActive() (bool, error) { if err := target.init(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0)