redisSyncFanoutQueue

Jan 24, 2023

Changes in this version

+ type ApiMetrics struct

+ KnownRoomsCount int64

+ TopRooms []*RoomMetrics

+ TopRoomsPendingMessagesBacklogLength int64

+ type ApiOptions struct

+ ClientTimeout time.Duration

+ RedisKeyPrefix string

+ RedisOptions *redis.Options

+ func (o *ApiOptions) Validate() error

+ type GetApiMetricsOptions struct

+ TopRoomsLimit int

+ type GetWorkerMetricsOptions struct

+ type HandleRoomClientTimeoutFunc func(ctx context.Context, clientId, room *string) error

type Message

+ AckToken *string

+ Room string

+ type RedisQueueApiClient interface

+ AckMessage func(ctx context.Context, clientId string, ackToken *string) error

+ Close func() error

+ CreateClientID func(ctx context.Context) (string, error)

+ GetMetrics func(ctx context.Context, options *GetApiMetricsOptions) (*ApiMetrics, error)

+ Peek func(ctx context.Context, room string, offset int, limit int) ([]*Message, error)

+ Ping func(ctx context.Context, clientId string) error

+ Send func(ctx context.Context, producerId string, room string, data interface{}, ...) error

+ SendOutOfBand func(ctx context.Context, producerId string, room string, data interface{}) error

+ Subscribe func(ctx context.Context, clientId string, room string) error

+ Unsubscribe func(ctx context.Context, clientId string, room string) error

+ func NewApiClient(ctx context.Context, options *ApiOptions) (RedisQueueApiClient, error)

+ type RedisQueueWorkerClient interface

+ Close func() error

+ GetMetrics func(ctx context.Context, options *GetWorkerMetricsOptions) (*WorkerMetrics, error)

+ func NewWorkerClient(ctx context.Context, options *WorkerOptions) (RedisQueueWorkerClient, error)

+ type WorkerMetrics struct

+ AvgLatency time.Duration

+ InvalidMessagesCount int64

+ MaxLatency time.Duration

+ MinLatency time.Duration

+ ReceivedMessagesCount int64

+ type WorkerOptions struct

+ HandleMessage HandleMessageFunc

+ HandleRoomClientTimeout HandleRoomClientTimeoutFunc

+ RedisKeyPrefix string

+ RedisOptions *redis.Options

+ func (o *WorkerOptions) Validate() error

Jul 9, 2022

Changes in this version

type ClientHandle

+ func (this *ClientHandle) GetClientID() string

+ func (this *ClientHandle) GetRoomProxyManager() RoomProxyManager

+ func (this *ClientHandle) GetRooms() []string

Jul 7, 2022

Changes in this version

+ type ClientHandle struct

+ func (this *ClientHandle) AddRoom(ctx context.Context, roomId string) (Room, error)

+ func (this *ClientHandle) RemoveRoom(ctx context.Context, roomId string) error

+ type ClientOptions struct

+ ClientEjectedHandler func(ctx context.Context, client *ClientHandle) error

+ MessageHandler HandleMessageFunc

+ func (o *ClientOptions) Validate() error

+ type RedisQueueClientProviderFunc func(ctx context.Context, roomEjectedFunc HandleRoomEjectedFunc) (RedisQueueClient, error)

+ type Room interface

+ type RoomProxyManager interface

+ AddClient func(ctx context.Context, options *ClientOptions) (*ClientHandle, error)

+ Close func() error

+ GetMetrics func(ctx context.Context, options *GetMetricsOptions) (*Metrics, error)

+ Peek func(ctx context.Context, room string, offset int, limit int) ([]*Message, error)

+ RemoveClient func(ctx context.Context, client *ClientHandle) error

+ Send func(ctx context.Context, room string, data interface{}, priority int) error

+ SendOutOfBand func(ctx context.Context, room string, data interface{}) error

+ func NewRoomProxyManager(ctx context.Context, options *RoomProxyManagerOptions) (RoomProxyManager, error)

+ type RoomProxyManagerOptions struct

+ RedisQueueClientProvider RedisQueueClientProviderFunc

+ func (o *RoomProxyManagerOptions) Validate() error

Jul 7, 2022

Changes in this version

type RedisQueueClient

+ func NewShardedClient(ctx context.Context, shardProvider RedisQueueShardsProvider) (RedisQueueClient, error)

+ type RedisQueueShardsProvider interface

+ GetRoomShardId func(ctx context.Context, room string) (uint32, error)

+ GetShardOptions func(ctx context.Context, shardId uint32) (*Options, error)

+ GetTotalShardsCount func(ctx context.Context) (uint32, error)

+ func NewRedisClusterShardProvider(ctx context.Context, options *Options, totalShardsCount uint32) (RedisQueueShardsProvider, error)

+ type ShardingOptions struct

+ TotalShardsCount int

+ func (o *ShardingOptions) Validate() error

Jun 28, 2022

Changes in this version

type RedisQueueClient

+ Peek func(ctx context.Context, room string, offset int, limit int) ([]*Message, error)

Jun 28, 2022

Changes in this version

+ type AckMessageFunc func(ctx context.Context) error

+ type GetMetricsOptions struct

+ TopRoomsLimit int

+ type HandleMessageFunc func(ctx context.Context, msg *Message) error

+ type HandleRoomEjectedFunc func(ctx context.Context, room *string) error

+ type Message struct

+ Ack AckMessageFunc

+ Data *interface{}

+ MessageContext struct{ ... }

+ type Metrics struct

+ AvgLatency time.Duration

+ InvalidMessagesCount int64

+ KnownRoomsCount int64

+ MaxLatency time.Duration

+ MinLatency time.Duration

+ ReceivedMessagesCount int64

+ SubscribedRoomsCount int

+ TopRooms []*RoomMetrics

+ TopRoomsPendingMessagesBacklogLength int64

+ type Options struct

+ ClientTimeout time.Duration

+ HandleRoomEjected HandleRoomEjectedFunc

+ RedisKeyPrefix string

+ RedisOptions *redis.Options

+ Sync bool

+ func (o *Options) Validate() error

+ type RedisQueueClient interface

+ Close func() error

+ GetMetrics func(ctx context.Context, options *GetMetricsOptions) (*Metrics, error)

+ Pong func(ctx context.Context) error

+ Send func(ctx context.Context, room string, data interface{}, priority int) error

+ SendOutOfBand func(ctx context.Context, room string, data interface{}) error

+ Subscribe func(ctx context.Context, room string, msgHandlerFunc HandleMessageFunc) error

+ Unsubscribe func(ctx context.Context, room string) error

+ func NewClient(ctx context.Context, options *Options) (RedisQueueClient, error)

+ type RoomMetrics struct

+ PendingMessagesBacklogLength int64

+ Room string