franz

type ACL struct {
	Host           string `json:"host"`
	Operation      string `json:"operation"`
	PermissionType string `json:"permissionType" yaml:"action"`
	Principal      string `json:"principal"`
}

type ACLDiff struct {
	ToCreate []sarama.ResourceAcls
	ToDelete []sarama.ResourceAcls
}

type ACLDiffTransformed struct {
	ToCreate KafkaACLs `json:"to_create" yaml:"to_create"`
	ToDelete KafkaACLs `json:"to_delete" yaml:"to_delete"`
}

type ACLs struct {
	Version     int    `json:"version" yaml:"-"`
	Name        string `json:"name" yaml:"name"`
	PatternType string `json:"pattern_type" yaml:"resourcePatternType,omitempty"` // optional, exists only for kafka version 2.1 and above
	ACL         []ACL  `json:"acls" yaml:"acl"`
}

type AlteredConfigs struct {
	TopicName string
	Configs   map[string]*string
}

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

type Config struct {
	KafkaVersion   string
	Brokers        []string
	SchemaRegistry string
	*TLSConfig
}

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

type HistoryRequest struct {
	Topic      string
	From, To   time.Time // To takes precedence over Count
	Count      int64
	Partitions []int32
	Decode     bool
}

type KafkaACLs struct {
	Cluster       []ACLs
	ConsumerGroup []ACLs
	Topic         []ACLs
}

type Message struct {
	Topic      string
	Timestamp  time.Time
	Partition  int32
	Key, Value string
	Offset     int64
}

type MonitorRequest struct {
	Topic      string
	Partitions []int32
	Count      int64
	Follow     bool
	Decode     bool
}

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

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

type Registry interface {
	Subjects() ([]string, error)
	SchemaByID(uint32) (string, error)
	SchemaBySubject(string) (Schema, error)
}

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

type Schema schemaregistry.Schema

type Status struct {
	Topic     string
	Partition int32
	Leader    int32
	Replicas  []int32
	ISR       []int32
	Internal  bool
}

type TLSConfig struct {
	CertFile, KeyFile, CaFile string
}

type Topic struct {
	Name              string               `json:"name" yaml:"name"`
	NumPartitions     int                  `json:"num_partitions" yaml:"partitions"`
	ReplicationFactor int                  `json:"replication_factor" yaml:"replication"`
	Configs           []sarama.ConfigEntry `json:"configs" yaml:"configs"`
}

type TopicDiff struct {
	ToCreate []Topic          `json:"to_create" yaml:"to_create"`
	ToDelete []Topic          `json:"to_delete" yaml:"to_delete"`
	ToAlter  []AlteredConfigs `json:"to_alter" yaml:"to_alter"`
}