configs

type Ack string

type Compression struct {
	Name  string `json:"name"`
	Level int    `json:"level"`
}

type Config struct {
	Generic
	Producers ProducerConfig            `json:"producers"`
	Consumers map[string]ConsumerConfig `json:"consumers"`
}

type ConsumerConfig struct {
	MaxPollRecords           int             `json:"maxPollRecords"`
	PartitionBuffer          int             `json:"partitionBuffer"`
	MaxWait                  time.Duration   `json:"maxWait"`
	MinBytes                 string          `json:"minBytes"`
	MaxBytes                 string          `json:"maxBytes"`
	MaxPartitionBytes        string          `json:"maxPartitionBytes"`
	Isolation                IsolationLevel  `json:"isolation"`
	KeepControl              bool            `json:"keepControl"`
	Rack                     string          `json:"rack"`
	MaxConcurrentFetches     int             `json:"maxConcurrentFetches"`
	KeepRetryableFetchErrors bool            `json:"keepRetryableFetchErrors"`
	Group                    string          `json:"group"` // group we are in
	Topics                   []string        `json:"topics"`
	Balancers                []GroupBalancer `json:"balancers"` // balancers we can use
	SessionTimeout           time.Duration   `json:"sessionTimeout"`
	RebalanceTimeout         time.Duration   `json:"rebalanceTimeout"`
	HeartbeatInterval        time.Duration   `json:"heartbeatInterval"`
	RequireStable            bool            `json:"requireStable"`
}

type Generic struct {
	Brokers                []string      `json:"brokers"`
	DialTimeout            time.Duration `json:"dialTimeout"`
	RequestTimeoutOverhead time.Duration `json:"requestTimeoutOverhead"`
	ConnIdleTimeout        time.Duration `json:"connIdleTimeout"`
	Retries                int           `json:"retries"`
	RetryTimeout           time.Duration `json:"retryTimeout"`
	MaxBrokerWriteBytes    string        `json:"maxBrokerWriteBytes"`
	MaxBrokerReadBytes     string        `json:"maxBrokerReadBytes"`
	AllowAutoTopicCreation bool          `json:"allowAutoTopicCreation"`
	Meta                   MetaConfig    `json:"meta"`
	SASL                   SASLConfig    `json:"sasl"`
	SSL                    SSLConfig     `json:"ssl"`
}

type GroupBalancer string

type IsolationLevel string

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

type Mechanism interface {
	Name() string
	Construct(options MechanismOptions) (err error)
	Authenticate(ctx context.Context, host string) (Session, []byte, error)
	Shutdown()
}

type MechanismOptions struct {
	Log    logs.Logger
	Config configures.Config
}

type MetaConfig struct {
	MaxAge time.Duration `json:"maxAge"`
	MinAge time.Duration `json:"minAge"`
}

type OffsetManagerConfig struct {
	Name    string          `json:"name"`
	Options json.RawMessage `json:"options"`
}

type Partitioner struct {
	Name    string          `json:"name"`
	Options json.RawMessage `json:"options"`
}

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

type PlainSASLConfig struct {
	Zid      string `json:"zid"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type ProducerConfig struct {
	Enable                bool          `json:"enable"`
	Num                   int           `json:"num"`
	Ack                   Ack           `json:"ack"`
	DisableIdempotency    bool          `json:"disableIdempotency"`
	MaxInflight           int           `json:"maxInflight"` // if idempotency is disabled, we allow a configurable max inflight
	Compressions          []Compression `json:"compressions"`
	MaxRecordBatchBytes   string        `json:"maxRecordBatchBytes"`
	MaxBufferedRecords    int           `json:"maxBufferedRecords"`
	MaxBufferedBytes      string        `json:"maxBufferedBytes"`
	Timeout               time.Duration `json:"timeout"`
	RecordRetries         int           `json:"recordRetries"`
	MaxUnknownFailures    int           `json:"maxUnknownFailures"`
	Linger                time.Duration `json:"linger"`
	RecordDeliveryTimeout time.Duration `json:"recordDeliveryTimeout"`
	Partitioner           *Partitioner  `json:"partitioner"`
}

type SASLConfig struct {
	Name    string          `json:"name"`
	Options json.RawMessage `json:"options"`
}

type SSLConfig struct {
	Enable bool `json:"enable"`
	configs.Client
}

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

type ScramSASLConfig struct {
	Zid      string `json:"zid"`
	Username string `json:"username"`
	Password string `json:"password"`
	Algo     string `json:"algo"`
}

type Session interface {
	Challenge([]byte) (bool, []byte, error)
}