Fetch

Documentation

Index

• func NewRequest(args *Args) *api.Request
• type AbortedTransaction
• type Args
• type Partition
• type PartitionResponse
• type Request
• type Response
  • func (r *Response) PartitionResponse() *PartitionResponse
• type Topic
• type TopicResponse

Functions

func NewRequest

func NewRequest(args *Args) *api.Request

Types

type AbortedTransaction

type AbortedTransaction struct {
	ProducerId  int64
	FirstOffset int64
}

type Args

type Args struct {
	ClientId      string
	Topic         string
	Partition     int32
	Offset        int64
	MinBytes      int32
	MaxBytes      int32
	MaxWaitTimeMs int32
}

type Partition

type Partition struct {
	Partition         int32
	FetchOffset       int64
	LogStartOffset    int64 // not used
	PartitionMaxBytes int32
}

type PartitionResponse

type PartitionResponse struct {
	Partition           int32
	ErrorCode           int16
	HighWatermark       int64
	LastStableOffset    int64
	LogStartOffset      int64
	AbortedTransactions []AbortedTransaction
	//
	RecordSet []byte // NULLABLE_BYTES
}

type Request

type Request struct {
	ReplicaId      int32
	MaxWaitTimeMs  int32
	MinBytes       int32
	MaxBytes       int32
	IsolationLevel int8 // not used
	Topics         []Topic
}

type Response

type Response struct {
	ThrottleTimeMs int32
	TopicResponses []TopicResponse
}

func (*Response) PartitionResponse

func (r *Response) PartitionResponse() *PartitionResponse

type Topic

type Topic struct {
	Topic      string
	Partitions []Partition
}

type TopicResponse

type TopicResponse struct {
	Topic              string
	PartitionResponses []PartitionResponse
}