cdc

type BootstrapProducerRequestPB struct {
	TableIds []string `protobuf:"bytes,1,rep,name=table_ids,json=tableIds" json:"table_ids,omitempty"`
	// contains filtered or unexported fields
}

type BootstrapProducerResponsePB struct {
	Error           *CDCErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	CdcBootstrapIds [][]byte    `protobuf:"bytes,2,rep,name=cdc_bootstrap_ids,json=cdcBootstrapIds" json:"cdc_bootstrap_ids,omitempty"`
	// contains filtered or unexported fields
}

type CDCCheckpointPB struct {
	OpId *util.OpIdPB `protobuf:"bytes,1,opt,name=op_id,json=opId" json:"op_id,omitempty"`
	// contains filtered or unexported fields
}

type CDCErrorPB struct {

	// The error code.
	Code *CDCErrorPB_Code `protobuf:"varint,1,opt,name=code,enum=yb.cdc.CDCErrorPB_Code,def=1" json:"code,omitempty"`
	// The Status object for the error. This will include a textual
	// message that may be more useful to present in log messages, etc,
	// though its error code is less specific.
	Status *common.AppStatusPB `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type CDCErrorPB_Code int32

type CDCRecordFormat int32

type CDCRecordPB struct {
	Time      *uint64                    `protobuf:"varint,1,opt,name=time" json:"time,omitempty"`
	Operation *CDCRecordPB_OperationType `protobuf:"varint,2,opt,name=operation,enum=yb.cdc.CDCRecordPB_OperationType" json:"operation,omitempty"`
	// Primary key of the record that changed
	Key []*KeyValuePairPB `protobuf:"bytes,3,rep,name=key" json:"key,omitempty"`
	// Key-value pairs (column_name : value) of changes / before record / after record
	Changes          []*KeyValuePairPB           `protobuf:"bytes,4,rep,name=changes" json:"changes,omitempty"`
	Before           []*KeyValuePairPB           `protobuf:"bytes,5,rep,name=before" json:"before,omitempty"` // NOT CURRENTLY USED
	After            []*KeyValuePairPB           `protobuf:"bytes,6,rep,name=after" json:"after,omitempty"`   // NOT CURRENTLY USED
	TransactionState *tserver.TransactionStatePB `protobuf:"bytes,7,opt,name=transaction_state,json=transactionState" json:"transaction_state,omitempty"`
	// If transaction_state.status is APPLYING, then partitions will contain the partition for the
	// tablet being polled.
	Partition *common.PartitionPB `protobuf:"bytes,9,opt,name=partition" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

type CDCRecordPB_OperationType int32

type CDCRecordType int32

type CDCService interface {
	CreateCDCStream(request *CreateCDCStreamRequestPB) (*CreateCDCStreamResponsePB, error)
	DeleteCDCStream(request *DeleteCDCStreamRequestPB) (*DeleteCDCStreamResponsePB, error)
	ListTablets(request *ListTabletsRequestPB) (*ListTabletsResponsePB, error)
	GetChanges(request *GetChangesRequestPB) (*GetChangesResponsePB, error)
	GetCheckpoint(request *GetCheckpointRequestPB) (*GetCheckpointResponsePB, error)
	UpdateCdcReplicatedIndex(request *UpdateCdcReplicatedIndexRequestPB) (*UpdateCdcReplicatedIndexResponsePB, error)
	BootstrapProducer(request *BootstrapProducerRequestPB) (*BootstrapProducerResponsePB, error)
	GetLatestEntryOpId(request *GetLatestEntryOpIdRequestPB) (*GetLatestEntryOpIdResponsePB, error)
}

type CDCServiceImpl struct {
	Log       logr.Logger
	Messenger message.Messenger
}

type CDCTabletPB struct {
	TabletId []byte `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Tservers holding data for the tablet.
	Tservers []*CDCTabletPB_ReplicaPB `protobuf:"bytes,2,rep,name=tservers" json:"tservers,omitempty"`
	// contains filtered or unexported fields
}

type CDCTabletPB_ReplicaPB struct {
	BroadcastAddresses []*common.HostPortPB `protobuf:"bytes,1,rep,name=broadcast_addresses,json=broadcastAddresses" json:"broadcast_addresses,omitempty"` // Don't use private_rpc_addresses since we're cross-universe
	// contains filtered or unexported fields
}

type ConsumerRegistryPB struct {

	// Map from producer universe uuid to metadata for that producer.
	ProducerMap map[string]*ProducerEntryPB `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateCDCStreamRequestPB struct {

	// Table to set up CDC on.
	TableId      *string          `protobuf:"bytes,1,opt,name=table_id,json=tableId" json:"table_id,omitempty"`
	RecordType   *CDCRecordType   `protobuf:"varint,2,opt,name=record_type,json=recordType,enum=yb.cdc.CDCRecordType,def=1" json:"record_type,omitempty"`
	RecordFormat *CDCRecordFormat `protobuf:"varint,3,opt,name=record_format,json=recordFormat,enum=yb.cdc.CDCRecordFormat,def=1" json:"record_format,omitempty"`
	// contains filtered or unexported fields
}

type CreateCDCStreamResponsePB struct {
	Error    *CDCErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	StreamId []byte      `protobuf:"bytes,2,opt,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteCDCStreamRequestPB struct {
	StreamId [][]byte `protobuf:"bytes,1,rep,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteCDCStreamResponsePB struct {
	Error *CDCErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type GetChangesRequestPB struct {
	StreamId []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	// Tablet to get the changes for.
	TabletId []byte `protobuf:"bytes,2,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Checkpoint to start reading from (exclusive).
	// Start reading from the first record after this checkpoint.
	FromCheckpoint *CDCCheckpointPB `protobuf:"bytes,3,opt,name=from_checkpoint,json=fromCheckpoint" json:"from_checkpoint,omitempty"`
	// Maximum records to read.
	MaxRecords *uint32 `protobuf:"varint,4,opt,name=max_records,json=maxRecords" json:"max_records,omitempty"`
	// Whether the caller knows the tablet address or needs to use us as a proxy.
	ServeAsProxy *bool `protobuf:"varint,5,opt,name=serve_as_proxy,json=serveAsProxy,def=1" json:"serve_as_proxy,omitempty"`
	// contains filtered or unexported fields
}

type GetChangesResponsePB struct {
	Error        *CDCErrorPB      `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	RecordType   *CDCRecordType   `protobuf:"varint,2,opt,name=record_type,json=recordType,enum=yb.cdc.CDCRecordType,def=1" json:"record_type,omitempty"`
	RecordFormat *CDCRecordFormat `protobuf:"varint,3,opt,name=record_format,json=recordFormat,enum=yb.cdc.CDCRecordFormat" json:"record_format,omitempty"`
	Records      []*CDCRecordPB   `protobuf:"bytes,4,rep,name=records" json:"records,omitempty"`
	// Checkpoint that consumers can send back in GetChanges RPC
	// to mark CDC records until this checkpoint as committed.
	Checkpoint *CDCCheckpointPB `protobuf:"bytes,5,opt,name=checkpoint" json:"checkpoint,omitempty"`
	// In case the tablet is no longer hosted on this tserver, provide the list of tservers holding
	// data for the tablet.
	Tserver []*common.HostPortPB `protobuf:"bytes,6,rep,name=tserver" json:"tserver,omitempty"`
	// contains filtered or unexported fields
}

type GetCheckpointRequestPB struct {
	StreamId []byte `protobuf:"bytes,1,opt,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	TabletId []byte `protobuf:"bytes,2,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// contains filtered or unexported fields
}

type GetCheckpointResponsePB struct {
	Error      *CDCErrorPB      `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Checkpoint *CDCCheckpointPB `protobuf:"bytes,2,opt,name=checkpoint" json:"checkpoint,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestEntryOpIdRequestPB struct {
	TabletId []byte `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestEntryOpIdResponsePB struct {
	Error *CDCErrorPB  `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	OpId  *util.OpIdPB `protobuf:"bytes,2,opt,name=op_id,json=opId" json:"op_id,omitempty"`
	// contains filtered or unexported fields
}

type KeyValuePairPB struct {
	Key   []byte            `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value *common.QLValuePB `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ListTabletsRequestPB struct {
	StreamId *string `protobuf:"bytes,1,opt,name=stream_id,json=streamId" json:"stream_id,omitempty"`
	// local_only = true will only list tablets local to the tserver that receives the request.
	// local_only = false will list  all tablets for the stream.
	LocalOnly *bool `protobuf:"varint,2,opt,name=local_only,json=localOnly,def=0" json:"local_only,omitempty"`
	// contains filtered or unexported fields
}

type ListTabletsResponsePB struct {
	Error   *CDCErrorPB    `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Tablets []*CDCTabletPB `protobuf:"bytes,2,rep,name=tablets" json:"tablets,omitempty"`
	// contains filtered or unexported fields
}

type ProducerEntryPB struct {

	// Map from stream id to metadata for that stream.
	StreamMap     map[string]*StreamEntryPB `` /* 176-byte string literal not displayed */
	MasterAddrs   []*common.HostPortPB      `protobuf:"bytes,2,rep,name=master_addrs,json=masterAddrs,proto3" json:"master_addrs,omitempty"`
	TserverAddrs  []*common.HostPortPB      `protobuf:"bytes,3,rep,name=tserver_addrs,json=tserverAddrs,proto3" json:"tserver_addrs,omitempty"`
	DisableStream bool                      `protobuf:"varint,4,opt,name=disable_stream,json=disableStream,proto3" json:"disable_stream,omitempty"` // [default = false] implicit in proto3
	// contains filtered or unexported fields
}

type ProducerTabletListPB struct {

	// List of tablet ids for a given producer table.
	Tablets []string `protobuf:"bytes,1,rep,name=tablets,proto3" json:"tablets,omitempty"`
	// contains filtered or unexported fields
}

type StreamEntryPB struct {

	// Map from consumer to producer tablet id.
	ConsumerProducerTabletMap      map[string]*ProducerTabletListPB `` /* 228-byte string literal not displayed */
	ConsumerTableId                string                           `protobuf:"bytes,2,opt,name=consumer_table_id,json=consumerTableId,proto3" json:"consumer_table_id,omitempty"`
	ProducerTableId                string                           `protobuf:"bytes,3,opt,name=producer_table_id,json=producerTableId,proto3" json:"producer_table_id,omitempty"`
	SameNumProducerConsumerTablets bool                             `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UpdateCdcReplicatedIndexRequestPB struct {

	// Tablet being updated.
	TabletId []byte `protobuf:"bytes,1,opt,name=tablet_id,json=tabletId" json:"tablet_id,omitempty"`
	// Minimum replicated index across all the streams for this tablet.
	ReplicatedIndex *int64 `protobuf:"varint,2,opt,name=replicated_index,json=replicatedIndex" json:"replicated_index,omitempty"`
	// contains filtered or unexported fields
}

type UpdateCdcReplicatedIndexResponsePB struct {
	Error *CDCErrorPB `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// contains filtered or unexported fields
}