config

package
v0.0.0-...-322893a Latest Latest
Warning

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

Go to latest
Published: Nov 9, 2020 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCommonKafkaConfig

func NewCommonKafkaConfig(configMap *kafka.ConfigMap) config.KafkaConfig

func NewCommonOutboxConfig

func NewCommonOutboxConfig(groupID uuid.UUID, outboxTableName string,
	pickerPollInterval int, pickerMessageLimitPerPoll int,
	zombieInterval int, zombiePickerPollInterval int, zombiePickerMessageLimitPerPoll int,
	removerPollInterval int, removerMessageLimitPerPoll int) config.OutboxConfig

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳