pubsub

Documentation

Index

• Variables
• type Channel
  • func (pubSub Channel) NewPublisher() message.Publisher
  • func (pubSub Channel) NewSubscriber() message.Subscriber
• type Container
  • func NewChannel() Container
  • func NewContainer(config ContainerConfig) (Container, error)
  • func NewRedis(redisClient *redis.Client) Container
  • func NewSQL(dbType string, dbClient *stdSQL.DB) Container
• type ContainerConfig
• type Redis
  • func (pubSub Redis) NewPublisher() message.Publisher
  • func (pubSub Redis) NewSubscriber() message.Subscriber
• type SQL
  • func (pubSub SQL) NewPublisher() message.Publisher
  • func (pubSub SQL) NewSubscriber() message.Subscriber

Variables

var (
	ErrRedisConfigIsEmpty = errors.New("redis config is empty")
	ErrSQLConfigIsEmpty   = errors.New("sql config is empty")
)

Types

type Channel

type Channel struct {
	// contains filtered or unexported fields
}

func (Channel) NewPublisher

func (pubSub Channel) NewPublisher() message.Publisher

func (Channel) NewSubscriber

func (pubSub Channel) NewSubscriber() message.Subscriber

type Container

type Container interface {
	NewSubscriber() message.Subscriber
	NewPublisher() message.Publisher
}

func NewChannel

func NewChannel() Container

func NewContainer

func NewContainer(
	config ContainerConfig,
) (Container, error)

func NewRedis

func NewRedis(
	redisClient *redis.Client,
) Container

func NewSQL

func NewSQL(
	dbType string,
	dbClient *stdSQL.DB,
) Container

type ContainerConfig

type ContainerConfig struct {
	EventDriver string  `json:"event_driver"`
	RedisAddr   *string `json:"redis_addr"`
	RedisDB     *int    `json:"redis_db"`
	SQLDBType   *string `json:"sql_db_type"`
	SQLUser     *string `json:"sql_user"`
	SQLPass     *string `json:"sql_pass"`
	SQLHost     *string `json:"sql_addr"`
	SQLPort     *string `json:"sql_port"`
	SQLDBName   *string `json:"sqldb_name"`
}

type Redis

type Redis struct {
	// contains filtered or unexported fields
}

func (Redis) NewPublisher

func (pubSub Redis) NewPublisher() message.Publisher

func (Redis) NewSubscriber

func (pubSub Redis) NewSubscriber() message.Subscriber

type SQL

type SQL struct {
	// contains filtered or unexported fields
}

func (SQL) NewPublisher

func (pubSub SQL) NewPublisher() message.Publisher

func (SQL) NewSubscriber

func (pubSub SQL) NewSubscriber() message.Subscriber