pubsub

Apr 12, 2023

Changes in this version

type IPubSub

+ MustSubscribeAsync func(ctx context.Context, subscriptions ...*subscription.Subscription)

type Mock

+ MockGetCounterPingFailed func() *expvar.Int

+ MockGetPublishedCounter func() *expvar.Int

+ MockGetPublishedFailedCounter func() *expvar.Int

+ MockGetSubscribedCounter func() *expvar.Int

+ MockGetSubscribedFailedCounter func() *expvar.Int

+ MockGetType func() string

+ MockMustPublish func(ctx context.Context, msgs ...*message.Message) []*message.Message

+ MockMustPublishAsync func(ctx context.Context, messages ...*message.Message)

+ MockMustSubscribe func(ctx context.Context, subscriptions ...*subscription.Subscription) []*subscription.Subscription

+ MockMustSubscribeAsyn func(ctx context.Context, subscriptions ...*subscription.Subscription)

+ func (m *Mock) GetCounterPingFailed() *expvar.Int

+ func (m *Mock) GetPublishedCounter() *expvar.Int

+ func (m *Mock) GetPublishedFailedCounter() *expvar.Int

+ func (m *Mock) GetSubscribedCounter() *expvar.Int

+ func (m *Mock) GetSubscribedFailedCounter() *expvar.Int

+ func (m *Mock) GetType() string

+ func (m *Mock) MustPublish(ctx context.Context, msgs ...*message.Message) []*message.Message

+ func (m *Mock) MustSubscribe(ctx context.Context, subscriptions ...*subscription.Subscription) []*subscription.Subscription

+ func (m *Mock) MustSubscribeAsync(ctx context.Context, subscriptions ...*subscription.Subscription)

Apr 12, 2023

Changes in this version

type IPubSub

+ GetCounterPingFailed func() *expvar.Int

type PubSub

+ func (p *PubSub) GetCounterPingFailed() *expvar.Int

Apr 12, 2023

Changes in this version

type IPubSub

+ GetPublishedCounter func() *expvar.Int

+ GetPublishedFailedCounter func() *expvar.Int

+ GetSubscribedCounter func() *expvar.Int

+ GetSubscribedFailedCounter func() *expvar.Int

+ GetType func() string

type PubSub

+ func (p *PubSub) GetPublishedCounter() *expvar.Int

+ func (p *PubSub) GetPublishedFailedCounter() *expvar.Int

+ func (p *PubSub) GetSubscribedCounter() *expvar.Int

+ func (p *PubSub) GetSubscribedFailedCounter() *expvar.Int

Apr 11, 2023

Changes in this version

+ type Func func(o *Options) error

+ func WithSync(sync bool) Func

type IPubSub

+ MustPublish func(ctx context.Context, msgs ...*message.Message) []*message.Message

+ MustPublishAsync func(ctx context.Context, messages ...*message.Message)

+ MustSubscribe func(ctx context.Context, subscriptions ...*subscription.Subscription) []*subscription.Subscription

+ MustSubscribeAsyn func(ctx context.Context, subscriptions ...*subscription.Subscription)

+ type Map map[string]IPubSub

+ func (m Map) MustPublishManyAsync(ctx context.Context, messages ...*message.Message)

+ func (m Map) MustSubscribeManyAsync(ctx context.Context, subscriptions ...*subscription.Subscription)

+ func (m Map) PublishMany(ctx context.Context, messages []*message.Message, opts ...Func)

+ func (m Map) SubscribeMany(ctx context.Context, subscriptions ...*subscription.Subscription)

type Mock

+ func (m *Mock) MustPublishAsync(topic string, message any)

+ type Options struct

+ Sync bool

+ func NewOptions() (*Options, error)

Apr 4, 2023

Changes in this version

+ type CallBackFunc func(msg []byte)

Apr 4, 2023

Changes in this version

type IPubSub

+ PublishAsync func(topic string, message any)

type Mock

+ MockPublishAsync func(topic string, message any)

+ func (m *Mock) PublishAsync(topic string, message any)

Apr 4, 2023

Changes in this version

type IPubSub

+ GetLogger func() sypl.ISypl

type Mock

+ MockGetLogger func() sypl.ISypl

+ func (m *Mock) GetLogger() sypl.ISypl

Apr 4, 2023

Changes in this version

type Mock

+ MockGetName func() string

+ func (m *Mock) GetName() any

Apr 4, 2023

Changes in this version

type IPubSub

+ GetName func() string

Apr 3, 2023

Changes in this version

+ const DefaultMetricCounterLabel

+ const OperationPublish

+ const OperationSubscribe

+ const Type

+ type IPubSub interface

+ Close func() error

+ GetClient func() any

+ Publish func(topic string, message any) error

+ Subscribe func(topic, queue string, cb func([]byte)) Subscription

+ Unsubscribe func(topic string) error

+ type Mock struct

+ MockClose func() error

+ MockGetClient func() any

+ MockPublish func(topic string, message any) error

+ MockSubscribe func(topic, queue string, cb func([]byte)) Subscription

+ MockUnsubscribe func(topic string) error

+ func (m *Mock) Close() error

+ func (m *Mock) GetClient() any

+ func (m *Mock) Publish(topic string, message any) error

+ func (m *Mock) Subscribe(topic, queue string, cb func([]byte)) Subscription

+ func (m *Mock) Unsubscribe(topic string) error

+ type PubSub struct

+ Logger sypl.ISypl

+ Name string

+ func New(name string) (*PubSub, error)

+ func (p *PubSub) ErrorHandler(ctx context.Context, operation string, err error) error

+ func (p *PubSub) FailedToErrorHandler(ctx context.Context, operation string, err error) error

+ func (p *PubSub) FailedToErrorMsgHandler(ctx context.Context, msg string, err error) error

+ func (p *PubSub) GetLogger() sypl.ISypl

+ func (p *PubSub) GetName() string

+ func (p *PubSub) GetPublishCounter() *expvar.Int

+ func (p *PubSub) GetSubscribeCounter() *expvar.Int

+ func (p *PubSub) GetType() string

+ func (p *PubSub) NotFoundErrorHandler(ctx context.Context) error

+ type Subscription struct

+ Callback func(msg []byte)

+ Channel <-chan []byte

+ Queue string

+ Topic string

+ func (s *Subscription) HandleMessage(msg *natsgo.Msg)