channel

Documentation

Index

• type BaseChannel
• type Manager
  • func New(client redis.UniversalClient, baseChannel BaseChannel) Manager
• type PubSubMessage
• type Writer
  • func NewWriter(client redis.UniversalClient, baseChannel BaseChannel) Writer

Types

type BaseChannel

type BaseChannel string

type Manager

type Manager interface {
	Writer
	String() string
	Subscribe(ctx context.Context, id sharedTypes.UUID) error
	Unsubscribe(ctx context.Context, id sharedTypes.UUID)
	UnSubscribeBulk(ctx context.Context, ids sharedTypes.UUIDBatch) error
	Listen(ctx context.Context) (<-chan PubSubMessage, error)
	Close()
}

func New

func New(client redis.UniversalClient, baseChannel BaseChannel) Manager

type PubSubMessage

type PubSubMessage struct {
	Msg     string
	Channel sharedTypes.UUID
}

type Writer

type Writer interface {
	Publish(ctx context.Context, msg *sharedTypes.EditorEvent) error
	PublishVia(ctx context.Context, runner redis.Cmdable, msg *sharedTypes.EditorEvent) (*redis.IntCmd, error)
}

func NewWriter

func NewWriter(client redis.UniversalClient, baseChannel BaseChannel) Writer