options

Documentation

Index

• type ConnectorConfig
• type KafkaConfig
• type NsqConfig
• type Options
  • func NewOptions() (*Options, error)
• type ProducerConfig
• type PulsarConfig

Types

type ConnectorConfig

type ConnectorConfig struct {
	ConnectorType define.ConnectorType
	KafkaConfig   KafkaConfig
	PulsarConfig  PulsarConfig
	NsqConfig     NsqConfig
}

ConnectorConfig is a connector config

type KafkaConfig

type KafkaConfig struct {
	BrokerList                 []string
	OffsetsAutoCommitEnable    bool
	FlowControlBatchNum        int
	Version                    string
	InitOffsetGetOffsetTimeout int64
	InitOffsetGetOffsetPeroid  int64
}

KafkaConfig is a Kafka config

type NsqConfig

type NsqConfig struct {
	NodeList    []string
	LookUpAddrs []string
}

NsqConfig is a Nsq config

type Options

type Options struct {
	LogConfig           log.Config
	ConnectorConfig     ConnectorConfig
	ConfConnectorConfig cc.ConfConnectorConfig
	RedisConfig         redis.Config
	ProducerConfig      ProducerConfig
	MonitorConfig       monitor.Options
}

Options is a processor server config

func NewOptions

func NewOptions() (*Options, error)

NewOptions creates a new processor configuration

type ProducerConfig

type ProducerConfig struct {
	Addr    string
	Timeout time.Duration
}

ProducerConfig is a producer server config

type PulsarConfig

type PulsarConfig struct {
	URL         string
	TopicPrefix string
	Token       string
}

PulsarConfig is a Pulsar config