isb

type Body struct {

	// Payload is the actual data of the message
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type Header struct {

	// MessageInfo contains the information window of the payload.
	MessageInfo *MessageInfo `protobuf:"bytes,1,opt,name=message_info,json=messageInfo,proto3" json:"message_info,omitempty"`
	// Kind indicates the kind of Message
	Kind MessageKind `protobuf:"varint,2,opt,name=kind,proto3,enum=isb.MessageKind" json:"kind,omitempty"`
	// ID is used for exactly-once-semantics. ID is a combination of vertex name, offset and index of the message.
	Id *MessageID `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// Keys is (key,value) in the map-reduce paradigm will be used for reduce operation
	Keys []string `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`
	// Headers is the headers of the message which can be used to store and propagate source headers
	Headers map[string]string `` /* 141-byte string literal not displayed */
	// Metadata is the metadata of the message
	Metadata *proto.Metadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type Message struct {
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Body   *Body   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type MessageID struct {

	// VertexName is the name of the vertex
	VertexName string `protobuf:"bytes,1,opt,name=vertex_name,json=vertexName,proto3" json:"vertex_name,omitempty"`
	// Offset is the offset of the message
	Offset string `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Index is the index of a flatmap message.
	Index int32 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

type MessageInfo struct {

	// EventTime represents the event time of the message
	EventTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// IsLate is used to indicate if the message is a late data
	IsLate bool `protobuf:"varint,2,opt,name=is_late,json=isLate,proto3" json:"is_late,omitempty"`
	// contains filtered or unexported fields
}

type MessageKind int32

type MessageMetadata struct {

	// NumDelivered is the number of times the message has been delivered.
	NumDelivered uint64 `protobuf:"varint,1,opt,name=num_delivered,json=numDelivered,proto3" json:"num_delivered,omitempty"`
	// contains filtered or unexported fields
}

type ReadMessage struct {

	// Message is the actual message read from the buffer
	Message *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// ReadOffset is the offset at which the message was read
	ReadOffset int64 `protobuf:"varint,2,opt,name=read_offset,json=readOffset,proto3" json:"read_offset,omitempty"`
	// Watermark is the watermark timestamp
	Watermark *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// Metadata is the metadata of the message after a message is read from the buffer.
	Metadata *MessageMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type WriteMessage struct {

	// Message is the actual message to be written
	Message *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Tags are the tags associated with the message
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}