- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for seves (0.18 sec)
-
internal/event/target/nsq.go
// To treat "connection refused" errors as errNotConnected. if xnet.IsConnRefusedErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil } // Save - saves the events to the store which will be replayed when the nsq connection is active. func (target *NSQTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 7.1K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
defer cancel() err := target.checkAndInitClient(ctx) if err != nil { return false, err } return target.client.ping(ctx, target.args) } // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active. func (target *ElasticsearchTarget) Save(eventData event.Event) error { if target.store != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
src/archive/zip/reader.go
ErrAlgorithm = errors.New("zip: unsupported compression algorithm") ErrChecksum = errors.New("zip: checksum error") ErrInsecurePath = errors.New("zip: insecure file path") ) // A Reader serves content from a ZIP archive. type Reader struct { r io.ReaderAt File []*File Comment string decompressors map[uint16]Decompressor
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
internal/grid/manager.go
// If the host does not exist nil will be returned. func (m *Manager) Connection(host string) *Connection { return m.targets[host] } // RegisterSingleHandler will register a stateless handler that serves // []byte -> ([]byte, error) requests. // subroutes are joined with "/" to a single subroute. func (m *Manager) RegisterSingleHandler(id HandlerID, h SingleHandlerFn, subroute ...string) error { if !id.valid() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version_test.go
} versionInvalid1 = &version.Info{ Major: "1", Minor: "7", GitVersion: "v1.invalid.7", } versionInvalid2 = &version.Info{ Major: "one", Minor: "seven", GitVersion: "one.seven", } ) func TestExtractKubernetesVersion(t *testing.T) { cases := []struct { version *version.Info expected int errMsg error isValid bool }{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0) -
internal/event/target/mqtt.go
return nil } return err } if err = target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Save - saves the events to the store if queuestore is configured, which will // be replayed when the mqtt connection is active. func (target *MQTTTarget) Save(eventData event.Event) error { if target.store != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
internal/event/target/amqp.go
confirmed := <-confirms if !confirmed.Ack { return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag) } } return nil } // Save - saves the events to the store which will be replayed when the amqp connection is active. func (target *AMQPTarget) Save(eventData event.Event) error { if target.store != nil { return target.store.Put(eventData) }
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
if err := target.db.Ping(); err != nil { if IsConnErr(err) { return false, store.ErrNotConnected } return false, err } return true, nil } // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active. func (target *PostgreSQLTarget) Save(eventData event.Event) error { if target.store != 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) -
cmd/tier.go
delete(config.Tiers, k) } // Copy over the new tier configs for tier, cfg := range newConfig.Tiers { config.Tiers[tier] = cfg } config.lastRefreshedAt = UTCNow() return nil } // Save saves tier configuration onto objAPI func (config *TierConfigMgr) Save(ctx context.Context, objAPI ObjectLayer) error { if objAPI == nil { return errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
binary.LittleEndian.PutUint16(data[0:2], poolMetaFormat) binary.LittleEndian.PutUint16(data[2:4], poolMetaVersion) buf, err := p.MarshalMsg(data) if err != nil { return err } // Saves on all pools to make sure decommissioning of first pool is allowed. for i, eset := range pools { if err = saveConfig(ctx, eset, poolMetaName, buf); err != nil { if !errors.Is(err, context.Canceled) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1)