publisher

May 20, 2024

Changes in this version

+ type AppSyncPayload struct

+ ChannelName string

+ In In

Jul 5, 2023

Changes in this version

type RedisPublisher

+ func (self *RedisPublisher[In]) WithDiscardWhenDisconnected(v bool) *RedisPublisher[In]

May 22, 2023

Changes in this version

+ type AppSyncPublisher struct

+ func NewAppSyncPublisher(config *config.Config, name string) (self *AppSyncPublisher[In])

+ func (self *AppSyncPublisher[In]) WithChannelName(v string) *AppSyncPublisher[In]

+ func (self *AppSyncPublisher[In]) WithInputChannel(v chan In) *AppSyncPublisher[In]

+ func (self *AppSyncPublisher[In]) WithMonitor(monitor monitoring.Monitor) *AppSyncPublisher[In]

+ type Args struct

+ Data string

+ Name string

+ type RedisPublisher struct

+ func NewRedisPublisher(config *config.Config, redisConfig config.Redis, name string) (self *RedisPublisher[In])

+ func (self *RedisPublisher[In]) WithChannelName(v string) *RedisPublisher[In]

+ func (self *RedisPublisher[In]) WithInputChannel(v chan In) *RedisPublisher[In]

+ func (self *RedisPublisher[In]) WithMonitor(monitor monitoring.Monitor) *RedisPublisher[In]