pubsub

Documentation

Index

• Constants
• type MemoryAdapter
  • func (ma *MemoryAdapter) Send(msg *channels.Message) error
  • func (ma *MemoryAdapter) Subscribe(client *channels.Client) error
• type PubSub
  • func NewMemoryAdapter() (*PubSub, error)
  • func NewPubSub(ctx context.Context, dto *dtos.PubSubConfig) (*PubSub, error)
  • func NewRedisAdapter(ctx context.Context, c *dtos.RedisConfig) (*PubSub, error)
  • func NewUpstashKafkaAdapter(ctx context.Context, config *dtos.UpstashKafkaConfig) (*PubSub, error)
• type PubSubError
  • func NewPubSubError(driver, message string) *PubSubError
  • func (e *PubSubError) Error() string
• type RedisAdapter
  • func (ra *RedisAdapter) Send(message *channels.Message) error
  • func (ra *RedisAdapter) Subscribe(client *channels.Client) error
• type UpstashKafkaAdapter
  • func (k *UpstashKafkaAdapter) Send(message *channels.Message) error
  • func (k *UpstashKafkaAdapter) Subscribe(client *channels.Client) error

Constants

const (
	MemoryDriver       = "MEMORY"
	RedisDriver        = "REDIS"
	UpstashKafkaDriver = "UPSTASH_KAFKA"
)

PubSub Drivers

Types

type MemoryAdapter

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

func (*MemoryAdapter) Send

func (ma *MemoryAdapter) Send(msg *channels.Message) error

func (*MemoryAdapter) Subscribe

func (ma *MemoryAdapter) Subscribe(client *channels.Client) error

type PubSub

type PubSub struct {
	Driver   string
	Consumer channels.ConsumerAdapter
	Producer channels.ProducerAdapter
}

func NewMemoryAdapter

func NewMemoryAdapter() (*PubSub, error)

func NewPubSub

func NewPubSub(ctx context.Context, dto *dtos.PubSubConfig) (*PubSub, error)

func NewRedisAdapter

func NewRedisAdapter(ctx context.Context, c *dtos.RedisConfig) (*PubSub, error)

func NewUpstashKafkaAdapter

func NewUpstashKafkaAdapter(ctx context.Context, config *dtos.UpstashKafkaConfig) (*PubSub, error)

type PubSubError

type PubSubError struct {
	Driver  string
	Message string
}

func NewPubSubError

func NewPubSubError(driver, message string) *PubSubError

func (*PubSubError) Error

func (e *PubSubError) Error() string

type RedisAdapter

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

func (*RedisAdapter) Send

func (ra *RedisAdapter) Send(message *channels.Message) error

func (*RedisAdapter) Subscribe

func (ra *RedisAdapter) Subscribe(client *channels.Client) error

type UpstashKafkaAdapter

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

func (*UpstashKafkaAdapter) Send

func (k *UpstashKafkaAdapter) Send(message *channels.Message) error

func (*UpstashKafkaAdapter) Subscribe

func (k *UpstashKafkaAdapter) Subscribe(client *channels.Client) error