Documentation
¶
Index ¶
- func NewCommonKafkaConfig(configMap *kafka.ConfigMap) config.KafkaConfig
- func NewCommonOutboxConfig(groupID uuid.UUID, outboxTableName string, pickerPollInterval int, ...) config.OutboxConfig
- func NewDefaultCommonOutboxConfig(groupID uuid.UUID) config.OutboxConfig
- type CommonKafkaConfig
- type CommonOutboxConfig
- func (c *CommonOutboxConfig) GetGroupID() uuid.UUID
- func (c *CommonOutboxConfig) GetOutboxTableName() string
- func (c *CommonOutboxConfig) GetPickerMessageLimitPerPoll() int
- func (c *CommonOutboxConfig) GetPickerPollInterval() int
- func (c *CommonOutboxConfig) GetRemoverMessageLimitPerPoll() int
- func (c *CommonOutboxConfig) GetRemoverPollInterval() int
- func (c *CommonOutboxConfig) GetZombieInterval() int
- func (c *CommonOutboxConfig) GetZombiePickerMessageLimitPerPoll() int
- func (c *CommonOutboxConfig) GetZombiePickerPollInterval() int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCommonKafkaConfig ¶
func NewCommonKafkaConfig(configMap *kafka.ConfigMap) config.KafkaConfig
func NewCommonOutboxConfig ¶
func NewDefaultCommonOutboxConfig ¶
func NewDefaultCommonOutboxConfig(groupID uuid.UUID) config.OutboxConfig
Types ¶
type CommonKafkaConfig ¶
type CommonKafkaConfig struct {
// contains filtered or unexported fields
}
func (*CommonKafkaConfig) GetConfigMap ¶
func (c *CommonKafkaConfig) GetConfigMap() *kafka.ConfigMap
type CommonOutboxConfig ¶
type CommonOutboxConfig struct { GroupID uuid.UUID OutboxTableName string PickerPollInterval int PickerMessageLimitPerPoll int ZombieInterval int ZombiePickerPollInterval int ZombiePickerMessageLimitPerPoll int RemoverPollInterval int RemoverMessageLimitPerPoll int }
func (*CommonOutboxConfig) GetGroupID ¶
func (c *CommonOutboxConfig) GetGroupID() uuid.UUID
func (*CommonOutboxConfig) GetOutboxTableName ¶
func (c *CommonOutboxConfig) GetOutboxTableName() string
func (*CommonOutboxConfig) GetPickerMessageLimitPerPoll ¶
func (c *CommonOutboxConfig) GetPickerMessageLimitPerPoll() int
func (*CommonOutboxConfig) GetPickerPollInterval ¶
func (c *CommonOutboxConfig) GetPickerPollInterval() int
func (*CommonOutboxConfig) GetRemoverMessageLimitPerPoll ¶
func (c *CommonOutboxConfig) GetRemoverMessageLimitPerPoll() int
func (*CommonOutboxConfig) GetRemoverPollInterval ¶
func (c *CommonOutboxConfig) GetRemoverPollInterval() int
func (*CommonOutboxConfig) GetZombieInterval ¶
func (c *CommonOutboxConfig) GetZombieInterval() int
func (*CommonOutboxConfig) GetZombiePickerMessageLimitPerPoll ¶
func (c *CommonOutboxConfig) GetZombiePickerMessageLimitPerPoll() int
func (*CommonOutboxConfig) GetZombiePickerPollInterval ¶
func (c *CommonOutboxConfig) GetZombiePickerPollInterval() int
Click to show internal directories.
Click to hide internal directories.