app

Documentation

Overview

Package app configures and runs application.

Index

• Constants
• func GetKafkaAggregateTypeTopic(cfg *KafkaEventsBusConfig, aggregateType string) kafka.TopicConfig
• func GetTopicName(eventStorePrefix string, aggregateType string) string
• func Run(cfg *config.Config)
• type KafkaEventsBusConfig

Constants

const (
	TaskAggregateType string = "Task"
)

Functions

func GetKafkaAggregateTypeTopic

func GetKafkaAggregateTypeTopic(cfg *KafkaEventsBusConfig, aggregateType string) kafka.TopicConfig

func GetTopicName

func GetTopicName(eventStorePrefix string, aggregateType string) string

func Run

func Run(cfg *config.Config)

Run creates objects via constructors.

Types

type KafkaEventsBusConfig

type KafkaEventsBusConfig struct {
	Topic             string `mapstructure:"topic" validate:"required"`
	TopicPrefix       string `mapstructure:"topicPrefix" validate:"required"`
	Partitions        int    `mapstructure:"partitions" validate:"required,gte=0"`
	ReplicationFactor int    `mapstructure:"replicationFactor" validate:"required,gte=0"`
	Headers           []kafka.Header
}

KafkaEventsBusConfig kafka eventbus config.