channel

Documentation

Index

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

Variables

var AllProviderNames = []ProviderName{INMEM, REDIS, NATS, STAN, KAFKA}

Types

type Provider

type Provider interface {
	Publish(ctx context.Context, event *eventgate.Event) error
	GetChannel(ctx context.Context) (chan *eventgate.Event, error)
	Close() error
}

func GetChannelProvider

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

type ProviderName

type ProviderName string

const (
	NATS  ProviderName = "nats"
	STAN  ProviderName = "stan"
	INMEM ProviderName = "inmem"
	REDIS ProviderName = "redis"
	KAFKA ProviderName = "kafka"
)