pubsub

package
v0.0.0-...-eec4d16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 17, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

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

PubSub Drivers

Variables

This section is empty.

Functions

This section is empty.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳