brokers

Documentation

Index

• Constants
• Variables
• type BrokerConfiguration
• type BrokerStatusArray
  • func (bsa *BrokerStatusArray) Brokers() utils.StringArray
• type Brokers
• type ChannelBroker

Constants

const (
	Kafka string = "kafka"
)

All possible broker names supported by Inspr

Variables

var SupportedBrokers = []string{
	Kafka,
}

SupportedBrokers is a list of all supported brokers

Types

type BrokerConfiguration

type BrokerConfiguration interface {
	Broker() string
}

BrokerConfiguration generic interface type

type BrokerStatusArray

type BrokerStatusArray map[string]BrokerConfiguration

BrokerStatusArray generic status array, used to return brokers data

func (*BrokerStatusArray) Brokers

func (bsa *BrokerStatusArray) Brokers() utils.StringArray

Brokers returns an array containing the name of all availible brokers

type Brokers

type Brokers struct {
	Default   string
	Available BrokerStatusArray
}

Brokers define all Available brokers on Insprd and its default broker

type ChannelBroker

type ChannelBroker struct {
	ChName string
	Broker string
}

ChannelBroker associates channel names with their brokers, used to recover data from enviroment