apiv1

package
v0.0.0-...-db7883e Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ConsumerGroupState_name = map[int32]string{
		0: "CONSUMER_GROUP_STATE_UNSPECIFIED",
		1: "CONSUMER_GROUP_STATE_PREPARING_REBALANCE",
		2: "CONSUMER_GROUP_STATE_COMPLETING_REBALANCE",
		3: "CONSUMER_GROUP_STATE_STABLE",
		4: "CONSUMER_GROUP_STATE_DEAD",
		5: "CONSUMER_GROUP_STATE_EMPTY",
	}
	ConsumerGroupState_value = map[string]int32{
		"CONSUMER_GROUP_STATE_UNSPECIFIED":          0,
		"CONSUMER_GROUP_STATE_PREPARING_REBALANCE":  1,
		"CONSUMER_GROUP_STATE_COMPLETING_REBALANCE": 2,
		"CONSUMER_GROUP_STATE_STABLE":               3,
		"CONSUMER_GROUP_STATE_DEAD":                 4,
		"CONSUMER_GROUP_STATE_EMPTY":                5,
	}
)

Enum value maps for ConsumerGroupState.

View Source 
var File_api_v1_api_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_consumer_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_index_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_record_proto protoreflect.FileDescriptor
View Source 
var File_api_v1_timeindex_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CarnaxConfig 

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

func (*CarnaxConfig) Descriptor deprecated 

func (*CarnaxConfig) Descriptor() ([]byte, []int)

Deprecated: Use CarnaxConfig.ProtoReflect.Descriptor instead.

func (*CarnaxConfig) ProtoMessage 

func (*CarnaxConfig) ProtoMessage()

func (*CarnaxConfig) ProtoReflect 

func (x *CarnaxConfig) ProtoReflect() protoreflect.Message

func (*CarnaxConfig) Reset 

func (x *CarnaxConfig) Reset()

func (*CarnaxConfig) String 

func (x *CarnaxConfig) String() string

type ConsumerGroupDescriptor 

type ConsumerGroupDescriptor struct {
	Id                 string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topics             []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	ActiveGenerationId uint64   `protobuf:"varint,3,opt,name=active_generation_id,json=activeGenerationId,proto3" json:"active_generation_id,omitempty"`
	// client.id -> node
	RegisteredClients map[string]*ConsumerGroupNode `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConsumerGroupDescriptor

func (*ConsumerGroupDescriptor) Descriptor deprecated 

func (*ConsumerGroupDescriptor) Descriptor() ([]byte, []int)

Deprecated: Use ConsumerGroupDescriptor.ProtoReflect.Descriptor instead.

func (*ConsumerGroupDescriptor) GetActiveGenerationId 

func (x *ConsumerGroupDescriptor) GetActiveGenerationId() uint64

func (*ConsumerGroupDescriptor) GetId 

func (x *ConsumerGroupDescriptor) GetId() string

func (*ConsumerGroupDescriptor) GetRegisteredClients 

func (x *ConsumerGroupDescriptor) GetRegisteredClients() map[string]*ConsumerGroupNode

func (*ConsumerGroupDescriptor) GetTopics 

func (x *ConsumerGroupDescriptor) GetTopics() []string

func (*ConsumerGroupDescriptor) ProtoMessage 

func (*ConsumerGroupDescriptor) ProtoMessage()

func (*ConsumerGroupDescriptor) ProtoReflect 

func (x *ConsumerGroupDescriptor) ProtoReflect() protoreflect.Message

func (*ConsumerGroupDescriptor) Reset 

func (x *ConsumerGroupDescriptor) Reset()

func (*ConsumerGroupDescriptor) String 

func (x *ConsumerGroupDescriptor) String() string

type ConsumerGroupNode 

type ConsumerGroupNode struct {
	ConsumerGroupId    string             `protobuf:"bytes,1,opt,name=consumer_group_id,json=consumerGroupId,proto3" json:"consumer_group_id,omitempty"`
	AssignedPartitions []*TopicPartition  `protobuf:"bytes,2,rep,name=assigned_partitions,json=assignedPartitions,proto3" json:"assigned_partitions,omitempty"`
	ActiveGenerationId uint64             `protobuf:"varint,3,opt,name=active_generation_id,json=activeGenerationId,proto3" json:"active_generation_id,omitempty"`
	State              ConsumerGroupState `protobuf:"varint,4,opt,name=state,proto3,enum=api.v1.ConsumerGroupState" json:"state,omitempty"`
	// equivalent to kafka's client.id
	// that uniquely identifies the node in a consumer group
	ClientId        string            `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	CommittedOffset map[uint32]uint64 `` /* 196-byte string literal not displayed */
	CurrentOffset   map[uint32]uint64 `` /* 190-byte string literal not displayed */
	// contains filtered or unexported fields
}

ConsumerGroupNode

func (*ConsumerGroupNode) Descriptor deprecated 

func (*ConsumerGroupNode) Descriptor() ([]byte, []int)

Deprecated: Use ConsumerGroupNode.ProtoReflect.Descriptor instead.

func (*ConsumerGroupNode) GetActiveGenerationId 

func (x *ConsumerGroupNode) GetActiveGenerationId() uint64

func (*ConsumerGroupNode) GetAssignedPartitions 

func (x *ConsumerGroupNode) GetAssignedPartitions() []*TopicPartition

func (*ConsumerGroupNode) GetClientId 

func (x *ConsumerGroupNode) GetClientId() string

func (*ConsumerGroupNode) GetCommittedOffset 

func (x *ConsumerGroupNode) GetCommittedOffset() map[uint32]uint64

func (*ConsumerGroupNode) GetConsumerGroupId 

func (x *ConsumerGroupNode) GetConsumerGroupId() string

func (*ConsumerGroupNode) GetCurrentOffset 

func (x *ConsumerGroupNode) GetCurrentOffset() map[uint32]uint64

func (*ConsumerGroupNode) GetState 

func (x *ConsumerGroupNode) GetState() ConsumerGroupState

func (*ConsumerGroupNode) ProtoMessage 

func (*ConsumerGroupNode) ProtoMessage()

func (*ConsumerGroupNode) ProtoReflect 

func (x *ConsumerGroupNode) ProtoReflect() protoreflect.Message

func (*ConsumerGroupNode) Reset 

func (x *ConsumerGroupNode) Reset()

func (*ConsumerGroupNode) String 

func (x *ConsumerGroupNode) String() string

type ConsumerGroupState 

type ConsumerGroupState int32
const (
	ConsumerGroupState_CONSUMER_GROUP_STATE_UNSPECIFIED          ConsumerGroupState = 0
	ConsumerGroupState_CONSUMER_GROUP_STATE_PREPARING_REBALANCE  ConsumerGroupState = 1
	ConsumerGroupState_CONSUMER_GROUP_STATE_COMPLETING_REBALANCE ConsumerGroupState = 2
	ConsumerGroupState_CONSUMER_GROUP_STATE_STABLE               ConsumerGroupState = 3
	ConsumerGroupState_CONSUMER_GROUP_STATE_DEAD                 ConsumerGroupState = 4
	ConsumerGroupState_CONSUMER_GROUP_STATE_EMPTY                ConsumerGroupState = 5
)

func (ConsumerGroupState) Descriptor 

func (ConsumerGroupState) Descriptor() protoreflect.EnumDescriptor

func (ConsumerGroupState) Enum 

func (x ConsumerGroupState) Enum() *ConsumerGroupState

func (ConsumerGroupState) EnumDescriptor deprecated 

func (ConsumerGroupState) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConsumerGroupState.Descriptor instead.

func (ConsumerGroupState) Number 

func (x ConsumerGroupState) Number() protoreflect.EnumNumber

func (ConsumerGroupState) String 

func (x ConsumerGroupState) String() string

func (ConsumerGroupState) Type 

func (ConsumerGroupState) Type() protoreflect.EnumType

type Headers 

type Headers struct {
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Headers are metadata on a record that are eligible to be overriden by producing clients. They should _ideally_ map to an existing field in the Metadata type.

func (*Headers) Descriptor deprecated 

func (*Headers) Descriptor() ([]byte, []int)

Deprecated: Use Headers.ProtoReflect.Descriptor instead.

func (*Headers) GetTimestamp 

func (x *Headers) GetTimestamp() int64

func (*Headers) ProtoMessage 

func (*Headers) ProtoMessage()

func (*Headers) ProtoReflect 

func (x *Headers) ProtoReflect() protoreflect.Message

func (*Headers) Reset 

func (x *Headers) Reset()

func (*Headers) String 

func (x *Headers) String() string

type Index 

type Index struct {
	Offset   uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Position uint64 `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated 

func (*Index) Descriptor() ([]byte, []int)

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetOffset 

func (x *Index) GetOffset() uint64

func (*Index) GetPosition 

func (x *Index) GetPosition() uint64

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

type Metadata 

type Metadata struct {
	Timestamp               int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Offset                  uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	RelativeOffset          uint64 `protobuf:"varint,3,opt,name=relative_offset,json=relativeOffset,proto3" json:"relative_offset,omitempty"`
	KeyUncompressedLength   int32  `` /* 127-byte string literal not displayed */
	ValueUncompressedLength int32  `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metadata is immutable data about the record that is generated before it is written to the log it is not permissible to override this information

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetKeyUncompressedLength 

func (x *Metadata) GetKeyUncompressedLength() int32

func (*Metadata) GetOffset 

func (x *Metadata) GetOffset() uint64

func (*Metadata) GetRelativeOffset 

func (x *Metadata) GetRelativeOffset() uint64

func (*Metadata) GetTimestamp 

func (x *Metadata) GetTimestamp() int64

func (*Metadata) GetValueUncompressedLength 

func (x *Metadata) GetValueUncompressedLength() int32

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Record 

type Record struct {
	Key      []byte    `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Payload  []byte    `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Headers  *Headers  `protobuf:"bytes,4,opt,name=headers,proto3" json:"headers,omitempty"`
	// the record is hashed with crc-32
	// nit: in kafka apparently record level
	// checksum is replaced by batch-level checksum
	Checksum uint32 `protobuf:"varint,5,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*Record) Descriptor deprecated 

func (*Record) Descriptor() ([]byte, []int)

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetChecksum 

func (x *Record) GetChecksum() uint32

func (*Record) GetHeaders 

func (x *Record) GetHeaders() *Headers

func (*Record) GetKey 

func (x *Record) GetKey() []byte

func (*Record) GetMetadata 

func (x *Record) GetMetadata() *Metadata

func (*Record) GetPayload 

func (x *Record) GetPayload() []byte

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

func (x *Record) ProtoReflect() protoreflect.Message

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type SeekIndex 

type SeekIndex struct {

	// Types that are assignable to Whence:
	//
	//	*SeekIndex_Offset
	//	*SeekIndex_Time
	Whence isSeekIndex_Whence `protobuf_oneof:"whence"`
	// contains filtered or unexported fields
}

func (*SeekIndex) Descriptor deprecated 

func (*SeekIndex) Descriptor() ([]byte, []int)

Deprecated: Use SeekIndex.ProtoReflect.Descriptor instead.

func (*SeekIndex) GetOffset 

func (x *SeekIndex) GetOffset() uint64

func (*SeekIndex) GetTime 

func (x *SeekIndex) GetTime() int64

func (*SeekIndex) GetWhence 

func (m *SeekIndex) GetWhence() isSeekIndex_Whence

func (*SeekIndex) ProtoMessage 

func (*SeekIndex) ProtoMessage()

func (*SeekIndex) ProtoReflect 

func (x *SeekIndex) ProtoReflect() protoreflect.Message

func (*SeekIndex) Reset 

func (x *SeekIndex) Reset()

func (*SeekIndex) String 

func (x *SeekIndex) String() string

type SeekIndex_Offset 

type SeekIndex_Offset struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3,oneof"`
}

type SeekIndex_Time 

type SeekIndex_Time struct {
	Time int64 `protobuf:"varint,2,opt,name=time,proto3,oneof"`
}

type TimeIndex 

type TimeIndex struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Offset    uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeIndex) Descriptor deprecated 

func (*TimeIndex) Descriptor() ([]byte, []int)

Deprecated: Use TimeIndex.ProtoReflect.Descriptor instead.

func (*TimeIndex) GetOffset 

func (x *TimeIndex) GetOffset() uint64

func (*TimeIndex) GetTimestamp 

func (x *TimeIndex) GetTimestamp() int64

func (*TimeIndex) ProtoMessage 

func (*TimeIndex) ProtoMessage()

func (*TimeIndex) ProtoReflect 

func (x *TimeIndex) ProtoReflect() protoreflect.Message

func (*TimeIndex) Reset 

func (x *TimeIndex) Reset()

func (*TimeIndex) String 

func (x *TimeIndex) String() string

type TopicConfig 

type TopicConfig struct {
	Name           string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PartitionCount uint32 `protobuf:"varint,2,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicConfig) Descriptor deprecated 

func (*TopicConfig) Descriptor() ([]byte, []int)

Deprecated: Use TopicConfig.ProtoReflect.Descriptor instead.

func (*TopicConfig) GetName 

func (x *TopicConfig) GetName() string

func (*TopicConfig) GetPartitionCount 

func (x *TopicConfig) GetPartitionCount() uint32

func (*TopicConfig) ProtoMessage 

func (*TopicConfig) ProtoMessage()

func (*TopicConfig) ProtoReflect 

func (x *TopicConfig) ProtoReflect() protoreflect.Message

func (*TopicConfig) Reset 

func (x *TopicConfig) Reset()

func (*TopicConfig) String 

func (x *TopicConfig) String() string

type TopicPartition 

type TopicPartition struct {
	Topic          string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	PartitionIndex uint32 `protobuf:"varint,2,opt,name=partition_index,json=partitionIndex,proto3" json:"partition_index,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicPartition) Descriptor deprecated 

func (*TopicPartition) Descriptor() ([]byte, []int)

Deprecated: Use TopicPartition.ProtoReflect.Descriptor instead.

func (*TopicPartition) GetPartitionIndex 

func (x *TopicPartition) GetPartitionIndex() uint32

func (*TopicPartition) GetTopic 

func (x *TopicPartition) GetTopic() string

func (*TopicPartition) ProtoMessage 

func (*TopicPartition) ProtoMessage()

func (*TopicPartition) ProtoReflect 

func (x *TopicPartition) ProtoReflect() protoreflect.Message

func (*TopicPartition) Reset 

func (x *TopicPartition) Reset()

func (*TopicPartition) String 

func (x *TopicPartition) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.