pb

package
v0.0.64 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 6, 2024 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DBLogController_PullDumpInfo_FullMethodName        = "/pgcapture.DBLogController/PullDumpInfo"
	DBLogController_Schedule_FullMethodName            = "/pgcapture.DBLogController/Schedule"
	DBLogController_StopSchedule_FullMethodName        = "/pgcapture.DBLogController/StopSchedule"
	DBLogController_SetScheduleCoolDown_FullMethodName = "/pgcapture.DBLogController/SetScheduleCoolDown"
)
View Source 
const (
	Agent_Configure_FullMethodName  = "/pgcapture.Agent/Configure"
	Agent_Dump_FullMethodName       = "/pgcapture.Agent/Dump"
	Agent_StreamDump_FullMethodName = "/pgcapture.Agent/StreamDump"
)
View Source 
const (
	DBLogGateway_Capture_FullMethodName = "/pgcapture.DBLogGateway/Capture"
)

Variables

View Source 
var (
	Change_Operation_name = map[int32]string{
		0: "INSERT",
		1: "UPDATE",
		2: "DELETE",
	}
	Change_Operation_value = map[string]int32{
		"INSERT": 0,
		"UPDATE": 1,
		"DELETE": 2,
	}
)

Enum value maps for Change_Operation.

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pgcapture.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _Agent_Configure_Handler,
		},
		{
			MethodName: "Dump",
			Handler:    _Agent_Dump_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamDump",
			Handler:       _Agent_StreamDump_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pb/pgcapture.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DBLogController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pgcapture.DBLogController",
	HandlerType: (*DBLogControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Schedule",
			Handler:    _DBLogController_Schedule_Handler,
		},
		{
			MethodName: "StopSchedule",
			Handler:    _DBLogController_StopSchedule_Handler,
		},
		{
			MethodName: "SetScheduleCoolDown",
			Handler:    _DBLogController_SetScheduleCoolDown_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PullDumpInfo",
			Handler:       _DBLogController_PullDumpInfo_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pb/pgcapture.proto",
}

DBLogController_ServiceDesc is the grpc.ServiceDesc for DBLogController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DBLogGateway_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pgcapture.DBLogGateway",
	HandlerType: (*DBLogGatewayServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Capture",
			Handler:       _DBLogGateway_Capture_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pb/pgcapture.proto",
}

DBLogGateway_ServiceDesc is the grpc.ServiceDesc for DBLogGateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pb_pgcapture_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

func RegisterDBLogControllerServer 

func RegisterDBLogControllerServer(s grpc.ServiceRegistrar, srv DBLogControllerServer)

func RegisterDBLogGatewayServer 

func RegisterDBLogGatewayServer(s grpc.ServiceRegistrar, srv DBLogGatewayServer)

Types

type AgentClient 

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)
}

AgentClient is the client API for Agent service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentConfigRequest 

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

func (*AgentConfigRequest) Descriptor deprecated 

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

Deprecated: Use AgentConfigRequest.ProtoReflect.Descriptor instead.

func (*AgentConfigRequest) GetParameters 

func (x *AgentConfigRequest) GetParameters() *structpb.Struct

func (*AgentConfigRequest) ProtoMessage 

func (*AgentConfigRequest) ProtoMessage()

func (*AgentConfigRequest) ProtoReflect 

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

func (*AgentConfigRequest) Reset 

func (x *AgentConfigRequest) Reset()

func (*AgentConfigRequest) String 

func (x *AgentConfigRequest) String() string

type AgentConfigResponse 

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

func (*AgentConfigResponse) Descriptor deprecated 

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

Deprecated: Use AgentConfigResponse.ProtoReflect.Descriptor instead.

func (*AgentConfigResponse) GetReport 

func (x *AgentConfigResponse) GetReport() *structpb.Struct

func (*AgentConfigResponse) ProtoMessage 

func (*AgentConfigResponse) ProtoMessage()

func (*AgentConfigResponse) ProtoReflect 

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

func (*AgentConfigResponse) Reset 

func (x *AgentConfigResponse) Reset()

func (*AgentConfigResponse) String 

func (x *AgentConfigResponse) String() string

type AgentDumpRequest 

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
}

func (*AgentDumpRequest) Descriptor deprecated 

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

Deprecated: Use AgentDumpRequest.ProtoReflect.Descriptor instead.

func (*AgentDumpRequest) GetInfo 

func (x *AgentDumpRequest) GetInfo() *DumpInfoResponse

func (*AgentDumpRequest) GetMinLsn 

func (x *AgentDumpRequest) GetMinLsn() uint64

func (*AgentDumpRequest) ProtoMessage 

func (*AgentDumpRequest) ProtoMessage()

func (*AgentDumpRequest) ProtoReflect 

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

func (*AgentDumpRequest) Reset 

func (x *AgentDumpRequest) Reset()

func (*AgentDumpRequest) String 

func (x *AgentDumpRequest) String() string

type AgentDumpResponse 

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

func (*AgentDumpResponse) Descriptor deprecated 

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

Deprecated: Use AgentDumpResponse.ProtoReflect.Descriptor instead.

func (*AgentDumpResponse) GetChange 

func (x *AgentDumpResponse) GetChange() []*Change

func (*AgentDumpResponse) ProtoMessage 

func (*AgentDumpResponse) ProtoMessage()

func (*AgentDumpResponse) ProtoReflect 

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

func (*AgentDumpResponse) Reset 

func (x *AgentDumpResponse) Reset()

func (*AgentDumpResponse) String 

func (x *AgentDumpResponse) String() string

type AgentServer 

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
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_StreamDumpClient 

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

type Agent_StreamDumpServer 

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

type Begin 

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
}

func (*Begin) Descriptor deprecated 

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

Deprecated: Use Begin.ProtoReflect.Descriptor instead.

func (*Begin) GetCommitTime 

func (x *Begin) GetCommitTime() uint64

func (*Begin) GetFinalLsn 

func (x *Begin) GetFinalLsn() uint64

func (*Begin) GetRemoteXid 

func (x *Begin) GetRemoteXid() uint32

func (*Begin) ProtoMessage 

func (*Begin) ProtoMessage()

func (*Begin) ProtoReflect 

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

func (*Begin) Reset 

func (x *Begin) Reset()

func (*Begin) String 

func (x *Begin) String() string

type CaptureAck 

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
}

func (*CaptureAck) Descriptor deprecated 

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

Deprecated: Use CaptureAck.ProtoReflect.Descriptor instead.

func (*CaptureAck) GetCheckpoint 

func (x *CaptureAck) GetCheckpoint() *Checkpoint

func (*CaptureAck) GetRequeueReason 

func (x *CaptureAck) GetRequeueReason() string

func (*CaptureAck) ProtoMessage 

func (*CaptureAck) ProtoMessage()

func (*CaptureAck) ProtoReflect 

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

func (*CaptureAck) Reset 

func (x *CaptureAck) Reset()

func (*CaptureAck) String 

func (x *CaptureAck) String() string

type CaptureInit 

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
}

func (*CaptureInit) Descriptor deprecated 

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

Deprecated: Use CaptureInit.ProtoReflect.Descriptor instead.

func (*CaptureInit) GetParameters 

func (x *CaptureInit) GetParameters() *structpb.Struct

func (*CaptureInit) GetUri 

func (x *CaptureInit) GetUri() string

func (*CaptureInit) ProtoMessage 

func (*CaptureInit) ProtoMessage()

func (*CaptureInit) ProtoReflect 

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

func (*CaptureInit) Reset 

func (x *CaptureInit) Reset()

func (*CaptureInit) String 

func (x *CaptureInit) String() string

type CaptureMessage 

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
}

func (*CaptureMessage) Descriptor deprecated 

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

Deprecated: Use CaptureMessage.ProtoReflect.Descriptor instead.

func (*CaptureMessage) GetChange 

func (x *CaptureMessage) GetChange() *Change

func (*CaptureMessage) GetCheckpoint 

func (x *CaptureMessage) GetCheckpoint() *Checkpoint

func (*CaptureMessage) ProtoMessage 

func (*CaptureMessage) ProtoMessage()

func (*CaptureMessage) ProtoReflect 

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

func (*CaptureMessage) Reset 

func (x *CaptureMessage) Reset()

func (*CaptureMessage) String 

func (x *CaptureMessage) String() string

type CaptureRequest 

type CaptureRequest struct {

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

func (*CaptureRequest) Descriptor deprecated 

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

Deprecated: Use CaptureRequest.ProtoReflect.Descriptor instead.

func (*CaptureRequest) GetAck 

func (x *CaptureRequest) GetAck() *CaptureAck

func (*CaptureRequest) GetInit 

func (x *CaptureRequest) GetInit() *CaptureInit

func (*CaptureRequest) GetType 

func (m *CaptureRequest) GetType() isCaptureRequest_Type

func (*CaptureRequest) ProtoMessage 

func (*CaptureRequest) ProtoMessage()

func (*CaptureRequest) ProtoReflect 

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

func (*CaptureRequest) Reset 

func (x *CaptureRequest) Reset()

func (*CaptureRequest) String 

func (x *CaptureRequest) String() string

type CaptureRequest_Ack 

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

type CaptureRequest_Init 

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

type Change 

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
}

func (*Change) Descriptor deprecated 

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

Deprecated: Use Change.ProtoReflect.Descriptor instead.

func (*Change) GetNew 

func (x *Change) GetNew() []*Field

func (*Change) GetOld 

func (x *Change) GetOld() []*Field

func (*Change) GetOp 

func (x *Change) GetOp() Change_Operation

func (*Change) GetSchema 

func (x *Change) GetSchema() string

func (*Change) GetTable 

func (x *Change) GetTable() string

func (*Change) ProtoMessage 

func (*Change) ProtoMessage()

func (*Change) ProtoReflect 

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

func (*Change) Reset 

func (x *Change) Reset()

func (*Change) String 

func (x *Change) String() string

type Change_Operation 

type Change_Operation int32
const (
	Change_INSERT Change_Operation = 0
	Change_UPDATE Change_Operation = 1
	Change_DELETE Change_Operation = 2
)

func (Change_Operation) Descriptor 

func (Change_Operation) Descriptor() protoreflect.EnumDescriptor

func (Change_Operation) Enum 

func (x Change_Operation) Enum() *Change_Operation

func (Change_Operation) EnumDescriptor deprecated 

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

Deprecated: Use Change_Operation.Descriptor instead.

func (Change_Operation) Number 

func (x Change_Operation) Number() protoreflect.EnumNumber

func (Change_Operation) String 

func (x Change_Operation) String() string

func (Change_Operation) Type 

func (Change_Operation) Type() protoreflect.EnumType

type Checkpoint 

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
}

func (*Checkpoint) Descriptor deprecated 

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

Deprecated: Use Checkpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint) GetData 

func (x *Checkpoint) GetData() []byte

func (*Checkpoint) GetLsn 

func (x *Checkpoint) GetLsn() uint64

func (*Checkpoint) GetSeq 

func (x *Checkpoint) GetSeq() uint32

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect 

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

func (*Checkpoint) Reset 

func (x *Checkpoint) Reset()

func (*Checkpoint) String 

func (x *Checkpoint) String() string

type Commit 

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
}

func (*Commit) Descriptor deprecated 

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

Deprecated: Use Commit.ProtoReflect.Descriptor instead.

func (*Commit) GetCommitLsn 

func (x *Commit) GetCommitLsn() uint64

func (*Commit) GetCommitTime 

func (x *Commit) GetCommitTime() uint64

func (*Commit) GetEndLsn 

func (x *Commit) GetEndLsn() uint64

func (*Commit) ProtoMessage 

func (*Commit) ProtoMessage()

func (*Commit) ProtoReflect 

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

func (*Commit) Reset 

func (x *Commit) Reset()

func (*Commit) String 

func (x *Commit) String() string

type DBLogControllerClient 

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)
}

DBLogControllerClient is the client API for DBLogController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDBLogControllerClient 

func NewDBLogControllerClient(cc grpc.ClientConnInterface) DBLogControllerClient

type DBLogControllerServer 

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
}

DBLogControllerServer is the server API for DBLogController service. All implementations must embed UnimplementedDBLogControllerServer for forward compatibility

type DBLogController_PullDumpInfoClient 

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

type DBLogController_PullDumpInfoServer 

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

type DBLogGatewayClient 

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

DBLogGatewayClient is the client API for DBLogGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDBLogGatewayClient 

func NewDBLogGatewayClient(cc grpc.ClientConnInterface) DBLogGatewayClient

type DBLogGatewayServer 

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

DBLogGatewayServer is the server API for DBLogGateway service. All implementations must embed UnimplementedDBLogGatewayServer for forward compatibility

type DBLogGateway_CaptureClient 

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

type DBLogGateway_CaptureServer 

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

type DumpInfoRequest 

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
}

func (*DumpInfoRequest) Descriptor deprecated 

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

Deprecated: Use DumpInfoRequest.ProtoReflect.Descriptor instead.

func (*DumpInfoRequest) GetRequeueReason 

func (x *DumpInfoRequest) GetRequeueReason() string

func (*DumpInfoRequest) GetUri 

func (x *DumpInfoRequest) GetUri() string

func (*DumpInfoRequest) ProtoMessage 

func (*DumpInfoRequest) ProtoMessage()

func (*DumpInfoRequest) ProtoReflect 

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

func (*DumpInfoRequest) Reset 

func (x *DumpInfoRequest) Reset()

func (*DumpInfoRequest) String 

func (x *DumpInfoRequest) String() string

type DumpInfoResponse 

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
}

func (*DumpInfoResponse) Descriptor deprecated 

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

Deprecated: Use DumpInfoResponse.ProtoReflect.Descriptor instead.

func (*DumpInfoResponse) GetPageBegin 

func (x *DumpInfoResponse) GetPageBegin() uint32

func (*DumpInfoResponse) GetPageEnd 

func (x *DumpInfoResponse) GetPageEnd() uint32

func (*DumpInfoResponse) GetSchema 

func (x *DumpInfoResponse) GetSchema() string

func (*DumpInfoResponse) GetTable 

func (x *DumpInfoResponse) GetTable() string

func (*DumpInfoResponse) ProtoMessage 

func (*DumpInfoResponse) ProtoMessage()

func (*DumpInfoResponse) ProtoReflect 

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

func (*DumpInfoResponse) Reset 

func (x *DumpInfoResponse) Reset()

func (*DumpInfoResponse) String 

func (x *DumpInfoResponse) String() string

type Field 

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
}

func (*Field) Descriptor deprecated 

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

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetBinary 

func (x *Field) GetBinary() []byte

func (*Field) GetName 

func (x *Field) GetName() string

func (*Field) GetOid 

func (x *Field) GetOid() uint32

func (*Field) GetText 

func (x *Field) GetText() string

func (*Field) GetValue 

func (m *Field) GetValue() isField_Value

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) String 

func (x *Field) String() string

type Field_Binary 

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

type Field_Text 

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

type KeepAlive added in v0.0.58 

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

func (*KeepAlive) Descriptor deprecated added in v0.0.58 

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

Deprecated: Use KeepAlive.ProtoReflect.Descriptor instead.

func (*KeepAlive) ProtoMessage added in v0.0.58 

func (*KeepAlive) ProtoMessage()

func (*KeepAlive) ProtoReflect added in v0.0.58 

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

func (*KeepAlive) Reset added in v0.0.58 

func (x *KeepAlive) Reset()

func (*KeepAlive) String added in v0.0.58 

func (x *KeepAlive) String() string

type Message 

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
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetBegin 

func (x *Message) GetBegin() *Begin

func (*Message) GetChange 

func (x *Message) GetChange() *Change

func (*Message) GetCommit 

func (x *Message) GetCommit() *Commit

func (*Message) GetKeepAlive added in v0.0.58 

func (x *Message) GetKeepAlive() *KeepAlive

func (*Message) GetType 

func (m *Message) GetType() isMessage_Type

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Message_Begin 

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

type Message_Change 

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

type Message_Commit 

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

type Message_KeepAlive added in v0.0.58 

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

type ScheduleRequest 

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
}

func (*ScheduleRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleRequest.ProtoReflect.Descriptor instead.

func (*ScheduleRequest) GetDumps 

func (x *ScheduleRequest) GetDumps() []*DumpInfoResponse

func (*ScheduleRequest) GetUri 

func (x *ScheduleRequest) GetUri() string

func (*ScheduleRequest) ProtoMessage 

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) ProtoReflect 

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

func (*ScheduleRequest) Reset 

func (x *ScheduleRequest) Reset()

func (*ScheduleRequest) String 

func (x *ScheduleRequest) String() string

type ScheduleResponse 

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

func (*ScheduleResponse) Descriptor deprecated 

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

Deprecated: Use ScheduleResponse.ProtoReflect.Descriptor instead.

func (*ScheduleResponse) ProtoMessage 

func (*ScheduleResponse) ProtoMessage()

func (*ScheduleResponse) ProtoReflect 

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

func (*ScheduleResponse) Reset 

func (x *ScheduleResponse) Reset()

func (*ScheduleResponse) String 

func (x *ScheduleResponse) String() string

type SetScheduleCoolDownRequest 

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
}

func (*SetScheduleCoolDownRequest) Descriptor deprecated 

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

Deprecated: Use SetScheduleCoolDownRequest.ProtoReflect.Descriptor instead.

func (*SetScheduleCoolDownRequest) GetDuration 

func (x *SetScheduleCoolDownRequest) GetDuration() *durationpb.Duration

func (*SetScheduleCoolDownRequest) GetUri 

func (x *SetScheduleCoolDownRequest) GetUri() string

func (*SetScheduleCoolDownRequest) ProtoMessage 

func (*SetScheduleCoolDownRequest) ProtoMessage()

func (*SetScheduleCoolDownRequest) ProtoReflect 

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

func (*SetScheduleCoolDownRequest) Reset 

func (x *SetScheduleCoolDownRequest) Reset()

func (*SetScheduleCoolDownRequest) String 

func (x *SetScheduleCoolDownRequest) String() string

type SetScheduleCoolDownResponse 

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

func (*SetScheduleCoolDownResponse) Descriptor deprecated 

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

Deprecated: Use SetScheduleCoolDownResponse.ProtoReflect.Descriptor instead.

func (*SetScheduleCoolDownResponse) ProtoMessage 

func (*SetScheduleCoolDownResponse) ProtoMessage()

func (*SetScheduleCoolDownResponse) ProtoReflect 

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

func (*SetScheduleCoolDownResponse) Reset 

func (x *SetScheduleCoolDownResponse) Reset()

func (*SetScheduleCoolDownResponse) String 

func (x *SetScheduleCoolDownResponse) String() string

type StopScheduleRequest 

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

func (*StopScheduleRequest) Descriptor deprecated 

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

Deprecated: Use StopScheduleRequest.ProtoReflect.Descriptor instead.

func (*StopScheduleRequest) GetUri 

func (x *StopScheduleRequest) GetUri() string

func (*StopScheduleRequest) ProtoMessage 

func (*StopScheduleRequest) ProtoMessage()

func (*StopScheduleRequest) ProtoReflect 

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

func (*StopScheduleRequest) Reset 

func (x *StopScheduleRequest) Reset()

func (*StopScheduleRequest) String 

func (x *StopScheduleRequest) String() string

type StopScheduleResponse 

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

func (*StopScheduleResponse) Descriptor deprecated 

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

Deprecated: Use StopScheduleResponse.ProtoReflect.Descriptor instead.

func (*StopScheduleResponse) ProtoMessage 

func (*StopScheduleResponse) ProtoMessage()

func (*StopScheduleResponse) ProtoReflect 

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

func (*StopScheduleResponse) Reset 

func (x *StopScheduleResponse) Reset()

func (*StopScheduleResponse) String 

func (x *StopScheduleResponse) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) Configure 

func (UnimplementedAgentServer) Configure(context.Context, *AgentConfigRequest) (*AgentConfigResponse, error)

func (UnimplementedAgentServer) Dump 

func (UnimplementedAgentServer) Dump(context.Context, *AgentDumpRequest) (*AgentDumpResponse, error)

func (UnimplementedAgentServer) StreamDump 

func (UnimplementedAgentServer) StreamDump(*AgentDumpRequest, Agent_StreamDumpServer) error

type UnimplementedDBLogControllerServer 

type UnimplementedDBLogControllerServer struct {
}

UnimplementedDBLogControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedDBLogControllerServer) PullDumpInfo 

func (UnimplementedDBLogControllerServer) PullDumpInfo(DBLogController_PullDumpInfoServer) error

func (UnimplementedDBLogControllerServer) Schedule 

func (UnimplementedDBLogControllerServer) Schedule(context.Context, *ScheduleRequest) (*ScheduleResponse, error)

func (UnimplementedDBLogControllerServer) SetScheduleCoolDown 

func (UnimplementedDBLogControllerServer) SetScheduleCoolDown(context.Context, *SetScheduleCoolDownRequest) (*SetScheduleCoolDownResponse, error)

func (UnimplementedDBLogControllerServer) StopSchedule 

func (UnimplementedDBLogControllerServer) StopSchedule(context.Context, *StopScheduleRequest) (*StopScheduleResponse, error)

type UnimplementedDBLogGatewayServer 

type UnimplementedDBLogGatewayServer struct {
}

UnimplementedDBLogGatewayServer must be embedded to have forward compatible implementations.

func (UnimplementedDBLogGatewayServer) Capture 

func (UnimplementedDBLogGatewayServer) Capture(DBLogGateway_CaptureServer) error

type UnsafeAgentServer 

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

UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.

type UnsafeDBLogControllerServer 

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

UnsafeDBLogControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DBLogControllerServer will result in compilation errors.

type UnsafeDBLogGatewayServer 

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

UnsafeDBLogGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DBLogGatewayServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.