primarybackup

Documentation

Index

• Variables
• func RegisterBackupServer(s grpc.ServiceRegistrar, srv BackupServer)
• type BackupClient
  • func NewBackupClient(cc grpc.ClientConnInterface) BackupClient
• type BackupServer
• type ForwardReply
  • func (*ForwardReply) Descriptor() ([]byte, []int)
  • func (*ForwardReply) ProtoMessage()
  • func (m *ForwardReply) Reset()
  • func (m *ForwardReply) String() string
  • func (m *ForwardReply) XXX_DiscardUnknown()
  • func (m *ForwardReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ForwardReply) XXX_Merge(src proto.Message)
  • func (m *ForwardReply) XXX_Size() int
  • func (m *ForwardReply) XXX_Unmarshal(b []byte) error
• type ForwardRequest
  • func (*ForwardRequest) Descriptor() ([]byte, []int)
  • func (m *ForwardRequest) GetClientRequest() isForwardRequest_ClientRequest
  • func (m *ForwardRequest) GetCopyRequest() *fs3.CopyRequest
  • func (m *ForwardRequest) GetGetRequest() *fs3.GetRequest
  • func (m *ForwardRequest) GetRemoveRequest() *fs3.RemoveRequest
  • func (*ForwardRequest) ProtoMessage()
  • func (m *ForwardRequest) Reset()
  • func (m *ForwardRequest) String() string
  • func (m *ForwardRequest) XXX_DiscardUnknown()
  • func (m *ForwardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ForwardRequest) XXX_Merge(src proto.Message)
  • func (*ForwardRequest) XXX_OneofWrappers() []interface{}
  • func (m *ForwardRequest) XXX_Size() int
  • func (m *ForwardRequest) XXX_Unmarshal(b []byte) error
• type ForwardRequest_CopyRequest
• type ForwardRequest_GetRequest
• type ForwardRequest_RemoveRequest
• type UnimplementedBackupServer
  • func (UnimplementedBackupServer) Forward(context.Context, *ForwardRequest) (*ForwardReply, error)
• type UnsafeBackupServer

Variables

var Backup_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "primarybackup.Backup",
	HandlerType: (*BackupServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Forward",
			Handler:    _Backup_Forward_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "primarybackup/primarybackup.proto",
}

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

Functions

func RegisterBackupServer

func RegisterBackupServer(s grpc.ServiceRegistrar, srv BackupServer)

Types

type BackupClient

type BackupClient interface {
	Forward(ctx context.Context, in *ForwardRequest, opts ...grpc.CallOption) (*ForwardReply, error)
}

BackupClient is the client API for Backup 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 NewBackupClient

func NewBackupClient(cc grpc.ClientConnInterface) BackupClient

type BackupServer

type BackupServer interface {
	Forward(context.Context, *ForwardRequest) (*ForwardReply, error)
	// contains filtered or unexported methods
}

BackupServer is the server API for Backup service. All implementations must embed UnimplementedBackupServer for forward compatibility

type ForwardReply

type ForwardReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ForwardReply) Descriptor

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

func (*ForwardReply) ProtoMessage

func (*ForwardReply) ProtoMessage()

func (*ForwardReply) Reset

func (m *ForwardReply) Reset()

func (*ForwardReply) String

func (m *ForwardReply) String() string

func (*ForwardReply) XXX_DiscardUnknown

func (m *ForwardReply) XXX_DiscardUnknown()

func (*ForwardReply) XXX_Marshal

func (m *ForwardReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardReply) XXX_Merge

func (m *ForwardReply) XXX_Merge(src proto.Message)

func (*ForwardReply) XXX_Size

func (m *ForwardReply) XXX_Size() int

func (*ForwardReply) XXX_Unmarshal

func (m *ForwardReply) XXX_Unmarshal(b []byte) error

type ForwardRequest

type ForwardRequest struct {
	// Types that are valid to be assigned to ClientRequest:
	//	*ForwardRequest_CopyRequest
	//	*ForwardRequest_RemoveRequest
	//	*ForwardRequest_GetRequest
	ClientRequest        isForwardRequest_ClientRequest `protobuf_oneof:"client_request"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*ForwardRequest) Descriptor

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

func (*ForwardRequest) GetClientRequest

func (m *ForwardRequest) GetClientRequest() isForwardRequest_ClientRequest

func (*ForwardRequest) GetCopyRequest

func (m *ForwardRequest) GetCopyRequest() *fs3.CopyRequest

func (*ForwardRequest) GetGetRequest

func (m *ForwardRequest) GetGetRequest() *fs3.GetRequest

func (*ForwardRequest) GetRemoveRequest

func (m *ForwardRequest) GetRemoveRequest() *fs3.RemoveRequest

func (*ForwardRequest) ProtoMessage

func (*ForwardRequest) ProtoMessage()

func (*ForwardRequest) Reset

func (m *ForwardRequest) Reset()

func (*ForwardRequest) String

func (m *ForwardRequest) String() string

func (*ForwardRequest) XXX_DiscardUnknown

func (m *ForwardRequest) XXX_DiscardUnknown()

func (*ForwardRequest) XXX_Marshal

func (m *ForwardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ForwardRequest) XXX_Merge

func (m *ForwardRequest) XXX_Merge(src proto.Message)

func (*ForwardRequest) XXX_OneofWrappers

func (*ForwardRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ForwardRequest) XXX_Size

func (m *ForwardRequest) XXX_Size() int

func (*ForwardRequest) XXX_Unmarshal

func (m *ForwardRequest) XXX_Unmarshal(b []byte) error

type ForwardRequest_CopyRequest

type ForwardRequest_CopyRequest struct {
	CopyRequest *fs3.CopyRequest `protobuf:"bytes,1,opt,name=copy_request,json=copyRequest,proto3,oneof"`
}

type ForwardRequest_GetRequest

type ForwardRequest_GetRequest struct {
	GetRequest *fs3.GetRequest `protobuf:"bytes,3,opt,name=get_request,json=getRequest,proto3,oneof"`
}

type ForwardRequest_RemoveRequest

type ForwardRequest_RemoveRequest struct {
	RemoveRequest *fs3.RemoveRequest `protobuf:"bytes,2,opt,name=remove_request,json=removeRequest,proto3,oneof"`
}

type UnimplementedBackupServer

type UnimplementedBackupServer struct {
}

UnimplementedBackupServer must be embedded to have forward compatible implementations.

func (UnimplementedBackupServer) Forward

func (UnimplementedBackupServer) Forward(context.Context, *ForwardRequest) (*ForwardReply, error)

type UnsafeBackupServer

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

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