config

Documentation

Index

• func NewCommonKafkaConfig(configMap *kafka.ConfigMap) config.KafkaConfig
• func NewCommonOutboxConfig(groupID string, databaseName string, outboxCollectionName string, ...) config.OutboxConfig
• func NewDefaultCommonOutboxConfig(groupID string, databaseName string) config.OutboxConfig
• type CommonKafkaConfig
  • func (c *CommonKafkaConfig) GetConfigMap() *kafka.ConfigMap
• type CommonOutboxConfig
  • func (c *CommonOutboxConfig) GetDatabaseName() string
  • func (c *CommonOutboxConfig) GetGroupID() string
  • func (c *CommonOutboxConfig) GetOutboxCollectionName() 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

Functions

func NewCommonKafkaConfig

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

func NewCommonOutboxConfig

func NewCommonOutboxConfig(groupID string, databaseName string,
	outboxCollectionName string,
	pickerPollInterval int, pickerMessageLimitPerPoll int,
	zombieInterval int, zombiePickerPollInterval int, zombiePickerMessageLimitPerPoll int,
	removerPollInterval int, removerMessageLimitPerPoll int) config.OutboxConfig

func NewDefaultCommonOutboxConfig

func NewDefaultCommonOutboxConfig(groupID string, databaseName string) 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                         string
	DatabaseName                    string
	OutboxCollectionName            string
	PickerPollInterval              int
	PickerMessageLimitPerPoll       int
	ZombieInterval                  int
	ZombiePickerPollInterval        int
	ZombiePickerMessageLimitPerPoll int
	RemoverPollInterval             int
	RemoverMessageLimitPerPoll      int
}

func (*CommonOutboxConfig) GetDatabaseName

func (c *CommonOutboxConfig) GetDatabaseName() string

func (*CommonOutboxConfig) GetGroupID

func (c *CommonOutboxConfig) GetGroupID() string

func (*CommonOutboxConfig) GetOutboxCollectionName

func (c *CommonOutboxConfig) GetOutboxCollectionName() 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