connectors

Documentation

Index

• Constants
• func InjectKVDBSync(dbsync *kvdbsync.Plugin, db keyval.KvProtoPlugin, dbPlugName core.PluginName, ...)
• type AllConnectorsFlavor
  • func (f *AllConnectorsFlavor) Inject() bool
  • func (f *AllConnectorsFlavor) Plugins() []*core.NamedPlugin

Constants

const CassaConf = "cassandra.conf"

CassaConf is default (flag value) - filename for the configuration.

const CassaConfFlag = "cassandra-config"

CassaConfFlag used as flag name (see implementation in declareFlags()) It is used to load configuration of Cassandra client plugin. This flag name is calculated from the name of the plugin.

const CassaConfUsage = "Location of the Cassandra Client configuration file; also set via 'CASSANDRA_CONFIG' env variable."

CassaConfUsage used as flag usage (see implementation in declareFlags())

const ETCDConf = "etcd.conf"

ETCDConf is default (flag value) - filename for the configuration.

const ETCDConfFlag = "etcdv3-config"

ETCDConfFlag used as flag name (see implementation in declareFlags()) It is used to load configuration of ETCD client plugin. This flag name is calculated from the name of the plugin.

const ETCDConfUsage = "Location of the Etcd configuration file; also set via 'ETCDV3_CONFIG' env variable."

ETCDConfUsage used as flag usage (see implementation in declareFlags())

const KafkaConf = "kafka.conf"

KafkaConf is default (flag value) - filename for the configuration.

const KafkaConfFlag = "kafka-config"

KafkaConfFlag used as flag name (see implementation in declareFlags()) It is used to load configuration of Kafka client plugin. This flag name is calculated from the name of the plugin.

const KafkaConfUsage = "Location of the Kafka configuration file; also set via 'KAFKA_CONFIG' env variable."

KafkaConfUsage used as flag usage (see implementation in declareFlags())

const RedisConf = "redis.conf"

RedisConf is default (flag value) - filename for the configuration.

const RedisConfFlag = "redis-config"

RedisConfFlag used as flag name (see implementation in declareFlags()) It is used to load configuration of Redis client plugin. This flag name is calculated from the name of the plugin.

const RedisConfUsage = "Location of Redis configuration file; Can also be set via environment variable REDIS_CONFIG"

RedisConfUsage used as flag usage (see implementation in declareFlags())

Functions

func InjectKVDBSync

func InjectKVDBSync(dbsync *kvdbsync.Plugin,
	db keyval.KvProtoPlugin, dbPlugName core.PluginName, local *local.FlavorLocal, resync resync.Subscriber)

InjectKVDBSync sets kvdbsync.Plugin dependencies. The intent of this method is just extract code that would be copy&pasted otherwise.

Types

type AllConnectorsFlavor

type AllConnectorsFlavor struct {
	*local.FlavorLocal

	ETCD         etcdv3.Plugin
	ETCDDataSync kvdbsync.Plugin

	Kafka kafka.Plugin

	Redis         redis.Plugin
	RedisDataSync kvdbsync.Plugin

	Cassandra cassandra.Plugin

	ResyncOrch resync.Plugin // the order is important because of AfterInit()
	// contains filtered or unexported fields
}

AllConnectorsFlavor is combination of all plugins that allow connectivity to external database/messaging... Effectively it is combination of ETCD, Kafka, Redis, Cassandra plugins.

User/admin can enable those plugins/connectors by providing configs (at least endpoints) for them.

func (*AllConnectorsFlavor) Inject

func (f *AllConnectorsFlavor) Inject() bool

Inject sets object references

func (*AllConnectorsFlavor) Plugins

func (f *AllConnectorsFlavor) Plugins() []*core.NamedPlugin

Plugins combines all Plugins in flavor to the list