isb

Documentation

Index

• Variables
• type WMB
  • func (*WMB) Descriptor() ([]byte, []int)
  • func (x *WMB) GetIdle() bool
  • func (x *WMB) GetOffset() int64
  • func (x *WMB) GetPartition() int32
  • func (x *WMB) GetWatermark() int64
  • func (*WMB) ProtoMessage()
  • func (x *WMB) ProtoReflect() protoreflect.Message
  • func (x *WMB) Reset()
  • func (x *WMB) String() string

Variables

var File_pkg_apis_proto_wmb_wmb_proto protoreflect.FileDescriptor

Types

type WMB

type WMB struct {

	// Idle is set to true if the given processor entity hasn't published anything
	// to the offset timeline bucket in a batch processing cycle.
	// Idle is used to signal an idle watermark.
	Idle bool `protobuf:"varint,1,opt,name=idle,proto3" json:"idle,omitempty"`
	// Offset is the monotonically increasing index/offset of the buffer (buffer is the physical representation
	// of the partition of the edge).
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Watermark is tightly coupled with the offset and will be monotonically increasing for a given ProcessorEntity
	// as the offset increases.
	// When it is idling (Idle==true), for a given offset, the watermark can monotonically increase without offset
	// increasing.
	Watermark int64 `protobuf:"varint,3,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// Partition to identify the partition to which the watermark belongs.
	Partition int32 `protobuf:"varint,4,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

WMB is used in the KV offset timeline bucket as the value for the given processor entity key.

func (*WMB) Descriptor

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

Deprecated: Use WMB.ProtoReflect.Descriptor instead.

func (*WMB) GetIdle

func (x *WMB) GetIdle() bool

func (*WMB) GetOffset

func (x *WMB) GetOffset() int64

func (*WMB) GetPartition

func (x *WMB) GetPartition() int32

func (*WMB) GetWatermark

func (x *WMB) GetWatermark() int64

func (*WMB) ProtoMessage

func (*WMB) ProtoMessage()

func (*WMB) ProtoReflect

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

func (*WMB) Reset

func (x *WMB) Reset()

func (*WMB) String

func (x *WMB) String() string