kafka_mq_proto

Documentation

Index

• Variables
• type Marker
  • func (*Marker) Descriptor() ([]byte, []int)
  • func (x *Marker) GetKey() []byte
  • func (x *Marker) GetMessageId() *MessageID
  • func (x *Marker) GetRedeliverAfterMs() uint64
  • func (x *Marker) GetType() Marker_Type
  • func (x *Marker) GetValue() []byte
  • func (x *Marker) GetVersion() Marker_Version
  • func (*Marker) ProtoMessage()
  • func (x *Marker) ProtoReflect() protoreflect.Message
  • func (x *Marker) Reset()
  • func (x *Marker) String() string
• type Marker_Type
  • func (Marker_Type) Descriptor() protoreflect.EnumDescriptor
  • func (x Marker_Type) Enum() *Marker_Type
  • func (Marker_Type) EnumDescriptor() ([]byte, []int)
  • func (x Marker_Type) Number() protoreflect.EnumNumber
  • func (x Marker_Type) String() string
  • func (Marker_Type) Type() protoreflect.EnumType
• type Marker_Version
  • func (Marker_Version) Descriptor() protoreflect.EnumDescriptor
  • func (x Marker_Version) Enum() *Marker_Version
  • func (Marker_Version) EnumDescriptor() ([]byte, []int)
  • func (x Marker_Version) Number() protoreflect.EnumNumber
  • func (x Marker_Version) String() string
  • func (Marker_Version) Type() protoreflect.EnumType
• type MessageID
  • func (*MessageID) Descriptor() ([]byte, []int)
  • func (x *MessageID) GetOffset() int64
  • func (x *MessageID) GetPartition() int32
  • func (*MessageID) ProtoMessage()
  • func (x *MessageID) ProtoReflect() protoreflect.Message
  • func (x *MessageID) Reset()
  • func (x *MessageID) String() string

Variables

var (
	Marker_Version_name = map[int32]string{
		0: "V1",
	}
	Marker_Version_value = map[string]int32{
		"V1": 0,
	}
)

Enum value maps for Marker_Version.

var (
	Marker_Type_name = map[int32]string{
		0: "START",
		1: "END",
		2: "KEEPALIVE",
	}
	Marker_Type_value = map[string]int32{
		"START":     0,
		"END":       1,
		"KEEPALIVE": 2,
	}
)

Enum value maps for Marker_Type.

var File_kafka_mq_v1_proto protoreflect.FileDescriptor

Types

type Marker

type Marker struct {

	// The verison of the marker message
	Version Marker_Version `protobuf:"varint,1,opt,name=version,proto3,enum=Marker_Version" json:"version,omitempty"`
	// The type of marker message
	Type Marker_Type `protobuf:"varint,2,opt,name=type,proto3,enum=Marker_Type" json:"type,omitempty"`
	// The identity of the message that this marker tracks
	MessageId *MessageID `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The number of milliseconds after seeing this marker which will trigger redelivery.
	// Start and KeepAlive markers must have this value set.
	// End markers will not have this value set.
	RedeliverAfterMs uint64 `protobuf:"varint,4,opt,name=redeliver_after_ms,json=redeliverAfterMs,proto3" json:"redeliver_after_ms,omitempty"`
	// The payload of the original record.
	// Start markers must contain non-null payload
	// End and KeepAlive markers will contain null payload
	Key   []byte `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,6,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A marker that can be used to determine when message redelivery is required

func (*Marker) Descriptor

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

Deprecated: Use Marker.ProtoReflect.Descriptor instead.

func (*Marker) GetKey

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

func (*Marker) GetMessageId

func (x *Marker) GetMessageId() *MessageID

func (*Marker) GetRedeliverAfterMs

func (x *Marker) GetRedeliverAfterMs() uint64

func (*Marker) GetType

func (x *Marker) GetType() Marker_Type

func (*Marker) GetValue

func (x *Marker) GetValue() []byte

func (*Marker) GetVersion

func (x *Marker) GetVersion() Marker_Version

func (*Marker) ProtoMessage

func (*Marker) ProtoMessage()

func (*Marker) ProtoReflect

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

func (*Marker) Reset

func (x *Marker) Reset()

func (*Marker) String

func (x *Marker) String() string

type Marker_Type

type Marker_Type int32

const (
	Marker_START     Marker_Type = 0
	Marker_END       Marker_Type = 1
	Marker_KEEPALIVE Marker_Type = 2
)

func (Marker_Type) Descriptor

func (Marker_Type) Descriptor() protoreflect.EnumDescriptor

func (Marker_Type) Enum

func (x Marker_Type) Enum() *Marker_Type

func (Marker_Type) EnumDescriptor

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

Deprecated: Use Marker_Type.Descriptor instead.

func (Marker_Type) Number

func (x Marker_Type) Number() protoreflect.EnumNumber

func (Marker_Type) String

func (x Marker_Type) String() string

func (Marker_Type) Type

func (Marker_Type) Type() protoreflect.EnumType

type Marker_Version

type Marker_Version int32

const (
	Marker_V1 Marker_Version = 0
)

func (Marker_Version) Descriptor

func (Marker_Version) Descriptor() protoreflect.EnumDescriptor

func (Marker_Version) Enum

func (x Marker_Version) Enum() *Marker_Version

func (Marker_Version) EnumDescriptor

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

Deprecated: Use Marker_Version.Descriptor instead.

func (Marker_Version) Number

func (x Marker_Version) Number() protoreflect.EnumNumber

func (Marker_Version) String

func (x Marker_Version) String() string

func (Marker_Version) Type

func (Marker_Version) Type() protoreflect.EnumType

type MessageID

type MessageID struct {
	Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

A named-pair of (partiton, offset) that is used to uniquely identify a message from the queue topic

func (*MessageID) Descriptor

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

Deprecated: Use MessageID.ProtoReflect.Descriptor instead.

func (*MessageID) GetOffset

func (x *MessageID) GetOffset() int64

func (*MessageID) GetPartition

func (x *MessageID) GetPartition() int32

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