franz

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

type Broker struct {
	Host string
	Port int
	ID   int
}

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

type ConnConfig struct {
	ClientID  string
	Topic     string
	Partition int
}

type DescribeGroupsRequestV1 struct {
	// List of groupIds to request metadata for (an empty groupId array
	// will return empty group metadata).
	GroupIDs []string
}

type DescribeGroupsResponseV1 struct {
	// Duration in milliseconds for which the request was throttled due
	// to quota violation (Zero if the request did not violate any quota)
	ThrottleTimeMS int32

	// Groups holds selected group information
	Groups []DescribeGroupsResponseV1Group
}

type DescribeGroupsResponseV1Group struct {
	// ErrorCode holds response error code
	ErrorCode int16

	// GroupID holds the unique group identifier
	GroupID string

	// State holds current state of the group (one of: Dead, Stable, AwaitingSync,
	// PreparingRebalance, or empty if there is no active group)
	State string

	// ProtocolType holds the current group protocol type (will be empty if there is
	// no active group)
	ProtocolType string

	// Protocol holds the current group protocol (only provided if the group is Stable)
	Protocol string

	// Members contains the current group members (only provided if the group is not Dead)
	Members []DescribeGroupsResponseV1Member
}

type DescribeGroupsResponseV1Member struct {
	// MemberID assigned by the group coordinator
	MemberID string

	// ClientID used in the member's latest join group request
	ClientID string

	// ClientHost used in the request session corresponding to the member's
	// join group.
	ClientHost string

	// MemberMetadata the metadata corresponding to the current group protocol
	// in use (will only be present if the group is stable).
	MemberMetadata []byte

	// MemberAssignments provided by the group leader (will only be present if
	// the group is stable).
	//
	// See consumer groups section of https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
	MemberAssignments []byte
}

type Dialer struct {
	// Unique identifier for client connections established by this Dialer.
	ClientID string

	// Timeout is the maximum amount of time a dial will wait for a connect to
	// complete. If Deadline is also set, it may fail earlier.
	//
	// The default is no timeout.
	//
	// When dialing a name with multiple IP addresses, the timeout may be
	// divided between them.
	//
	// With or without a timeout, the operating system may impose its own
	// earlier timeout. For instance, TCP timeouts are often around 3 minutes.
	Timeout time.Duration

	// Deadline is the absolute point in time after which dials will fail.
	// If Timeout is set, it may fail earlier.
	// Zero means no deadline, or dependent on the operating system as with the
	// Timeout option.
	Deadline time.Time

	// LocalAddr is the local address to use when dialing an address.
	// The address must be of a compatible type for the network being dialed.
	// If nil, a local address is automatically chosen.
	LocalAddr net.Addr

	// DualStack enables RFC 6555-compliant "Happy Eyeballs" dialing when the
	// network is "tcp" and the destination is a host name with both IPv4 and
	// IPv6 addresses. This allows a client to tolerate networks where one
	// address family is silently broken.
	DualStack bool

	// FallbackDelay specifies the length of time to wait before spawning a
	// fallback connection, when DualStack is enabled.
	// If zero, a default delay of 300ms is used.
	FallbackDelay time.Duration

	// KeepAlive specifies the keep-alive period for an active network
	// connection.
	// If zero, keep-alives are not enabled. Network protocols that do not
	// support keep-alives ignore this field.
	KeepAlive time.Duration

	// Resolver optionally specifies an alternate resolver to use.
	Resolver Resolver

	// TLS enables Dialer to open secure connections.  If nil, standard net.Conn
	// will be used.
	TLS *tls.Config
}

type DurationStats struct {
	Avg time.Duration `metric:"avg" type:"gauge"`
	Min time.Duration `metric:"min" type:"gauge"`
	Max time.Duration `metric:"max" type:"gauge"`
}

type Error int

type FindCoordinatorRequestV1 struct {
	// CoordinatorKey holds id to use for finding the coordinator (for groups, this is
	// the groupId, for transactional producers, this is the transactional id)
	CoordinatorKey string

	// CoordinatorType indicates type of coordinator to find (0 = group, 1 = transaction)
	CoordinatorType int8
}

type FindCoordinatorResponseV1 struct {
	// ThrottleTimeMS holds the duration in milliseconds for which the request
	// was throttled due to quota violation (Zero if the request did not violate
	// any quota)
	ThrottleTimeMS int32

	// ErrorCode holds response error code
	ErrorCode int16

	// ErrorMessage holds response error message
	ErrorMessage string

	// Coordinator holds host and port information for the coordinator
	Coordinator FindCoordinatorResponseV1Coordinator
}

type FindCoordinatorResponseV1Coordinator struct {
	// NodeID holds the broker id.
	NodeID int32

	// Host of the broker
	Host string

	// Port on which broker accepts requests
	Port int32
}

type ListGroupsRequestV1 struct {
}

type ListGroupsResponseV1 struct {
	// ThrottleTimeMS holds the duration in milliseconds for which the request
	// was throttled due to quota violation (Zero if the request did not violate
	// any quota)
	ThrottleTimeMS int32

	// ErrorCode holds response error code
	ErrorCode int16
	Groups    []ListGroupsResponseV1Group
}

type ListGroupsResponseV1Group struct {
	// GroupID holds the unique group identifier
	GroupID      string
	ProtocolType string
}

type ListOffsetRequestV1 struct {
	ReplicaID int32
	Topics    []ListOffsetRequestV1Topic
}

type ListOffsetRequestV1Partition struct {
	Partition int32

	// Time is used to ask for all messages before a certain time (ms).
	//
	// There are two special values. Specify -1 to receive the latest offset (i.e.
	// the offset of the next coming message) and -2 to receive the earliest
	// available offset. This applies to all versions of the API. Note that because
	// offsets are pulled in descending order, asking for the earliest offset will
	// always return you a single element.
	Time int64
}

type ListOffsetRequestV1Topic struct {
	TopicName  string
	Partitions []ListOffsetRequestV1Partition
}

type ListOffsetResponseV1 struct {
	Responses []ListOffsetResponseV1Response
}

type ListOffsetResponseV1Partition struct {
	Partition int32
	ErrorCode int16
	Timestamp int64
	Offset    int64
}

type ListOffsetResponseV1Response struct {
	Topic              string
	PartitionResponses []ListOffsetResponseV1Partition
}

type Message struct {
	// Topic is reads only and MUST NOT be set when writing messages
	Topic string

	// Partition is reads only and MUST NOT be set when writing messages
	Partition int
	Offset    int64
	Key       []byte
	Value     []byte
	Time      time.Time
}

type MetadataRequestV0 []string

type MetadataResponseV0 struct {
	Brokers []*MetadataResponseV0Broker
	Topics  []*MetadataResponseV0Topic
}

type MetadataResponseV0Broker struct {
	NodeID int32
	Host   string
	Port   int32
}

type MetadataResponseV0Partition struct {
	PartitionErrorCode int16
	PartitionID        int32
	Leader             int32
	Replicas           []int32
	Isr                []int32
}

type MetadataResponseV0Topic struct {
	TopicErrorCode int16
	TopicName      string
	Partitions     []MetadataResponseV0Partition
}

type OffsetFetchRequestV3 struct {
	// GroupID holds the unique group identifier
	GroupID string

	// Topics to fetch offsets.
	Topics []OffsetFetchRequestV3Topic
}

type OffsetFetchRequestV3Topic struct {
	// Topic name
	Topic string

	// Partitions to fetch offsets
	Partitions []int32
}

type OffsetFetchResponseV3 struct {
	// ThrottleTimeMS holds the duration in milliseconds for which the request
	// was throttled due to quota violation (Zero if the request did not violate
	// any quota)
	ThrottleTimeMS int32

	// Responses holds topic partition offsets
	Responses []OffsetFetchResponseV3Response

	// ErrorCode holds response error code
	ErrorCode int16
}

type OffsetFetchResponseV3PartitionResponse struct {
	// Partition ID
	Partition int32

	// Offset of last committed message
	Offset int64

	// Metadata client wants to keep
	Metadata string

	// ErrorCode holds response error code
	ErrorCode int16
}

type OffsetFetchResponseV3Response struct {
	// Topic name
	Topic string

	// PartitionResponses holds offsets by partition
	PartitionResponses []OffsetFetchResponseV3PartitionResponse
}

type Partition struct {
	Topic    string
	Leader   Broker
	Replicas []Broker
	Isr      []Broker
	ID       int
}

type Resolver interface {
	// LookupHost looks up the given host using the local resolver.
	// It returns a slice of that host's addresses.
	LookupHost(ctx context.Context, host string) (addrs []string, err error)
}

type SummaryStats struct {
	Avg int64 `metric:"avg" type:"gauge"`
	Min int64 `metric:"min" type:"gauge"`
	Max int64 `metric:"max" type:"gauge"`
}