siesta

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

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

type Broker struct {
	NodeId int32
	Host   string
	Port   int32
}

type CompressionCodec int

type Connector interface {
	// GetTopicMetadata is primarily used to discover leaders for given topics and how many partitions these topics have.
	// Passing it an empty topic list will retrieve metadata for all topics in a cluster.
	GetTopicMetadata(topics []string) (*TopicMetadataResponse, error)

	// GetAvailableOffset issues an offset request to a specified topic and partition with a given offset time.
	// More on offset time here - https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetRequest
	GetAvailableOffset(topic string, partition int32, offsetTime OffsetTime) (int64, error)

	// Consume issues a single fetch request to a broker responsible for a given topic and partition and returns messages starting from a given offset.
	Consume(topic string, partition int32, offset int64) ([]*Message, error)

	// GetOffset is a part of new offset management API. Not fully functional yet.
	GetOffset(group string, topic string, partition int32) (int64, error)

	// Tells the Connector to close all existing connections and stop.
	// This method is NOT blocking but returns a channel which will get a single value once the closing is finished.
	Close() <-chan bool
}

type ConnectorConfig struct {
	// BrokerList is a bootstrap list to discover other brokers in a cluster. At least one broker is required.
	BrokerList []string

	// ReadTimeout is a timeout to read the response from a TCP socket.
	ReadTimeout time.Duration

	// WriteTimeout is a timeout to write the request to a TCP socket.
	WriteTimeout time.Duration

	// ConnectTimeout is a timeout to connect to a TCP socket.
	ConnectTimeout time.Duration

	// Sets whether the connection should be kept alive.
	KeepAlive bool

	// A keep alive period for a TCP connection.
	KeepAliveTimeout time.Duration

	// Maximum number of open connections for a connector.
	MaxConnections int

	// Maximum number of open connections for a single broker for a connector.
	MaxConnectionsPerBroker int

	// Maximum fetch size in bytes which will be used in all Consume() calls.
	FetchSize int32

	// Number of retries to get topic metadata.
	MetadataRetries int

	// Backoff value between topic metadata requests.
	MetadataBackoff time.Duration

	// Client id that will be used by a connector to identify client requests by broker.
	ClientId string
}

type ConsumerMetadataRequest struct {
	ConsumerGroup string
}

type ConsumerMetadataResponse struct {
	Error           error
	CoordinatorId   int32
	CoordinatorHost string
	CoordinatorPort int32
}

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

type Decoder interface {
	// Gets an int8 from this decoder. Returns EOF if end of stream is reached.
	GetInt8() (int8, error)

	// Gets an int16 from this decoder. Returns EOF if end of stream is reached.
	GetInt16() (int16, error)

	// Gets an int32 from this decoder. Returns EOF if end of stream is reached.
	GetInt32() (int32, error)

	// Gets an int64 from this decoder. Returns EOF if end of stream is reached.
	GetInt64() (int64, error)

	// Gets a []byte from this decoder. Returns EOF if end of stream is reached.
	GetBytes() ([]byte, error)

	// Gets a string from this decoder. Returns EOF if end of stream is reached.
	GetString() (string, error)

	// Tells how many bytes left unread in this decoder.
	Remaining() int
}

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

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

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

type Encoder interface {
	// Writes an int8 to this encoder.
	WriteInt8(int8)

	// Writes an int16 to this encoder.
	WriteInt16(int16)

	// Writes an int32 to this encoder.
	WriteInt32(int32)

	// Writes an int64 to this encoder.
	WriteInt64(int64)

	// Writes a []byte to this encoder.
	WriteBytes([]byte)

	// Writes a string to this encoder.
	WriteString(string)

	// Returns the size in bytes written to this encoder.
	Size() int32

	// Reserves a place for an updatable slice.
	// This is used as an optimization for length and crc fields.
	// The encoder reserves a place for this data and updates it later instead of pre-calculating it and doing redundant work.
	Reserve(UpdatableSlice)

	// Tells the last reserved slice to be updated with new data.
	UpdateReserved()
}

type FetchRequest struct {
	MaxWaitTime int32
	MinBytes    int32
	RequestInfo map[string][]*PartitionFetchInfo
}

type FetchResponse struct {
	Blocks map[string]map[int32]*FetchResponseData
}

type FetchResponseData struct {
	Error               error
	HighwaterMarkOffset int64
	Messages            []*MessageAndOffset
}

type FetchedOffset struct {
	Offset   int64
	Metadata string
	Error    error
}

type KafkaLogger interface {
	//Formats a given message according to given params to log with level Trace.
	Trace(message string, params ...interface{})

	//Formats a given message according to given params to log with level Debug.
	Debug(message string, params ...interface{})

	//Formats a given message according to given params to log with level Info.
	Info(message string, params ...interface{})

	//Formats a given message according to given params to log with level Warn.
	Warn(message string, params ...interface{})

	//Formats a given message according to given params to log with level Error.
	Error(message string, params ...interface{})

	//Formats a given message according to given params to log with level Critical.
	Critical(message string, params ...interface{})
}

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

type LogLevel string

type Message struct {
	Topic     string
	Partition int32
	Offset    int64
	Key       []byte
	Value     []byte
}

type MessageAndOffset struct {
	Offset  int64
	Message *MessageData
}

type MessageData struct {
	Crc        int32
	MagicByte  int8
	Attributes int8
	Key        []byte
	Value      []byte

	Nested []*MessageAndOffset
}

type OffsetAndMetadata struct {
	Offset    int64
	TimeStamp int64
	Metadata  string
}

type OffsetCommitRequest struct {
	ConsumerGroup string
	Offsets       map[string]map[int32]*OffsetAndMetadata
}

type OffsetCommitResponse struct {
	Offsets map[string]map[int32]error
}

type OffsetFetchRequest struct {
	ConsumerGroup string
	Offsets       map[string][]int32
}

type OffsetFetchResponse struct {
	Offsets map[string]map[int32]*FetchedOffset
}

type OffsetRequest struct {
	RequestInfo map[string][]*PartitionOffsetRequestInfo
}

type OffsetResponse struct {
	Offsets map[string]map[int32]*PartitionOffsets
}

type OffsetTime int64

type PartitionFetchInfo struct {
	Partition   int32
	FetchOffset int64
	FetchSize   int32
}

type PartitionMetadata struct {
	Error       error
	PartitionId int32
	Leader      int32
	Replicas    []int32
	Isr         []int32
}

type PartitionOffsetRequestInfo struct {
	Partition     int32
	Time          OffsetTime
	MaxNumOffsets int32
}

type PartitionOffsets struct {
	Error   error
	Offsets []int64
}

type ProduceRequest struct {
	RequiredAcks int16
	Timeout      int32
	Messages     map[string]map[int32][]*MessageAndOffset
}

type ProduceResponse struct {
	Blocks map[string]map[int32]*ProduceResponseData
}

type ProduceResponseData struct {
	Error  error
	Offset int64
}

type Request interface {
	// Writes the Request to the given Encoder.
	Write(Encoder)

	// Returns the Kafka API key for this Request.
	Key() int16

	// Returns the Kafka request version for backwards compatibility.
	Version() int16
}

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

type Response interface {
	// Read the Response from the given Decoder. May return a DecodingError if the response is invalid.
	Read(Decoder) *DecodingError
}

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

type TopicMetadata struct {
	Error             error
	TopicName         string
	PartitionMetadata []*PartitionMetadata
}

type TopicMetadataRequest struct {
	Topics []string
}

type TopicMetadataResponse struct {
	Brokers       []*Broker
	TopicMetadata []*TopicMetadata
}

type UpdatableSlice interface {
	// Returns the length to reserve for this slice.
	GetReserveLength() int

	// Set the current position within the encoder to be updated later.
	SetPosition(int)

	// Get the position within the encoder to be updated later.
	GetPosition() int

	// Update this slice. At this point all necessary data should be written to encoder.
	Update([]byte)
}