- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SendFromStore (0.12 sec)
-
internal/store/store.go
var ErrNotConnected = errors.New("not connected to target server/service") // Target - store target interface type Target interface { Name() string SendFromStore(key Key) error } // Store - Used to persist items. type Store[I any] interface { Put(item I) (Key, error) PutMultiple(item []I) (Key, error) Get(key Key) (I, error) GetMultiple(key Key) ([]I, error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
internal/event/target/nsq.go
if err != nil { return err } return target.producer.Publish(target.args.Topic, data) } // SendFromStore - reads an event from store and sends it to NSQ. func (target *NSQTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil { return err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/event/targetlist_test.go
panic(err) } time.Sleep(time.Duration(b[0]) * time.Millisecond) if target.sendErr { return errors.New("send error") } return nil } // SendFromStore - interface compatible method does no-op. func (target *ExampleTarget) SendFromStore(_ store.Key) error { return nil } func (target ExampleTarget) Close() error { if target.closeErr { return errors.New("close error") } return nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 05 10:16:33 UTC 2023 - 6.1K bytes - Viewed (0) -
internal/event/target/webhook.go
} return fmt.Errorf("%s returned '%s', please check your endpoint configuration", target.args.Endpoint, resp.Status) } // SendFromStore - reads an event from store and sends it to webhook. func (target *WebhookTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } eventData, eErr := target.store.Get(key) if eErr != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/event/target/mqtt.go
if !token.WaitTimeout(reconnectInterval) { return store.ErrNotConnected } return token.Error() } // SendFromStore - reads an event from store and sends it to MQTT. func (target *MQTTTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } // Do not send if the connection is not active. _, err := target.isActive()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
internal/event/target/redis.go
return err } if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil { return err } } return nil } // SendFromStore - reads an event from store and sends it to redis. func (target *RedisTarget) SendFromStore(key store.Key) error { if err := target.init(); err != nil { return err } conn := target.pool.Get() defer conn.Close()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 9.1K bytes - Viewed (0) -
internal/event/targetlist.go
maxConcurrentAsyncSend = 50000 ) // Target - event target interface type Target interface { ID() TargetID IsActive() (bool, error) Save(Event) error SendFromStore(store.Key) error Close() error Store() TargetStore } // TargetStore is a shallow version of a target.Store type TargetStore interface { Len() int }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)