channel

Feb 11, 2021

Changes in this version

+ var AllProviderNames = []ProviderName

+ type Provider interface

+ Close func() error

+ GetChannel func(ctx context.Context) (chan *eventgate.Event, error)

+ Publish func(ctx context.Context, event *eventgate.Event) error

+ func GetChannelProvider(provider ProviderName, lgger *logger.Logger, providerConfig map[string]string) (Provider, error)

+ type ProviderName string

+ const INMEM

+ const KAFKA

+ const NATS

+ const REDIS

+ const STAN