kafkaapi

type AbortedTransaction struct {
	ProducerID  value.Int64
	FirstOffset value.Int64
}

type ApiKeyEntry struct {
	// ApiKey contains the API index.
	ApiKey value.Int16
	// MinVersion contains the minimum supported version, inclusive.
	MinVersion value.Int16
	// MaxVersion contains the maximum supported version, inclusive.
	MaxVersion value.Int16
}

type ApiVersionsRequest struct {
	Header headers.RequestHeader
	Body   ApiVersionsRequestBody
}

type ApiVersionsRequestBody struct {
	// Version defines the protocol version to use for encode and decode
	Version value.Int16
	// ClientSoftwareName contains the name of the client.
	ClientSoftwareName value.CompactString
	// ClientSoftwareVersion contains the version of the client.
	ClientSoftwareVersion value.CompactString
}

type ApiVersionsResponse struct {
	Header headers.ResponseHeader
	Body   ApiVersionsResponseBody
}

type ApiVersionsResponseBody struct {
	// Version defines the protocol version to use for encode and decode
	Version int16
	// ErrorCode contains the top-level error code.
	ErrorCode value.Int16
	// ApiKeys contains the APIs supported by the broker.
	ApiKeys []ApiKeyEntry
	// ThrottleTimeMs contains the duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota.
	ThrottleTimeMs value.Int32
}

type ClusterMetadataPayload struct {
	FrameVersion int8
	Type         int8
	Version      int8
	Data         ClusterMetadataPayloadDataRecord
}

type ClusterMetadataPayloadDataRecord interface {
	GetEncodedBytes() []byte
	// contains filtered or unexported methods
}

type Cursor struct {
	TopicName      value.CompactString
	PartitionIndex value.Int32
}

type DescribeTopicPartitionsRequest struct {
	Header headers.RequestHeader
	Body   DescribeTopicPartitionsRequestBody
}

type DescribeTopicPartitionsRequestBody struct {
	TopicNames             []value.CompactString
	ResponsePartitionLimit value.Int32
	// This is unused because we don't test using cursors in this extension
	Cursor *Cursor
}

type DescribeTopicPartitionsResponse struct {
	Header headers.ResponseHeader
	Body   DescribeTopicPartitionsResponseBody
}

type DescribeTopicPartitionsResponseBody struct {
	ThrottleTimeMs value.Int32
	Topics         []DescribeTopicPartitionsResponseTopic
	NextCursor     DescribeTopicPartitionsResponseCursor
}

type DescribeTopicPartitionsResponseCursor struct {
	TopicName      value.CompactString
	PartitionIndex value.Int32
}

type DescribeTopicPartitionsResponsePartition struct {
	ErrorCode              value.Int16
	PartitionIndex         value.Int32
	LeaderId               value.Int32
	LeaderEpoch            value.Int32
	ReplicaNodes           []value.Int32
	IsrNodes               []value.Int32
	EligibleLeaderReplicas []value.Int32
	LastKnownElr           []value.Int32
	OfflineReplicas        []value.Int32
}

type DescribeTopicPartitionsResponseTopic struct {
	ErrorCode                 value.Int16
	Name                      value.CompactNullableString
	TopicUUID                 value.UUID
	IsInternal                value.Boolean
	Partitions                []DescribeTopicPartitionsResponsePartition
	TopicAuthorizedOperations value.Int32
}

type FeatureLevelRecord struct {
	Name         string
	FeatureLevel int16
}

type FetchRequest struct {
	Header headers.RequestHeader
	Body   FetchRequestBody
}

type FetchRequestBody struct {
	MaxWaitMS       value.Int32
	MinBytes        value.Int32
	MaxBytes        value.Int32
	IsolationLevel  value.Int8
	SessionId       value.Int32
	SessionEpoch    value.Int32
	Topics          []Topic
	ForgottenTopics []ForgottenTopic
	RackId          value.CompactString
}

type FetchResponse struct {
	Header headers.ResponseHeader
	Body   FetchResponseBody
}

type FetchResponseBody struct {
	ThrottleTimeMs value.Int32
	ErrorCode      value.Int16
	SessionId      value.Int32
	TopicResponses []TopicResponse
}

type ForgottenTopic struct {
	UUID         value.UUID
	PartitionIds []value.Int32
}

type Partition struct {
	ID                 value.Int32 // partition id
	CurrentLeaderEpoch value.Int32 // current leader epoch
	FetchOffset        value.Int64 // fetch offset
	LastFetchedOffset  value.Int32 // last fetched offset
	LogStartOffset     value.Int64 // log start offset
	PartitionMaxBytes  value.Int32 // max bytes to fetch
}

type PartitionRecord struct {
	PartitionId      int32
	TopicUUID        string
	Replicas         []int32
	ISReplicas       []int32
	RemovingReplicas []int32
	AddingReplicas   []int32
	Leader           int32
	LeaderEpoch      int32
	PartitionEpoch   int32
	DirectoryUUIDs   []string
}

type PartitionResponse struct {
	Id                   value.Int32
	ErrorCode            value.Int16
	HighWatermark        value.Int64
	LastStableOffset     value.Int64
	LogStartOffset       value.Int64
	AbortedTransactions  []AbortedTransaction
	RecordBatches        []RecordBatch
	PreferredReadReplica value.Int32
}

type Record struct {
	Length         value.Int32
	Attributes     value.Int8
	TimestampDelta value.Varint
	OffsetDelta    value.Varint
	Key            []byte
	Value          []byte
	Headers        []RecordHeader
}

type RecordBatch struct {
	BaseOffset           value.Int64
	BatchLength          value.Int32
	PartitionLeaderEpoch value.Int32
	Magic                value.Int8
	CRC                  value.Int32
	Attributes           value.Int16
	LastOffsetDelta      value.Int32
	FirstTimestamp       value.Int64
	MaxTimestamp         value.Int64
	ProducerId           value.Int64
	ProducerEpoch        value.Int16
	BaseSequence         value.Int32
	Records              []Record
}

type RecordBatches []RecordBatch

type RecordHeader struct {
	Key   value.RawBytes
	Value value.RawBytes
}

type Topic struct {
	UUID       value.UUID
	Partitions []Partition
}

type TopicRecord struct {
	TopicName string
	TopicUUID string
}

type TopicResponse struct {
	UUID               value.UUID
	PartitionResponses []PartitionResponse
}