config

Documentation

Index

• type Cluster
  • func (c Cluster) GetName() string
• type Configuration
  • func (c *Configuration) GetClusterByName(name string) (Cluster, bool)
  • func (c *Configuration) GetCurrentCluster() Cluster
  • func (c *Configuration) GetTopicByName(name string) (Topic, bool)
  • func (c *Configuration) SetCluster(cluster Cluster)
  • func (c *Configuration) SetCurrentCluster(name string) bool
  • func (c *Configuration) SetTopic(topic Topic)
• type Encoding
• type SASL
• type TLS
• type Topic
  • func (t Topic) GetName() string

Types

type Cluster

type Cluster struct {
	Name              string   `yaml:"name,omitempty"`
	Brokers           []string `yaml:"brokers,omitempty"`
	Version           string   `yaml:"version,omitempty"`
	SASL              *SASL    `yaml:"sasl,omitempty"`
	TLS               *TLS     `yaml:"tls,omitempty"`
	SecurityProtocol  string   `yaml:"security_protocol,omitempty"`
	SchemaRegistryURL string   `yaml:"schema_registry_url,omitempty"`
}

func (Cluster) GetName

func (c Cluster) GetName() string

type Configuration

type Configuration struct {
	CurrentCluster string    `yaml:"current_cluster"`
	Clusters       []Cluster `yaml:"clusters"`
	Topics         []Topic   `yaml:"topics"`
}

func (*Configuration) GetClusterByName

func (c *Configuration) GetClusterByName(name string) (Cluster, bool)

func (*Configuration) GetCurrentCluster

func (c *Configuration) GetCurrentCluster() Cluster

func (*Configuration) GetTopicByName

func (c *Configuration) GetTopicByName(name string) (Topic, bool)

func (*Configuration) SetCluster

func (c *Configuration) SetCluster(cluster Cluster)

func (*Configuration) SetCurrentCluster

func (c *Configuration) SetCurrentCluster(name string) bool

func (*Configuration) SetTopic

func (c *Configuration) SetTopic(topic Topic)

type Encoding

type Encoding string

const (
	MSGPack  Encoding = "msgpack"
	Protobuf Encoding = "protobuf"
	Avro     Encoding = "avro"
	RAW      Encoding = "raw"
	Base64   Encoding = "base64"
)

type SASL

type SASL struct {
	Mechanism    string `yaml:"mechanism,omitempty"`
	Username     string `yaml:"username,omitempty"`
	Password     string `yaml:"password,omitempty"`
	ClientID     string `yaml:"client_id,omitempty"`
	ClientSecret string `yaml:"client_secret,omitempty"`
	TokenURL     string `yaml:"token_url,omitempty"`
	Token        string `yaml:"token,omitempty"`
}

type TLS

type TLS struct {
	Cafile        string `yaml:"cafile,omitempty"`
	Clientfile    string `yaml:"clientfile,omitempty"`
	Clientkeyfile string `yaml:"clientkeyfile,omitempty"`
	Insecure      bool   `yaml:"insecure,omitempty"`
}

type Topic

type Topic struct {
	Name              string   `yaml:"name"`
	Encoding          Encoding `yaml:"encoding,omitempty"`
	ProtoType         string   `yaml:"proto_type,omitempty"`
	ProtoPaths        []string `yaml:"proto_paths,omitempty"`
	ProtoExcludePaths []string `yaml:"proto_exclude_paths,omitempty"`
	AvroSchemaURL     string   `yaml:"avro_schema_url,omitempty"`
	AvroSchemaID      int      `yaml:"avro_schema_id,omitempty"`
}

func (Topic) GetName

func (t Topic) GetName() string