datacommunicator

type KafkaF struct {

	// KServersInfo defines the list of Kafka Server URI/Nodename:port. DEFAULT = [localhost:9092]
	KServersInfo []string `toml:"KServersInfo"`
	// KTimeout defines the timeout for Kafka Server connection.
	// DEFAULT = 10 (in seconds)
	KTimeout int `toml:"KTimeout"`
	// KAFKACertFile defines the TLS Certificate File for KAFKA. No DEFAULT
	KAFKACertFile string `toml:"KAFKACertFile"`
	// KAFKAKeyFile defines the TLS Key File for KAFKA. No DEFAULT
	KAFKAKeyFile string `toml:"KAFKAKeyFile"`
	// KAFKACAFile defines the KAFKA Certification Authority. No DEFAULT
	KAFKACAFile string `toml:"KAFKACAFile"`
}

type KafkaPacket struct {
	// All common base function objects are defined in this object. This
	// object will support only Publishing and Subscriptions based on KAFKA
	// support. We use KAFKA 2.2.0 with Scala 2.12.
	Packet

	// DialerConn defines the member which can be used for single connection
	// towards KAFKA
	DialerConn *kafka.Dialer

	// ServerInfo  defines list of the KAFKA server with port
	ServersInfo []string
	// contains filtered or unexported fields
}

type MQBus interface {
	Distribute(data interface{}) error
	Accept(fn MsgProcess) error
	Get(pipe string, d interface{}) interface{}
	Remove() error
	Close() error
}

type MQF struct {
	KafkaF       *KafkaF       `toml:"KAFKA"`
	RedisStreams *RedisStreams `toml:"RedisStreams"`
}

type MsgProcess func(d interface{})

type Packet struct {
	// BrokerType defines the underline MQ platform
	BrokerType string
}

type RedisStreams struct {
	RedisServerAddress             string `toml:"RedisServerAddress"`
	RedisServerPort                string `toml:"RedisServerPort"`
	SentinalAddress                string `toml:"SentinalAddress"`
	RedisCertFile                  string `toml:"RedisCertFile"`
	RedisKeyFile                   string `toml:"RedisKeyFile"`
	RedisCAFile                    string `toml:"RedisCAFile"`
	RSAPrivateKeyPath              string `toml:"RSAPrivateKeyPath"`
	RedisInMemoryEncryptedPassword string `toml:"RedisInMemoryEncryptedPassword"`
	RSAPrivateKey                  []byte
	RedisInMemoryPassword          []byte
}

type RedisStreamsPacket struct {
	Packet
	// contains filtered or unexported fields
}