agentrpc

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BackupBinlogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "BackupBinlogService",
	HandlerType: (*BackupBinlogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FlushAndBackupBinlog",
			Handler:    _BackupBinlogService_FlushAndBackupBinlog_Handler,
		},
		{
			MethodName: "FlushBinlog",
			Handler:    _BackupBinlogService_FlushBinlog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "agentrpc.proto",
}

BackupBinlogService_ServiceDesc is the grpc.ServiceDesc for BackupBinlogService 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 CloneService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "CloneService",
	HandlerType: (*CloneServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Clone",
			Handler:    _CloneService_Clone_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "agentrpc.proto",
}

CloneService_ServiceDesc is the grpc.ServiceDesc for CloneService 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_agentrpc_proto protoreflect.FileDescriptor

Functions

func RegisterBackupBinlogServiceServer 

func RegisterBackupBinlogServiceServer(s grpc.ServiceRegistrar, srv BackupBinlogServiceServer)

func RegisterCloneServiceServer 

func RegisterCloneServiceServer(s grpc.ServiceRegistrar, srv CloneServiceServer)

Types

type BackupBinlogServiceClient 

type BackupBinlogServiceClient interface {
	FlushAndBackupBinlog(ctx context.Context, in *FlushAndBackupBinlogRequest, opts ...grpc.CallOption) (*FlushAndBackupBinlogResponse, error)
	FlushBinlog(ctx context.Context, in *FlushBinlogRequest, opts ...grpc.CallOption) (*FlushBinlogResponse, error)
}

BackupBinlogServiceClient is the client API for BackupBinlogService 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 NewBackupBinlogServiceClient 

func NewBackupBinlogServiceClient(cc grpc.ClientConnInterface) BackupBinlogServiceClient

type BackupBinlogServiceServer 

type BackupBinlogServiceServer interface {
	FlushAndBackupBinlog(context.Context, *FlushAndBackupBinlogRequest) (*FlushAndBackupBinlogResponse, error)
	FlushBinlog(context.Context, *FlushBinlogRequest) (*FlushBinlogResponse, error)
	// contains filtered or unexported methods
}

BackupBinlogServiceServer is the server API for BackupBinlogService service. All implementations must embed UnimplementedBackupBinlogServiceServer for forward compatibility

type CloneRequest 

type CloneRequest struct {
	Token     string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	External  bool   `protobuf:"varint,2,opt,name=external,proto3" json:"external,omitempty"`
	DonorHost string `protobuf:"bytes,3,opt,name=donor_host,json=donorHost,proto3" json:"donor_host,omitempty"`
	DonorPort int32  `protobuf:"varint,4,opt,name=donor_port,json=donorPort,proto3" json:"donor_port,omitempty"`
	// contains filtered or unexported fields
}

func (*CloneRequest) Descriptor deprecated 

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

Deprecated: Use CloneRequest.ProtoReflect.Descriptor instead.

func (*CloneRequest) GetDonorHost 

func (x *CloneRequest) GetDonorHost() string

func (*CloneRequest) GetDonorPort 

func (x *CloneRequest) GetDonorPort() int32

func (*CloneRequest) GetExternal 

func (x *CloneRequest) GetExternal() bool

func (*CloneRequest) GetToken 

func (x *CloneRequest) GetToken() string

func (*CloneRequest) ProtoMessage 

func (*CloneRequest) ProtoMessage()

func (*CloneRequest) ProtoReflect 

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

func (*CloneRequest) Reset 

func (x *CloneRequest) Reset()

func (*CloneRequest) String 

func (x *CloneRequest) String() string

type CloneResponse 

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

func (*CloneResponse) Descriptor deprecated 

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

Deprecated: Use CloneResponse.ProtoReflect.Descriptor instead.

func (*CloneResponse) ProtoMessage 

func (*CloneResponse) ProtoMessage()

func (*CloneResponse) ProtoReflect 

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

func (*CloneResponse) Reset 

func (x *CloneResponse) Reset()

func (*CloneResponse) String 

func (x *CloneResponse) String() string

type CloneServiceClient 

type CloneServiceClient interface {
	Clone(ctx context.Context, in *CloneRequest, opts ...grpc.CallOption) (*CloneResponse, error)
}

CloneServiceClient is the client API for CloneService 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 NewCloneServiceClient 

func NewCloneServiceClient(cc grpc.ClientConnInterface) CloneServiceClient

type CloneServiceServer 

type CloneServiceServer interface {
	Clone(context.Context, *CloneRequest) (*CloneResponse, error)
	// contains filtered or unexported methods
}

CloneServiceServer is the server API for CloneService service. All implementations must embed UnimplementedCloneServiceServer for forward compatibility

type FlushAndBackupBinlogRequest 

type FlushAndBackupBinlogRequest struct {
	Token           string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	BackupId        string `protobuf:"bytes,2,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"`
	BucketHost      string `protobuf:"bytes,3,opt,name=bucket_host,json=bucketHost,proto3" json:"bucket_host,omitempty"`
	BucketPort      int32  `protobuf:"varint,4,opt,name=bucket_port,json=bucketPort,proto3" json:"bucket_port,omitempty"`
	BucketName      string `protobuf:"bytes,5,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	BucketRegion    string `protobuf:"bytes,6,opt,name=bucket_region,json=bucketRegion,proto3" json:"bucket_region,omitempty"`
	AccessKeyId     string `protobuf:"bytes,7,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`
	SecretAccessKey string `protobuf:"bytes,8,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushAndBackupBinlogRequest) Descriptor deprecated 

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

Deprecated: Use FlushAndBackupBinlogRequest.ProtoReflect.Descriptor instead.

func (*FlushAndBackupBinlogRequest) GetAccessKeyId 

func (x *FlushAndBackupBinlogRequest) GetAccessKeyId() string

func (*FlushAndBackupBinlogRequest) GetBackupId 

func (x *FlushAndBackupBinlogRequest) GetBackupId() string

func (*FlushAndBackupBinlogRequest) GetBucketHost 

func (x *FlushAndBackupBinlogRequest) GetBucketHost() string

func (*FlushAndBackupBinlogRequest) GetBucketName 

func (x *FlushAndBackupBinlogRequest) GetBucketName() string

func (*FlushAndBackupBinlogRequest) GetBucketPort 

func (x *FlushAndBackupBinlogRequest) GetBucketPort() int32

func (*FlushAndBackupBinlogRequest) GetBucketRegion 

func (x *FlushAndBackupBinlogRequest) GetBucketRegion() string

func (*FlushAndBackupBinlogRequest) GetSecretAccessKey 

func (x *FlushAndBackupBinlogRequest) GetSecretAccessKey() string

func (*FlushAndBackupBinlogRequest) GetToken 

func (x *FlushAndBackupBinlogRequest) GetToken() string

func (*FlushAndBackupBinlogRequest) ProtoMessage 

func (*FlushAndBackupBinlogRequest) ProtoMessage()

func (*FlushAndBackupBinlogRequest) ProtoReflect 

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

func (*FlushAndBackupBinlogRequest) Reset 

func (x *FlushAndBackupBinlogRequest) Reset()

func (*FlushAndBackupBinlogRequest) String 

func (x *FlushAndBackupBinlogRequest) String() string

type FlushAndBackupBinlogResponse 

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

func (*FlushAndBackupBinlogResponse) Descriptor deprecated 

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

Deprecated: Use FlushAndBackupBinlogResponse.ProtoReflect.Descriptor instead.

func (*FlushAndBackupBinlogResponse) ProtoMessage 

func (*FlushAndBackupBinlogResponse) ProtoMessage()

func (*FlushAndBackupBinlogResponse) ProtoReflect 

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

func (*FlushAndBackupBinlogResponse) Reset 

func (x *FlushAndBackupBinlogResponse) Reset()

func (*FlushAndBackupBinlogResponse) String 

func (x *FlushAndBackupBinlogResponse) String() string

type FlushBinlogRequest 

type FlushBinlogRequest struct {
	Token  string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Delete bool   `protobuf:"varint,2,opt,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*FlushBinlogRequest) Descriptor deprecated 

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

Deprecated: Use FlushBinlogRequest.ProtoReflect.Descriptor instead.

func (*FlushBinlogRequest) GetDelete 

func (x *FlushBinlogRequest) GetDelete() bool

func (*FlushBinlogRequest) GetToken 

func (x *FlushBinlogRequest) GetToken() string

func (*FlushBinlogRequest) ProtoMessage 

func (*FlushBinlogRequest) ProtoMessage()

func (*FlushBinlogRequest) ProtoReflect 

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

func (*FlushBinlogRequest) Reset 

func (x *FlushBinlogRequest) Reset()

func (*FlushBinlogRequest) String 

func (x *FlushBinlogRequest) String() string

type FlushBinlogResponse 

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

func (*FlushBinlogResponse) Descriptor deprecated 

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

Deprecated: Use FlushBinlogResponse.ProtoReflect.Descriptor instead.

func (*FlushBinlogResponse) ProtoMessage 

func (*FlushBinlogResponse) ProtoMessage()

func (*FlushBinlogResponse) ProtoReflect 

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

func (*FlushBinlogResponse) Reset 

func (x *FlushBinlogResponse) Reset()

func (*FlushBinlogResponse) String 

func (x *FlushBinlogResponse) String() string

type UnimplementedBackupBinlogServiceServer 

type UnimplementedBackupBinlogServiceServer struct {
}

UnimplementedBackupBinlogServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedBackupBinlogServiceServer) FlushAndBackupBinlog 

func (UnimplementedBackupBinlogServiceServer) FlushAndBackupBinlog(context.Context, *FlushAndBackupBinlogRequest) (*FlushAndBackupBinlogResponse, error)

func (UnimplementedBackupBinlogServiceServer) FlushBinlog 

func (UnimplementedBackupBinlogServiceServer) FlushBinlog(context.Context, *FlushBinlogRequest) (*FlushBinlogResponse, error)

type UnimplementedCloneServiceServer 

type UnimplementedCloneServiceServer struct {
}

UnimplementedCloneServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCloneServiceServer) Clone 

func (UnimplementedCloneServiceServer) Clone(context.Context, *CloneRequest) (*CloneResponse, error)

type UnsafeBackupBinlogServiceServer 

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

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

type UnsafeCloneServiceServer 

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

UnsafeCloneServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CloneServiceServer 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.