pb

type AgentClient interface {
	Configure(ctx context.Context, in *AgentConfigRequest, opts ...grpc.CallOption) (*AgentConfigResponse, error)
	Dump(ctx context.Context, in *AgentDumpRequest, opts ...grpc.CallOption) (*AgentDumpResponse, error)
	StreamDump(ctx context.Context, in *AgentDumpRequest, opts ...grpc.CallOption) (Agent_StreamDumpClient, error)
}

type AgentConfigRequest struct {
	Parameters *structpb.Struct `protobuf:"bytes,1,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

type AgentConfigResponse struct {
	Report *structpb.Struct `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

type AgentDumpRequest struct {
	MinLsn uint64            `protobuf:"varint,1,opt,name=min_lsn,json=minLsn,proto3" json:"min_lsn,omitempty"`
	Info   *DumpInfoResponse `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

type AgentDumpResponse struct {
	Change []*Change `protobuf:"bytes,1,rep,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

type AgentServer interface {
	Configure(context.Context, *AgentConfigRequest) (*AgentConfigResponse, error)
	Dump(context.Context, *AgentDumpRequest) (*AgentDumpResponse, error)
	StreamDump(*AgentDumpRequest, Agent_StreamDumpServer) error
	// contains filtered or unexported methods
}

type Agent_StreamDumpClient interface {
	Recv() (*Change, error)
	grpc.ClientStream
}

type Agent_StreamDumpServer interface {
	Send(*Change) error
	grpc.ServerStream
}

type Begin struct {
	FinalLsn   uint64 `protobuf:"varint,1,opt,name=final_lsn,json=finalLsn,proto3" json:"final_lsn,omitempty"`
	CommitTime uint64 `protobuf:"varint,2,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	RemoteXid  uint32 `protobuf:"varint,3,opt,name=remote_xid,json=remoteXid,proto3" json:"remote_xid,omitempty"`
	// contains filtered or unexported fields
}

type CaptureAck struct {
	Checkpoint    *Checkpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	RequeueReason string      `protobuf:"bytes,2,opt,name=requeue_reason,json=requeueReason,proto3" json:"requeue_reason,omitempty"`
	// contains filtered or unexported fields
}

type CaptureInit struct {
	Uri        string           `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Parameters *structpb.Struct `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

type CaptureMessage struct {
	Checkpoint *Checkpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Change     *Change     `protobuf:"bytes,2,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

type CaptureRequest struct {

	// Types that are assignable to Type:
	//
	//	*CaptureRequest_Init
	//	*CaptureRequest_Ack
	Type isCaptureRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type CaptureRequest_Ack struct {
	Ack *CaptureAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"`
}

type CaptureRequest_Init struct {
	Init *CaptureInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type Change struct {
	Op     Change_Operation `protobuf:"varint,1,opt,name=op,proto3,enum=pgcapture.Change_Operation" json:"op,omitempty"`
	Schema string           `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	Table  string           `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	New    []*Field         `protobuf:"bytes,4,rep,name=new,proto3" json:"new,omitempty"`
	Old    []*Field         `protobuf:"bytes,5,rep,name=old,proto3" json:"old,omitempty"`
	// contains filtered or unexported fields
}

type Change_Operation int32

type Checkpoint struct {
	Lsn  uint64 `protobuf:"varint,1,opt,name=lsn,proto3" json:"lsn,omitempty"`
	Seq  uint32 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type Commit struct {
	CommitLsn  uint64 `protobuf:"varint,1,opt,name=commit_lsn,json=commitLsn,proto3" json:"commit_lsn,omitempty"`
	EndLsn     uint64 `protobuf:"varint,2,opt,name=end_lsn,json=endLsn,proto3" json:"end_lsn,omitempty"`
	CommitTime uint64 `protobuf:"varint,3,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	// contains filtered or unexported fields
}

type DBLogControllerClient interface {
	PullDumpInfo(ctx context.Context, opts ...grpc.CallOption) (DBLogController_PullDumpInfoClient, error)
	Schedule(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleResponse, error)
	StopSchedule(ctx context.Context, in *StopScheduleRequest, opts ...grpc.CallOption) (*StopScheduleResponse, error)
	SetScheduleCoolDown(ctx context.Context, in *SetScheduleCoolDownRequest, opts ...grpc.CallOption) (*SetScheduleCoolDownResponse, error)
}

type DBLogControllerServer interface {
	PullDumpInfo(DBLogController_PullDumpInfoServer) error
	Schedule(context.Context, *ScheduleRequest) (*ScheduleResponse, error)
	StopSchedule(context.Context, *StopScheduleRequest) (*StopScheduleResponse, error)
	SetScheduleCoolDown(context.Context, *SetScheduleCoolDownRequest) (*SetScheduleCoolDownResponse, error)
	// contains filtered or unexported methods
}

type DBLogController_PullDumpInfoClient interface {
	Send(*DumpInfoRequest) error
	Recv() (*DumpInfoResponse, error)
	grpc.ClientStream
}

type DBLogController_PullDumpInfoServer interface {
	Send(*DumpInfoResponse) error
	Recv() (*DumpInfoRequest, error)
	grpc.ServerStream
}

type DBLogGatewayClient interface {
	Capture(ctx context.Context, opts ...grpc.CallOption) (DBLogGateway_CaptureClient, error)
}

type DBLogGatewayServer interface {
	Capture(DBLogGateway_CaptureServer) error
	// contains filtered or unexported methods
}

type DBLogGateway_CaptureClient interface {
	Send(*CaptureRequest) error
	Recv() (*CaptureMessage, error)
	grpc.ClientStream
}

type DBLogGateway_CaptureServer interface {
	Send(*CaptureMessage) error
	Recv() (*CaptureRequest, error)
	grpc.ServerStream
}

type DumpInfoRequest struct {
	Uri           string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	RequeueReason string `protobuf:"bytes,2,opt,name=requeue_reason,json=requeueReason,proto3" json:"requeue_reason,omitempty"`
	// contains filtered or unexported fields
}

type DumpInfoResponse struct {
	Schema    string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Table     string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	PageBegin uint32 `protobuf:"varint,3,opt,name=page_begin,json=pageBegin,proto3" json:"page_begin,omitempty"`
	PageEnd   uint32 `protobuf:"varint,4,opt,name=page_end,json=pageEnd,proto3" json:"page_end,omitempty"`
	// contains filtered or unexported fields
}

type Field struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Oid  uint32 `protobuf:"varint,2,opt,name=oid,proto3" json:"oid,omitempty"`
	// Types that are assignable to Value:
	//
	//	*Field_Binary
	//	*Field_Text
	Value isField_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type Field_Binary struct {
	Binary []byte `protobuf:"bytes,3,opt,name=binary,proto3,oneof"`
}

type Field_Text struct {
	Text string `protobuf:"bytes,4,opt,name=text,proto3,oneof"`
}

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

type Message struct {

	// Types that are assignable to Type:
	//
	//	*Message_Begin
	//	*Message_Commit
	//	*Message_Change
	//	*Message_KeepAlive
	Type isMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type Message_Begin struct {
	Begin *Begin `protobuf:"bytes,1,opt,name=begin,proto3,oneof"`
}

type Message_Change struct {
	Change *Change `protobuf:"bytes,3,opt,name=change,proto3,oneof"`
}

type Message_Commit struct {
	Commit *Commit `protobuf:"bytes,2,opt,name=commit,proto3,oneof"`
}

type Message_KeepAlive struct {
	KeepAlive *KeepAlive `protobuf:"bytes,4,opt,name=keep_alive,json=keepAlive,proto3,oneof"`
}

type ScheduleRequest struct {
	Uri   string              `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Dumps []*DumpInfoResponse `protobuf:"bytes,2,rep,name=dumps,proto3" json:"dumps,omitempty"`
	// contains filtered or unexported fields
}

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

type SetScheduleCoolDownRequest struct {
	Uri      string               `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type UnimplementedAgentServer struct {
}

type UnimplementedDBLogControllerServer struct {
}

type UnimplementedDBLogGatewayServer struct {
}

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

type UnsafeDBLogControllerServer interface {
	// contains filtered or unexported methods
}

type UnsafeDBLogGatewayServer interface {
	// contains filtered or unexported methods
}