config

Documentation

Index

• type ConnectionType
  • func (c ConnectionType) Start(conf interface{}, enableDebug bool, sidelineImpl interface{})
• type DMuxConfigSetting
  • func (s DMuxConfigSetting) GetDmuxConf() DmuxConf
• type DmuxConf
• type DmuxItem

Types

type ConnectionType

type ConnectionType string

ConnectionType based on this type of Connection and related forks happen

const (
	//KafkaHTTP key to define kafka to generic http sink
	KafkaHTTP ConnectionType = "kafka_http"
	//KafkaFoxtrot key to define kafka to foxtrot http sink
	KafkaFoxtrot ConnectionType = "kafka_foxtrot"

	//PulsarHTTP key to define pulsar to generic http sink
	PulsarHTTP ConnectionType = "pulsar_http"
)

func (ConnectionType) Start

func (c ConnectionType) Start(conf interface{}, enableDebug bool, sidelineImpl interface{})

Start invokes Run of the respective connection in a go routine

type DMuxConfigSetting

type DMuxConfigSetting struct {
	FilePath string
}

DMuxConfigSetting dumx obj

func (DMuxConfigSetting) GetDmuxConf

func (s DMuxConfigSetting) GetDmuxConf() DmuxConf

GetDmuxConf parses Config file and return DmuxConf

type DmuxConf

type DmuxConf struct {
	Name      string     `json:"name"`
	DMuxItems []DmuxItem `json:"dmuxItems"`
	// DMuxMap    map[string]KafkaHTTPConnConfig `json:"dmuxMap"`
	MetricPort int             `json:"metric_port"`
	Logging    logging.LogConf `json:"logging"`
}

DmuxConf hold Config data

type DmuxItem

type DmuxItem struct {
	Name           string         `json:"name"`
	Disabled       bool           `json:"disabled`
	ConnType       ConnectionType `json:"connectionType"`
	Connection     interface{}    `json:connection`
	SidelineEnable bool           `json:"sidelineEnable"`
}

DmuxItem struct defines name and type of connection