pb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BackupRequest_Mode_name = map[int32]string{
		0: "DIFFERENTIAL",
		1: "FULL",
	}
	BackupRequest_Mode_value = map[string]int32{
		"DIFFERENTIAL": 0,
		"FULL":         1,
	}
)

Enum value maps for BackupRequest_Mode.

View Source 
var File_pkg_pb_medusa_proto protoreflect.FileDescriptor
View Source 
var Medusa_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Medusa",
	HandlerType: (*MedusaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Backup",
			Handler:    _Medusa_Backup_Handler,
		},
		{
			MethodName: "BackupStatus",
			Handler:    _Medusa_BackupStatus_Handler,
		},
		{
			MethodName: "DeleteBackup",
			Handler:    _Medusa_DeleteBackup_Handler,
		},
		{
			MethodName: "GetBackups",
			Handler:    _Medusa_GetBackups_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/pb/medusa.proto",
}

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

Functions

func RegisterMedusaServer 

func RegisterMedusaServer(s grpc.ServiceRegistrar, srv MedusaServer)

Types

type BackupNode added in v0.4.0 

type BackupNode struct {
	Host       string  `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Tokens     []int64 `protobuf:"varint,2,rep,packed,name=tokens,proto3" json:"tokens,omitempty"`
	Datacenter string  `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	Rack       string  `protobuf:"bytes,4,opt,name=rack,proto3" json:"rack,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupNode) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use BackupNode.ProtoReflect.Descriptor instead.

func (*BackupNode) GetDatacenter added in v0.4.0 

func (x *BackupNode) GetDatacenter() string

func (*BackupNode) GetHost added in v0.4.0 

func (x *BackupNode) GetHost() string

func (*BackupNode) GetRack added in v0.4.0 

func (x *BackupNode) GetRack() string

func (*BackupNode) GetTokens added in v0.4.0 

func (x *BackupNode) GetTokens() []int64

func (*BackupNode) ProtoMessage added in v0.4.0 

func (*BackupNode) ProtoMessage()

func (*BackupNode) ProtoReflect added in v0.4.0 

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

func (*BackupNode) Reset added in v0.4.0 

func (x *BackupNode) Reset()

func (*BackupNode) String added in v0.4.0 

func (x *BackupNode) String() string

type BackupRequest 

type BackupRequest struct {
	Name string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mode BackupRequest_Mode `protobuf:"varint,2,opt,name=mode,proto3,enum=BackupRequest_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupRequest) Descriptor deprecated 

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

Deprecated: Use BackupRequest.ProtoReflect.Descriptor instead.

func (*BackupRequest) GetMode 

func (x *BackupRequest) GetMode() BackupRequest_Mode

func (*BackupRequest) GetName 

func (x *BackupRequest) GetName() string

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) ProtoReflect 

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

func (*BackupRequest) Reset 

func (x *BackupRequest) Reset()

func (*BackupRequest) String 

func (x *BackupRequest) String() string

type BackupRequest_Mode 

type BackupRequest_Mode int32
const (
	BackupRequest_DIFFERENTIAL BackupRequest_Mode = 0
	BackupRequest_FULL         BackupRequest_Mode = 1
)

func (BackupRequest_Mode) Descriptor 

func (BackupRequest_Mode) Descriptor() protoreflect.EnumDescriptor

func (BackupRequest_Mode) Enum 

func (x BackupRequest_Mode) Enum() *BackupRequest_Mode

func (BackupRequest_Mode) EnumDescriptor deprecated 

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

Deprecated: Use BackupRequest_Mode.Descriptor instead.

func (BackupRequest_Mode) Number 

func (x BackupRequest_Mode) Number() protoreflect.EnumNumber

func (BackupRequest_Mode) String 

func (x BackupRequest_Mode) String() string

func (BackupRequest_Mode) Type 

func (BackupRequest_Mode) Type() protoreflect.EnumType

type BackupResponse 

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

func (*BackupResponse) Descriptor deprecated 

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

Deprecated: Use BackupResponse.ProtoReflect.Descriptor instead.

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) ProtoReflect 

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

func (*BackupResponse) Reset 

func (x *BackupResponse) Reset()

func (*BackupResponse) String 

func (x *BackupResponse) String() string

type BackupStatusRequest 

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

func (*BackupStatusRequest) Descriptor deprecated 

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

Deprecated: Use BackupStatusRequest.ProtoReflect.Descriptor instead.

func (*BackupStatusRequest) GetBackupName 

func (x *BackupStatusRequest) GetBackupName() string

func (*BackupStatusRequest) ProtoMessage 

func (*BackupStatusRequest) ProtoMessage()

func (*BackupStatusRequest) ProtoReflect 

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

func (*BackupStatusRequest) Reset 

func (x *BackupStatusRequest) Reset()

func (*BackupStatusRequest) String 

func (x *BackupStatusRequest) String() string

type BackupStatusResponse 

type BackupStatusResponse struct {
	FinishedNodes   []string `protobuf:"bytes,1,rep,name=finishedNodes,proto3" json:"finishedNodes,omitempty"`
	UnfinishedNodes []string `protobuf:"bytes,2,rep,name=unfinishedNodes,proto3" json:"unfinishedNodes,omitempty"`
	MissingNodes    []string `protobuf:"bytes,3,rep,name=missingNodes,proto3" json:"missingNodes,omitempty"`
	StartTime       string   `protobuf:"bytes,4,opt,name=startTime,proto3" json:"startTime,omitempty"`
	FinishTime      string   `protobuf:"bytes,5,opt,name=finishTime,proto3" json:"finishTime,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupStatusResponse) Descriptor deprecated 

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

Deprecated: Use BackupStatusResponse.ProtoReflect.Descriptor instead.

func (*BackupStatusResponse) GetFinishTime 

func (x *BackupStatusResponse) GetFinishTime() string

func (*BackupStatusResponse) GetFinishedNodes 

func (x *BackupStatusResponse) GetFinishedNodes() []string

func (*BackupStatusResponse) GetMissingNodes 

func (x *BackupStatusResponse) GetMissingNodes() []string

func (*BackupStatusResponse) GetStartTime 

func (x *BackupStatusResponse) GetStartTime() string

func (*BackupStatusResponse) GetUnfinishedNodes 

func (x *BackupStatusResponse) GetUnfinishedNodes() []string

func (*BackupStatusResponse) ProtoMessage 

func (*BackupStatusResponse) ProtoMessage()

func (*BackupStatusResponse) ProtoReflect 

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

func (*BackupStatusResponse) Reset 

func (x *BackupStatusResponse) Reset()

func (*BackupStatusResponse) String 

func (x *BackupStatusResponse) String() string

type BackupSummary 

type BackupSummary struct {
	BackupName    string        `protobuf:"bytes,1,opt,name=backupName,proto3" json:"backupName,omitempty"`
	StartTime     int64         `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	FinishTime    int64         `protobuf:"varint,3,opt,name=finishTime,proto3" json:"finishTime,omitempty"`
	TotalNodes    int32         `protobuf:"varint,4,opt,name=totalNodes,proto3" json:"totalNodes,omitempty"`
	FinishedNodes int32         `protobuf:"varint,5,opt,name=finishedNodes,proto3" json:"finishedNodes,omitempty"`
	Nodes         []*BackupNode `protobuf:"bytes,6,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*BackupSummary) Descriptor deprecated 

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

Deprecated: Use BackupSummary.ProtoReflect.Descriptor instead.

func (*BackupSummary) GetBackupName 

func (x *BackupSummary) GetBackupName() string

func (*BackupSummary) GetFinishTime 

func (x *BackupSummary) GetFinishTime() int64

func (*BackupSummary) GetFinishedNodes 

func (x *BackupSummary) GetFinishedNodes() int32

func (*BackupSummary) GetNodes added in v0.4.0 

func (x *BackupSummary) GetNodes() []*BackupNode

func (*BackupSummary) GetStartTime 

func (x *BackupSummary) GetStartTime() int64

func (*BackupSummary) GetTotalNodes 

func (x *BackupSummary) GetTotalNodes() int32

func (*BackupSummary) ProtoMessage 

func (*BackupSummary) ProtoMessage()

func (*BackupSummary) ProtoReflect 

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

func (*BackupSummary) Reset 

func (x *BackupSummary) Reset()

func (*BackupSummary) String 

func (x *BackupSummary) String() string

type DeleteBackupRequest 

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

func (*DeleteBackupRequest) Descriptor deprecated 

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

Deprecated: Use DeleteBackupRequest.ProtoReflect.Descriptor instead.

func (*DeleteBackupRequest) GetName 

func (x *DeleteBackupRequest) GetName() string

func (*DeleteBackupRequest) ProtoMessage 

func (*DeleteBackupRequest) ProtoMessage()

func (*DeleteBackupRequest) ProtoReflect 

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

func (*DeleteBackupRequest) Reset 

func (x *DeleteBackupRequest) Reset()

func (*DeleteBackupRequest) String 

func (x *DeleteBackupRequest) String() string

type DeleteBackupResponse 

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

func (*DeleteBackupResponse) Descriptor deprecated 

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

Deprecated: Use DeleteBackupResponse.ProtoReflect.Descriptor instead.

func (*DeleteBackupResponse) ProtoMessage 

func (*DeleteBackupResponse) ProtoMessage()

func (*DeleteBackupResponse) ProtoReflect 

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

func (*DeleteBackupResponse) Reset 

func (x *DeleteBackupResponse) Reset()

func (*DeleteBackupResponse) String 

func (x *DeleteBackupResponse) String() string

type GetBackupsRequest 

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

func (*GetBackupsRequest) Descriptor deprecated 

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

Deprecated: Use GetBackupsRequest.ProtoReflect.Descriptor instead.

func (*GetBackupsRequest) ProtoMessage 

func (*GetBackupsRequest) ProtoMessage()

func (*GetBackupsRequest) ProtoReflect 

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

func (*GetBackupsRequest) Reset 

func (x *GetBackupsRequest) Reset()

func (*GetBackupsRequest) String 

func (x *GetBackupsRequest) String() string

type GetBackupsResponse 

type GetBackupsResponse struct {
	Backups []*BackupSummary `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBackupsResponse) Descriptor deprecated 

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

Deprecated: Use GetBackupsResponse.ProtoReflect.Descriptor instead.

func (*GetBackupsResponse) GetBackups 

func (x *GetBackupsResponse) GetBackups() []*BackupSummary

func (*GetBackupsResponse) ProtoMessage 

func (*GetBackupsResponse) ProtoMessage()

func (*GetBackupsResponse) ProtoReflect 

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

func (*GetBackupsResponse) Reset 

func (x *GetBackupsResponse) Reset()

func (*GetBackupsResponse) String 

func (x *GetBackupsResponse) String() string

type MedusaClient 

type MedusaClient interface {
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (*BackupResponse, error)
	BackupStatus(ctx context.Context, in *BackupStatusRequest, opts ...grpc.CallOption) (*BackupStatusResponse, error)
	DeleteBackup(ctx context.Context, in *DeleteBackupRequest, opts ...grpc.CallOption) (*DeleteBackupResponse, error)
	GetBackups(ctx context.Context, in *GetBackupsRequest, opts ...grpc.CallOption) (*GetBackupsResponse, error)
}

MedusaClient is the client API for Medusa 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 NewMedusaClient 

func NewMedusaClient(cc grpc.ClientConnInterface) MedusaClient

type MedusaServer 

type MedusaServer interface {
	Backup(context.Context, *BackupRequest) (*BackupResponse, error)
	BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)
	DeleteBackup(context.Context, *DeleteBackupRequest) (*DeleteBackupResponse, error)
	GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)
	// contains filtered or unexported methods
}

MedusaServer is the server API for Medusa service. All implementations must embed UnimplementedMedusaServer for forward compatibility

type UnimplementedMedusaServer 

type UnimplementedMedusaServer struct {
}

UnimplementedMedusaServer must be embedded to have forward compatible implementations.

func (UnimplementedMedusaServer) Backup 

func (UnimplementedMedusaServer) Backup(context.Context, *BackupRequest) (*BackupResponse, error)

func (UnimplementedMedusaServer) BackupStatus 

func (UnimplementedMedusaServer) BackupStatus(context.Context, *BackupStatusRequest) (*BackupStatusResponse, error)

func (UnimplementedMedusaServer) DeleteBackup 

func (UnimplementedMedusaServer) DeleteBackup(context.Context, *DeleteBackupRequest) (*DeleteBackupResponse, error)

func (UnimplementedMedusaServer) GetBackups 

func (UnimplementedMedusaServer) GetBackups(context.Context, *GetBackupsRequest) (*GetBackupsResponse, error)

type UnsafeMedusaServer 

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

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