providers

Documentation

Index

• Variables
• func GetChannelProvider(provider ChannelProvider, storage storage.Provider, lgger *logger.Logger, ...) (eventgate.EventGateServiceServer, func(), error)
• func GetStorageProvider(provider StorageProvider, lgger *logger.Logger, ...) (storage.Provider, error)
• type ChannelProvider
• type StorageProvider

Variables

var AllChannelProviders = []ChannelProvider{INMEM, REDIS, NATS, STAN, KAFKA, GOOGLEPUBSUB, AWSSQS}

var AllStorageProviders = []StorageProvider{INMEM_STORAGE, MONGO_STORAGE, ELASTICSEARCH_STORAGE}

Functions

func GetChannelProvider

func GetChannelProvider(provider ChannelProvider, storage storage.Provider, lgger *logger.Logger, providerConfig map[string]string) (eventgate.EventGateServiceServer, func(), error)

func GetStorageProvider

func GetStorageProvider(provider StorageProvider, lgger *logger.Logger, providerConfig map[string]string) (storage.Provider, error)

Types

type ChannelProvider

type ChannelProvider string

const (
	NATS         ChannelProvider = "nats"
	STAN         ChannelProvider = "stan"
	INMEM        ChannelProvider = "inmem"
	REDIS        ChannelProvider = "redis"
	KAFKA        ChannelProvider = "kafka"
	GOOGLEPUBSUB ChannelProvider = "google-pubsub"
	AWSSQS       ChannelProvider = "aws-sqs"
)

type StorageProvider

type StorageProvider string

const (
	MONGO_STORAGE         StorageProvider = "mongo"
	ELASTICSEARCH_STORAGE StorageProvider = "elasticsearch"
	INMEM_STORAGE         StorageProvider = "inmem"
)