messagespb

package
v0.0.2-0...-bef042a Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	MessageType_name = map[int32]string{
		0:   "Unknown",
		1:   "TimeTick",
		2:   "Insert",
		3:   "Delete",
		4:   "Flush",
		5:   "CreateCollection",
		6:   "DropCollection",
		7:   "CreatePartition",
		8:   "DropPartition",
		9:   "ManualFlush",
		10:  "CreateSegment",
		900: "BeginTxn",
		901: "CommitTxn",
		902: "RollbackTxn",
		999: "Txn",
	}
	MessageType_value = map[string]int32{
		"Unknown":          0,
		"TimeTick":         1,
		"Insert":           2,
		"Delete":           3,
		"Flush":            4,
		"CreateCollection": 5,
		"DropCollection":   6,
		"CreatePartition":  7,
		"DropPartition":    8,
		"ManualFlush":      9,
		"CreateSegment":    10,
		"BeginTxn":         900,
		"CommitTxn":        901,
		"RollbackTxn":      902,
		"Txn":              999,
	}
)

Enum value maps for MessageType.

View Source 
var (
	TxnState_name = map[int32]string{
		0: "TxnUnknown",
		1: "TxnBegin",
		2: "TxnInFlight",
		3: "TxnOnCommit",
		4: "TxnCommitted",
		5: "TxnOnRollback",
		6: "TxnRollbacked",
	}
	TxnState_value = map[string]int32{
		"TxnUnknown":    0,
		"TxnBegin":      1,
		"TxnInFlight":   2,
		"TxnOnCommit":   3,
		"TxnCommitted":  4,
		"TxnOnRollback": 5,
		"TxnRollbacked": 6,
	}
)

Enum value maps for TxnState.

View Source 
var File_messages_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BeginTxnMessageBody 

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

BeginTxnMessageBody is the body of begin transaction message. Just do nothing now.

func (*BeginTxnMessageBody) Descriptor deprecated 

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

Deprecated: Use BeginTxnMessageBody.ProtoReflect.Descriptor instead.

func (*BeginTxnMessageBody) ProtoMessage 

func (*BeginTxnMessageBody) ProtoMessage()

func (*BeginTxnMessageBody) ProtoReflect 

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

func (*BeginTxnMessageBody) Reset 

func (x *BeginTxnMessageBody) Reset()

func (*BeginTxnMessageBody) String 

func (x *BeginTxnMessageBody) String() string

type BeginTxnMessageHeader 

type BeginTxnMessageHeader struct {

	// the max milliseconds to keep alive of the transaction.
	// the keepalive_milliseconds is never changed in a transaction by now,
	KeepaliveMilliseconds int64 `protobuf:"varint,1,opt,name=keepalive_milliseconds,json=keepaliveMilliseconds,proto3" json:"keepalive_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

BeginTxnMessageHeader is the header of begin transaction message. Just do nothing now. Add Channel info here to implement cross pchannel transaction.

func (*BeginTxnMessageHeader) Descriptor deprecated 

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

Deprecated: Use BeginTxnMessageHeader.ProtoReflect.Descriptor instead.

func (*BeginTxnMessageHeader) GetKeepaliveMilliseconds 

func (x *BeginTxnMessageHeader) GetKeepaliveMilliseconds() int64

func (*BeginTxnMessageHeader) ProtoMessage 

func (*BeginTxnMessageHeader) ProtoMessage()

func (*BeginTxnMessageHeader) ProtoReflect 

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

func (*BeginTxnMessageHeader) Reset 

func (x *BeginTxnMessageHeader) Reset()

func (*BeginTxnMessageHeader) String 

func (x *BeginTxnMessageHeader) String() string

type CommitTxnMessageBody 

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

CommitTxnMessageBody is the body of commit transaction message. Just do nothing now.

func (*CommitTxnMessageBody) Descriptor deprecated 

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

Deprecated: Use CommitTxnMessageBody.ProtoReflect.Descriptor instead.

func (*CommitTxnMessageBody) ProtoMessage 

func (*CommitTxnMessageBody) ProtoMessage()

func (*CommitTxnMessageBody) ProtoReflect 

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

func (*CommitTxnMessageBody) Reset 

func (x *CommitTxnMessageBody) Reset()

func (*CommitTxnMessageBody) String 

func (x *CommitTxnMessageBody) String() string

type CommitTxnMessageHeader 

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

CommitTxnMessageHeader is the header of commit transaction message. Just do nothing now.

func (*CommitTxnMessageHeader) Descriptor deprecated 

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

Deprecated: Use CommitTxnMessageHeader.ProtoReflect.Descriptor instead.

func (*CommitTxnMessageHeader) ProtoMessage 

func (*CommitTxnMessageHeader) ProtoMessage()

func (*CommitTxnMessageHeader) ProtoReflect 

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

func (*CommitTxnMessageHeader) Reset 

func (x *CommitTxnMessageHeader) Reset()

func (*CommitTxnMessageHeader) String 

func (x *CommitTxnMessageHeader) String() string

type CreateCollectionMessageHeader 

type CreateCollectionMessageHeader struct {
	CollectionId int64   `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionIds []int64 `protobuf:"varint,2,rep,packed,name=partition_ids,json=partitionIds,proto3" json:"partition_ids,omitempty"`
	// contains filtered or unexported fields
}

CreateCollectionMessageHeader is the header of create collection message.

func (*CreateCollectionMessageHeader) Descriptor deprecated 

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

Deprecated: Use CreateCollectionMessageHeader.ProtoReflect.Descriptor instead.

func (*CreateCollectionMessageHeader) GetCollectionId 

func (x *CreateCollectionMessageHeader) GetCollectionId() int64

func (*CreateCollectionMessageHeader) GetPartitionIds 

func (x *CreateCollectionMessageHeader) GetPartitionIds() []int64

func (*CreateCollectionMessageHeader) ProtoMessage 

func (*CreateCollectionMessageHeader) ProtoMessage()

func (*CreateCollectionMessageHeader) ProtoReflect 

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

func (*CreateCollectionMessageHeader) Reset 

func (x *CreateCollectionMessageHeader) Reset()

func (*CreateCollectionMessageHeader) String 

func (x *CreateCollectionMessageHeader) String() string

type CreatePartitionMessageHeader 

type CreatePartitionMessageHeader struct {
	CollectionId int64 `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64 `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// contains filtered or unexported fields
}

CreatePartitionMessageHeader is the header of create partition message.

func (*CreatePartitionMessageHeader) Descriptor deprecated 

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

Deprecated: Use CreatePartitionMessageHeader.ProtoReflect.Descriptor instead.

func (*CreatePartitionMessageHeader) GetCollectionId 

func (x *CreatePartitionMessageHeader) GetCollectionId() int64

func (*CreatePartitionMessageHeader) GetPartitionId 

func (x *CreatePartitionMessageHeader) GetPartitionId() int64

func (*CreatePartitionMessageHeader) ProtoMessage 

func (*CreatePartitionMessageHeader) ProtoMessage()

func (*CreatePartitionMessageHeader) ProtoReflect 

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

func (*CreatePartitionMessageHeader) Reset 

func (x *CreatePartitionMessageHeader) Reset()

func (*CreatePartitionMessageHeader) String 

func (x *CreatePartitionMessageHeader) String() string

type CreateSegmentInfo 

type CreateSegmentInfo struct {
	PartitionId int64 `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	SegmentId   int64 `protobuf:"varint,2,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	// contains filtered or unexported fields
}

CreateSegmentInfo is the info of create segment.

func (*CreateSegmentInfo) Descriptor deprecated 

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

Deprecated: Use CreateSegmentInfo.ProtoReflect.Descriptor instead.

func (*CreateSegmentInfo) GetPartitionId 

func (x *CreateSegmentInfo) GetPartitionId() int64

func (*CreateSegmentInfo) GetSegmentId 

func (x *CreateSegmentInfo) GetSegmentId() int64

func (*CreateSegmentInfo) ProtoMessage 

func (*CreateSegmentInfo) ProtoMessage()

func (*CreateSegmentInfo) ProtoReflect 

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

func (*CreateSegmentInfo) Reset 

func (x *CreateSegmentInfo) Reset()

func (*CreateSegmentInfo) String 

func (x *CreateSegmentInfo) String() string

type CreateSegmentMessageBody 

type CreateSegmentMessageBody struct {
	CollectionId int64                `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Segments     []*CreateSegmentInfo `protobuf:"bytes,2,rep,name=segments,proto3" json:"segments,omitempty"`
	// contains filtered or unexported fields
}

CreateSegmentMessageBody is the body of create segment message.

func (*CreateSegmentMessageBody) Descriptor deprecated 

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

Deprecated: Use CreateSegmentMessageBody.ProtoReflect.Descriptor instead.

func (*CreateSegmentMessageBody) GetCollectionId 

func (x *CreateSegmentMessageBody) GetCollectionId() int64

func (*CreateSegmentMessageBody) GetSegments 

func (x *CreateSegmentMessageBody) GetSegments() []*CreateSegmentInfo

func (*CreateSegmentMessageBody) ProtoMessage 

func (*CreateSegmentMessageBody) ProtoMessage()

func (*CreateSegmentMessageBody) ProtoReflect 

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

func (*CreateSegmentMessageBody) Reset 

func (x *CreateSegmentMessageBody) Reset()

func (*CreateSegmentMessageBody) String 

func (x *CreateSegmentMessageBody) String() string

type CreateSegmentMessageHeader 

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

CreateSegmentMessageHeader just nothing.

func (*CreateSegmentMessageHeader) Descriptor deprecated 

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

Deprecated: Use CreateSegmentMessageHeader.ProtoReflect.Descriptor instead.

func (*CreateSegmentMessageHeader) ProtoMessage 

func (*CreateSegmentMessageHeader) ProtoMessage()

func (*CreateSegmentMessageHeader) ProtoReflect 

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

func (*CreateSegmentMessageHeader) Reset 

func (x *CreateSegmentMessageHeader) Reset()

func (*CreateSegmentMessageHeader) String 

func (x *CreateSegmentMessageHeader) String() string

type DeleteMessageHeader 

type DeleteMessageHeader struct {
	CollectionId int64 `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

DeleteMessageHeader

func (*DeleteMessageHeader) Descriptor deprecated 

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

Deprecated: Use DeleteMessageHeader.ProtoReflect.Descriptor instead.

func (*DeleteMessageHeader) GetCollectionId 

func (x *DeleteMessageHeader) GetCollectionId() int64

func (*DeleteMessageHeader) ProtoMessage 

func (*DeleteMessageHeader) ProtoMessage()

func (*DeleteMessageHeader) ProtoReflect 

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

func (*DeleteMessageHeader) Reset 

func (x *DeleteMessageHeader) Reset()

func (*DeleteMessageHeader) String 

func (x *DeleteMessageHeader) String() string

type DropCollectionMessageHeader 

type DropCollectionMessageHeader struct {
	CollectionId int64 `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	// contains filtered or unexported fields
}

DropCollectionMessageHeader is the header of drop collection message.

func (*DropCollectionMessageHeader) Descriptor deprecated 

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

Deprecated: Use DropCollectionMessageHeader.ProtoReflect.Descriptor instead.

func (*DropCollectionMessageHeader) GetCollectionId 

func (x *DropCollectionMessageHeader) GetCollectionId() int64

func (*DropCollectionMessageHeader) ProtoMessage 

func (*DropCollectionMessageHeader) ProtoMessage()

func (*DropCollectionMessageHeader) ProtoReflect 

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

func (*DropCollectionMessageHeader) Reset 

func (x *DropCollectionMessageHeader) Reset()

func (*DropCollectionMessageHeader) String 

func (x *DropCollectionMessageHeader) String() string

type DropPartitionMessageHeader 

type DropPartitionMessageHeader struct {
	CollectionId int64 `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64 `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// contains filtered or unexported fields
}

DropPartitionMessageHeader is the header of drop partition message.

func (*DropPartitionMessageHeader) Descriptor deprecated 

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

Deprecated: Use DropPartitionMessageHeader.ProtoReflect.Descriptor instead.

func (*DropPartitionMessageHeader) GetCollectionId 

func (x *DropPartitionMessageHeader) GetCollectionId() int64

func (*DropPartitionMessageHeader) GetPartitionId 

func (x *DropPartitionMessageHeader) GetPartitionId() int64

func (*DropPartitionMessageHeader) ProtoMessage 

func (*DropPartitionMessageHeader) ProtoMessage()

func (*DropPartitionMessageHeader) ProtoReflect 

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

func (*DropPartitionMessageHeader) Reset 

func (x *DropPartitionMessageHeader) Reset()

func (*DropPartitionMessageHeader) String 

func (x *DropPartitionMessageHeader) String() string

type FlushMessageBody 

type FlushMessageBody struct {

	// indicate which the collection that segment belong to.
	CollectionId int64   `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	SegmentId    []int64 `protobuf:"varint,2,rep,packed,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"` // indicate which segment to flush.
	// contains filtered or unexported fields
}

FlushMessageBody is the body of flush message.

func (*FlushMessageBody) Descriptor deprecated 

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

Deprecated: Use FlushMessageBody.ProtoReflect.Descriptor instead.

func (*FlushMessageBody) GetCollectionId 

func (x *FlushMessageBody) GetCollectionId() int64

func (*FlushMessageBody) GetSegmentId 

func (x *FlushMessageBody) GetSegmentId() []int64

func (*FlushMessageBody) ProtoMessage 

func (*FlushMessageBody) ProtoMessage()

func (*FlushMessageBody) ProtoReflect 

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

func (*FlushMessageBody) Reset 

func (x *FlushMessageBody) Reset()

func (*FlushMessageBody) String 

func (x *FlushMessageBody) String() string

type FlushMessageHeader 

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

FlushMessageHeader just nothing.

func (*FlushMessageHeader) Descriptor deprecated 

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

Deprecated: Use FlushMessageHeader.ProtoReflect.Descriptor instead.

func (*FlushMessageHeader) ProtoMessage 

func (*FlushMessageHeader) ProtoMessage()

func (*FlushMessageHeader) ProtoReflect 

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

func (*FlushMessageHeader) Reset 

func (x *FlushMessageHeader) Reset()

func (*FlushMessageHeader) String 

func (x *FlushMessageHeader) String() string

type ImmutableMessage 

type ImmutableMessage struct {
	Id         *MessageID        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Payload    []byte            `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // message body
	Properties map[string]string ``                                                                    // message properties
	/* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

ImmutableMessage is the message that can not be modified anymore.

func (*ImmutableMessage) Descriptor deprecated 

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

Deprecated: Use ImmutableMessage.ProtoReflect.Descriptor instead.

func (*ImmutableMessage) GetId 

func (x *ImmutableMessage) GetId() *MessageID

func (*ImmutableMessage) GetPayload 

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

func (*ImmutableMessage) GetProperties 

func (x *ImmutableMessage) GetProperties() map[string]string

func (*ImmutableMessage) ProtoMessage 

func (*ImmutableMessage) ProtoMessage()

func (*ImmutableMessage) ProtoReflect 

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

func (*ImmutableMessage) Reset 

func (x *ImmutableMessage) Reset()

func (*ImmutableMessage) String 

func (x *ImmutableMessage) String() string

type InsertMessageHeader 

type InsertMessageHeader struct {
	CollectionId int64                         `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	Partitions   []*PartitionSegmentAssignment `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions,omitempty"`
	// contains filtered or unexported fields
}

InsertMessageHeader is the header of insert message.

func (*InsertMessageHeader) Descriptor deprecated 

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

Deprecated: Use InsertMessageHeader.ProtoReflect.Descriptor instead.

func (*InsertMessageHeader) GetCollectionId 

func (x *InsertMessageHeader) GetCollectionId() int64

func (*InsertMessageHeader) GetPartitions 

func (x *InsertMessageHeader) GetPartitions() []*PartitionSegmentAssignment

func (*InsertMessageHeader) ProtoMessage 

func (*InsertMessageHeader) ProtoMessage()

func (*InsertMessageHeader) ProtoReflect 

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

func (*InsertMessageHeader) Reset 

func (x *InsertMessageHeader) Reset()

func (*InsertMessageHeader) String 

func (x *InsertMessageHeader) String() string

type ManualFlushExtraResponse 

type ManualFlushExtraResponse struct {
	SegmentIds []int64 `protobuf:"varint,1,rep,packed,name=segment_ids,json=segmentIds,proto3" json:"segment_ids,omitempty"`
	// contains filtered or unexported fields
}

ManualFlushExtraResponse is the extra response of manual flush message.

func (*ManualFlushExtraResponse) Descriptor deprecated 

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

Deprecated: Use ManualFlushExtraResponse.ProtoReflect.Descriptor instead.

func (*ManualFlushExtraResponse) GetSegmentIds 

func (x *ManualFlushExtraResponse) GetSegmentIds() []int64

func (*ManualFlushExtraResponse) ProtoMessage 

func (*ManualFlushExtraResponse) ProtoMessage()

func (*ManualFlushExtraResponse) ProtoReflect 

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

func (*ManualFlushExtraResponse) Reset 

func (x *ManualFlushExtraResponse) Reset()

func (*ManualFlushExtraResponse) String 

func (x *ManualFlushExtraResponse) String() string

type ManualFlushMessageBody 

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

ManualFlushMessageBody is the body of manual flush message.

func (*ManualFlushMessageBody) Descriptor deprecated 

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

Deprecated: Use ManualFlushMessageBody.ProtoReflect.Descriptor instead.

func (*ManualFlushMessageBody) ProtoMessage 

func (*ManualFlushMessageBody) ProtoMessage()

func (*ManualFlushMessageBody) ProtoReflect 

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

func (*ManualFlushMessageBody) Reset 

func (x *ManualFlushMessageBody) Reset()

func (*ManualFlushMessageBody) String 

func (x *ManualFlushMessageBody) String() string

type ManualFlushMessageHeader 

type ManualFlushMessageHeader struct {
	CollectionId int64  `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	FlushTs      uint64 `protobuf:"varint,2,opt,name=flush_ts,json=flushTs,proto3" json:"flush_ts,omitempty"`
	// contains filtered or unexported fields
}

func (*ManualFlushMessageHeader) Descriptor deprecated 

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

Deprecated: Use ManualFlushMessageHeader.ProtoReflect.Descriptor instead.

func (*ManualFlushMessageHeader) GetCollectionId 

func (x *ManualFlushMessageHeader) GetCollectionId() int64

func (*ManualFlushMessageHeader) GetFlushTs 

func (x *ManualFlushMessageHeader) GetFlushTs() uint64

func (*ManualFlushMessageHeader) ProtoMessage 

func (*ManualFlushMessageHeader) ProtoMessage()

func (*ManualFlushMessageHeader) ProtoReflect 

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

func (*ManualFlushMessageHeader) Reset 

func (x *ManualFlushMessageHeader) Reset()

func (*ManualFlushMessageHeader) String 

func (x *ManualFlushMessageHeader) String() string

type Message 

type Message struct {
	Payload    []byte            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // message body
	Properties map[string]string ``                                                                    // message properties
	/* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message is the basic unit of communication between publisher and consumer.

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetPayload 

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

func (*Message) GetProperties 

func (x *Message) GetProperties() map[string]string

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageID 

type MessageID struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

MessageID is the unique identifier of a message.

func (*MessageID) Descriptor deprecated 

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

Deprecated: Use MessageID.ProtoReflect.Descriptor instead.

func (*MessageID) GetId 

func (x *MessageID) GetId() string

func (*MessageID) ProtoMessage 

func (*MessageID) ProtoMessage()

func (*MessageID) ProtoReflect 

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

func (*MessageID) Reset 

func (x *MessageID) Reset()

func (*MessageID) String 

func (x *MessageID) String() string

type MessageType 

type MessageType int32

MessageType is the type of message. 

const (
	MessageType_Unknown          MessageType = 0
	MessageType_TimeTick         MessageType = 1
	MessageType_Insert           MessageType = 2
	MessageType_Delete           MessageType = 3
	MessageType_Flush            MessageType = 4
	MessageType_CreateCollection MessageType = 5
	MessageType_DropCollection   MessageType = 6
	MessageType_CreatePartition  MessageType = 7
	MessageType_DropPartition    MessageType = 8
	MessageType_ManualFlush      MessageType = 9
	MessageType_CreateSegment    MessageType = 10
	// begin transaction message is only used for transaction, once a begin
	// transaction message is received, all messages combined with the
	// transaction message cannot be consumed until a CommitTxn message
	// is received.
	MessageType_BeginTxn MessageType = 900
	// commit transaction message is only used for transaction, once a commit
	// transaction message is received, all messages combined with the
	// transaction message can be consumed, the message combined with the
	// transaction which is received after the commit transaction message will
	// be drop.
	MessageType_CommitTxn MessageType = 901
	// rollback transaction message is only used for transaction, once a
	// rollback transaction message is received, all messages combined with the
	// transaction message can be discarded, the message combined with the
	// transaction which is received after the rollback transaction message will
	// be drop.
	MessageType_RollbackTxn MessageType = 902
	// txn message is a set of messages combined by multiple messages in a
	// transaction. the txn properties is consist of the begin txn message and
	// commit txn message.
	MessageType_Txn MessageType = 999
)

func (MessageType) Descriptor 

func (MessageType) Descriptor() protoreflect.EnumDescriptor

func (MessageType) Enum 

func (x MessageType) Enum() *MessageType

func (MessageType) EnumDescriptor deprecated 

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

Deprecated: Use MessageType.Descriptor instead.

func (MessageType) Number 

func (x MessageType) Number() protoreflect.EnumNumber

func (MessageType) String 

func (x MessageType) String() string

func (MessageType) Type 

func (MessageType) Type() protoreflect.EnumType

type PartitionSegmentAssignment 

type PartitionSegmentAssignment struct {
	PartitionId       int64              `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Rows              uint64             `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	BinarySize        uint64             `protobuf:"varint,3,opt,name=binary_size,json=binarySize,proto3" json:"binary_size,omitempty"`
	SegmentAssignment *SegmentAssignment `protobuf:"bytes,4,opt,name=segment_assignment,json=segmentAssignment,proto3" json:"segment_assignment,omitempty"`
	// contains filtered or unexported fields
}

PartitionSegmentAssignment is the segment assignment of a partition.

func (*PartitionSegmentAssignment) Descriptor deprecated 

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

Deprecated: Use PartitionSegmentAssignment.ProtoReflect.Descriptor instead.

func (*PartitionSegmentAssignment) GetBinarySize 

func (x *PartitionSegmentAssignment) GetBinarySize() uint64

func (*PartitionSegmentAssignment) GetPartitionId 

func (x *PartitionSegmentAssignment) GetPartitionId() int64

func (*PartitionSegmentAssignment) GetRows 

func (x *PartitionSegmentAssignment) GetRows() uint64

func (*PartitionSegmentAssignment) GetSegmentAssignment 

func (x *PartitionSegmentAssignment) GetSegmentAssignment() *SegmentAssignment

func (*PartitionSegmentAssignment) ProtoMessage 

func (*PartitionSegmentAssignment) ProtoMessage()

func (*PartitionSegmentAssignment) ProtoReflect 

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

func (*PartitionSegmentAssignment) Reset 

func (x *PartitionSegmentAssignment) Reset()

func (*PartitionSegmentAssignment) String 

func (x *PartitionSegmentAssignment) String() string

type RMQMessageLayout 

type RMQMessageLayout struct {
	Payload    []byte            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // message body
	Properties map[string]string ``                                                                    // message properties
	/* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

RMQMessageLayout is the layout of message for RMQ.

func (*RMQMessageLayout) Descriptor deprecated 

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

Deprecated: Use RMQMessageLayout.ProtoReflect.Descriptor instead.

func (*RMQMessageLayout) GetPayload 

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

func (*RMQMessageLayout) GetProperties 

func (x *RMQMessageLayout) GetProperties() map[string]string

func (*RMQMessageLayout) ProtoMessage 

func (*RMQMessageLayout) ProtoMessage()

func (*RMQMessageLayout) ProtoReflect 

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

func (*RMQMessageLayout) Reset 

func (x *RMQMessageLayout) Reset()

func (*RMQMessageLayout) String 

func (x *RMQMessageLayout) String() string

type RollbackTxnMessageBody 

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

RollbackTxnMessageBody is the body of rollback transaction message. Just do nothing now.

func (*RollbackTxnMessageBody) Descriptor deprecated 

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

Deprecated: Use RollbackTxnMessageBody.ProtoReflect.Descriptor instead.

func (*RollbackTxnMessageBody) ProtoMessage 

func (*RollbackTxnMessageBody) ProtoMessage()

func (*RollbackTxnMessageBody) ProtoReflect 

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

func (*RollbackTxnMessageBody) Reset 

func (x *RollbackTxnMessageBody) Reset()

func (*RollbackTxnMessageBody) String 

func (x *RollbackTxnMessageBody) String() string

type RollbackTxnMessageHeader 

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

RollbackTxnMessageHeader is the header of rollback transaction message. Just do nothing now.

func (*RollbackTxnMessageHeader) Descriptor deprecated 

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

Deprecated: Use RollbackTxnMessageHeader.ProtoReflect.Descriptor instead.

func (*RollbackTxnMessageHeader) ProtoMessage 

func (*RollbackTxnMessageHeader) ProtoMessage()

func (*RollbackTxnMessageHeader) ProtoReflect 

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

func (*RollbackTxnMessageHeader) Reset 

func (x *RollbackTxnMessageHeader) Reset()

func (*RollbackTxnMessageHeader) String 

func (x *RollbackTxnMessageHeader) String() string

type SegmentAssignment 

type SegmentAssignment struct {
	SegmentId int64 `protobuf:"varint,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	// contains filtered or unexported fields
}

SegmentAssignment is the assignment of a segment.

func (*SegmentAssignment) Descriptor deprecated 

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

Deprecated: Use SegmentAssignment.ProtoReflect.Descriptor instead.

func (*SegmentAssignment) GetSegmentId 

func (x *SegmentAssignment) GetSegmentId() int64

func (*SegmentAssignment) ProtoMessage 

func (*SegmentAssignment) ProtoMessage()

func (*SegmentAssignment) ProtoReflect 

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

func (*SegmentAssignment) Reset 

func (x *SegmentAssignment) Reset()

func (*SegmentAssignment) String 

func (x *SegmentAssignment) String() string

type TimeTickMessageHeader 

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

TimeTickMessageHeader just nothing.

func (*TimeTickMessageHeader) Descriptor deprecated 

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

Deprecated: Use TimeTickMessageHeader.ProtoReflect.Descriptor instead.

func (*TimeTickMessageHeader) ProtoMessage 

func (*TimeTickMessageHeader) ProtoMessage()

func (*TimeTickMessageHeader) ProtoReflect 

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

func (*TimeTickMessageHeader) Reset 

func (x *TimeTickMessageHeader) Reset()

func (*TimeTickMessageHeader) String 

func (x *TimeTickMessageHeader) String() string

type TxnContext 

type TxnContext struct {

	// the unique id of the transaction.
	// the txn_id is never changed in a transaction.
	TxnId int64 `protobuf:"varint,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	// the next keep alive timeout of the transaction.
	// after the keep alive timeout, the transaction will be expired.
	KeepaliveMilliseconds int64 `protobuf:"varint,2,opt,name=keepalive_milliseconds,json=keepaliveMilliseconds,proto3" json:"keepalive_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

TxnContext is the context of transaction. It will be carried by every message in a transaction.

func (*TxnContext) Descriptor deprecated 

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

Deprecated: Use TxnContext.ProtoReflect.Descriptor instead.

func (*TxnContext) GetKeepaliveMilliseconds 

func (x *TxnContext) GetKeepaliveMilliseconds() int64

func (*TxnContext) GetTxnId 

func (x *TxnContext) GetTxnId() int64

func (*TxnContext) ProtoMessage 

func (*TxnContext) ProtoMessage()

func (*TxnContext) ProtoReflect 

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

func (*TxnContext) Reset 

func (x *TxnContext) Reset()

func (*TxnContext) String 

func (x *TxnContext) String() string

type TxnMessageBody 

type TxnMessageBody struct {
	Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

TxnMessageBody is the body of transaction message. A transaction message is combined by multiple messages. It's only can be seen at consume side. All message in a transaction message only has same timetick which is equal to the CommitTransationMessage.

func (*TxnMessageBody) Descriptor deprecated 

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

Deprecated: Use TxnMessageBody.ProtoReflect.Descriptor instead.

func (*TxnMessageBody) GetMessages 

func (x *TxnMessageBody) GetMessages() []*Message

func (*TxnMessageBody) ProtoMessage 

func (*TxnMessageBody) ProtoMessage()

func (*TxnMessageBody) ProtoReflect 

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

func (*TxnMessageBody) Reset 

func (x *TxnMessageBody) Reset()

func (*TxnMessageBody) String 

func (x *TxnMessageBody) String() string

type TxnMessageHeader 

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

TxnMessageHeader is the header of transaction message. Just do nothing now.

func (*TxnMessageHeader) Descriptor deprecated 

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

Deprecated: Use TxnMessageHeader.ProtoReflect.Descriptor instead.

func (*TxnMessageHeader) ProtoMessage 

func (*TxnMessageHeader) ProtoMessage()

func (*TxnMessageHeader) ProtoReflect 

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

func (*TxnMessageHeader) Reset 

func (x *TxnMessageHeader) Reset()

func (*TxnMessageHeader) String 

func (x *TxnMessageHeader) String() string

type TxnState 

type TxnState int32
const (
	// should never be used.
	TxnState_TxnUnknown TxnState = 0
	// the transaction begin.
	TxnState_TxnBegin TxnState = 1
	// the transaction is in flight.
	TxnState_TxnInFlight TxnState = 2
	// the transaction is on commit.
	TxnState_TxnOnCommit TxnState = 3
	// the transaction is committed.
	TxnState_TxnCommitted TxnState = 4
	// the transaction is on rollback.
	TxnState_TxnOnRollback TxnState = 5
	// the transaction is rollbacked.
	TxnState_TxnRollbacked TxnState = 6
)

func (TxnState) Descriptor 

func (TxnState) Descriptor() protoreflect.EnumDescriptor

func (TxnState) Enum 

func (x TxnState) Enum() *TxnState

func (TxnState) EnumDescriptor deprecated 

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

Deprecated: Use TxnState.Descriptor instead.

func (TxnState) Number 

func (x TxnState) Number() protoreflect.EnumNumber

func (TxnState) String 

func (x TxnState) String() string

func (TxnState) Type 

func (TxnState) Type() protoreflect.EnumType

type VChannels 

type VChannels struct {
	Vchannels []string `protobuf:"bytes,1,rep,name=vchannels,proto3" json:"vchannels,omitempty"`
	// contains filtered or unexported fields
}

VChannels is a layout to represent the virtual channels for broadcast.

func (*VChannels) Descriptor deprecated 

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

Deprecated: Use VChannels.ProtoReflect.Descriptor instead.

func (*VChannels) GetVchannels 

func (x *VChannels) GetVchannels() []string

func (*VChannels) ProtoMessage 

func (*VChannels) ProtoMessage()

func (*VChannels) ProtoReflect 

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

func (*VChannels) Reset 

func (x *VChannels) Reset()

func (*VChannels) String 

func (x *VChannels) 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.