internal

type AuthConfiguration struct {
	Method     string `yaml:"method,omitempty"` // either tls or sasl
	RootCAFile string `yaml:"root_ca_file,omitempty"`

	Username string `yaml:"username,omitempty"` // only used when method=sasl
	Password string `yaml:"password,omitempty"` // only used when method=sasl

	KeyFile         string `yaml:"key_file,omitempty"`         // only used when method=tls
	CertificateFile string `yaml:"certificate_file,omitempty"` // only used when method=tls
}

type AvroDecoder struct {
	// contains filtered or unexported fields
}

type Configuration struct {
	APIVersion      string `yaml:"api_version"`
	CurrentContext  string `yaml:"current_context"`
	PreviousContext string `yaml:"previous_context,omitempty"`

	Contexts []ContextConfiguration   `yaml:"contexts"`
	Topics   []*TopicConfig           `yaml:"topics,omitempty"`
	Proto    GlobalProtoDecoderConfig `yaml:"proto,omitempty"`
}

type ConfluentSchemaRegistry struct {
	// contains filtered or unexported fields
}

type Consumer struct {
	// contains filtered or unexported fields
}

type ContextConfiguration struct {
	Name    string            `yaml:"name"`
	Brokers []string          `yaml:"brokers"`
	Auth    AuthConfiguration `yaml:"auth,omitempty"`

	SchemaRegistry SchemaRegistryConfiguration `yaml:"schema_registry,omitempty"`
}

type Decoder interface {
	Decode(*sarama.ConsumerMessage) (*Message, error)
}

type Encoder interface {
	Encode(msg string) (sarama.Encoder, error)
}

type GlobalProtoDecoderConfig struct {
	Includes []string `yaml:"includes,omitempty"`
}

type Message struct {
	Topic     string
	Partition int32
	Offset    int64
	Headers   map[string][]string
	Timestamp time.Time
	Key       any
	Value     any
}

type OffsetConsumer struct {
	// contains filtered or unexported fields
}

type PartitionOffset struct {
	Partition int32
	Offset    int64 // can also be sarama.Newest or sarama.Oldest
}

type PartitionOffsetRange struct {
	Partition int32
	From      int64
	Until     *int64 // optional
}

type PartitionOffsets struct {
	Partition int32
	Offsets   []int64
}

type ProtoConfig struct {
	Includes []string
	File     string
	Type     string
}

type ProtoDecoder struct {
	// contains filtered or unexported fields
}

type ProtoEncoder struct {
	// contains filtered or unexported fields
}

type RangeConsumer struct {
	// contains filtered or unexported fields
}

type SchemaRegistry interface {
	Schema(id int) (string, error)
}

type SchemaRegistryConfiguration struct {
	URL      string `yaml:"url"`
	Username string `yaml:"username,omitempty"`
	Password string `yaml:"password,omitempty"`
}

type StringDecoder struct{}

type StringEncoder struct{}

type TopicConfig struct {
	Name   string            `yaml:"name"`
	Schema TopicSchemaConfig `yaml:"schema,omitempty"`
}

type TopicProtoConfig struct {
	Type string `yaml:"type,omitempty"`
	File string `yaml:"file,omitempty"`
}

type TopicSchemaConfig struct {
	Type  string           `yaml:"type"` // "avro" or "proto"
	Proto TopicProtoConfig `yaml:"proto,omitempty"`
}