pb

package
v0.0.0-...-fb2c0b6 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2023 License: GPL-2.0, GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ChunkServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.ChunkServer",
	HandlerType: (*ChunkServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateChunk",
			Handler:    _ChunkServer_CreateChunk_Handler,
		},
		{
			MethodName: "DeleteChunk",
			Handler:    _ChunkServer_DeleteChunk_Handler,
		},
		{
			MethodName: "ChangeToPrimary",
			Handler:    _ChunkServer_ChangeToPrimary_Handler,
		},
		{
			MethodName: "AssignNewPrimary",
			Handler:    _ChunkServer_AssignNewPrimary_Handler,
		},
		{
			MethodName: "UpdateBackup",
			Handler:    _ChunkServer_UpdateBackup_Handler,
		},
		{
			MethodName: "ReadVersion",
			Handler:    _ChunkServer_ReadVersion_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _ChunkServer_Read_Handler,
		},
		{
			MethodName: "AppendData",
			Handler:    _ChunkServer_AppendData_Handler,
		},
		{
			MethodName: "ForwardCreate",
			Handler:    _ChunkServer_ForwardCreate_Handler,
		},
		{
			MethodName: "Replicate",
			Handler:    _ChunkServer_Replicate_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _ChunkServer_GetVersion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cdfs.proto",
}

ChunkServer_ServiceDesc is the grpc.ServiceDesc for ChunkServer 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_cdfs_proto protoreflect.FileDescriptor
View Source 
var Master_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Master",
	HandlerType: (*MasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetToken",
			Handler:    _Master_GetToken_Handler,
		},
		{
			MethodName: "GetLocation",
			Handler:    _Master_GetLocation_Handler,
		},
		{
			MethodName: "AppendFile",
			Handler:    _Master_AppendFile_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Master_Delete_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Master_Create_Handler,
		},
		{
			MethodName: "HeartBeat",
			Handler:    _Master_HeartBeat_Handler,
		},
		{
			MethodName: "CSRegister",
			Handler:    _Master_CSRegister_Handler,
		},
		{
			MethodName: "AppendResult",
			Handler:    _Master_AppendResult_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cdfs.proto",
}

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

Functions

func RegisterChunkServerServer 

func RegisterChunkServerServer(s grpc.ServiceRegistrar, srv ChunkServerServer)

func RegisterMasterServer 

func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

Types

type AppendDataReq 

type AppendDataReq struct {

	// uint32 seqSeq = 1;
	// was	uint32 chunkID = 2;
	ChunkHandle string `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	FileData    []byte `protobuf:"bytes,2,opt,name=fileData,proto3" json:"fileData,omitempty"`
	Token       string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Uuid        string `protobuf:"bytes,4,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendDataReq) Descriptor deprecated 

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

Deprecated: Use AppendDataReq.ProtoReflect.Descriptor instead.

func (*AppendDataReq) GetChunkHandle 

func (x *AppendDataReq) GetChunkHandle() string

func (*AppendDataReq) GetFileData 

func (x *AppendDataReq) GetFileData() []byte

func (*AppendDataReq) GetToken 

func (x *AppendDataReq) GetToken() string

func (*AppendDataReq) GetUuid 

func (x *AppendDataReq) GetUuid() string

func (*AppendDataReq) ProtoMessage 

func (*AppendDataReq) ProtoMessage()

func (*AppendDataReq) ProtoReflect 

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

func (*AppendDataReq) Reset 

func (x *AppendDataReq) Reset()

func (*AppendDataReq) String 

func (x *AppendDataReq) String() string

type AppendDataResp 

type AppendDataResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendDataResp) Descriptor deprecated 

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

Deprecated: Use AppendDataResp.ProtoReflect.Descriptor instead.

func (*AppendDataResp) GetStatus 

func (x *AppendDataResp) GetStatus() *Status

func (*AppendDataResp) ProtoMessage 

func (*AppendDataResp) ProtoMessage()

func (*AppendDataResp) ProtoReflect 

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

func (*AppendDataResp) Reset 

func (x *AppendDataResp) Reset()

func (*AppendDataResp) String 

func (x *AppendDataResp) String() string

type AppendFileReq 

type AppendFileReq struct {
	FileName string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	FileSize uint32 `protobuf:"varint,2,opt,name=fileSize,proto3" json:"fileSize,omitempty"`
	Uuid     string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendFileReq) Descriptor deprecated 

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

Deprecated: Use AppendFileReq.ProtoReflect.Descriptor instead.

func (*AppendFileReq) GetFileName 

func (x *AppendFileReq) GetFileName() string

func (*AppendFileReq) GetFileSize 

func (x *AppendFileReq) GetFileSize() uint32

func (*AppendFileReq) GetUuid 

func (x *AppendFileReq) GetUuid() string

func (*AppendFileReq) ProtoMessage 

func (*AppendFileReq) ProtoMessage()

func (*AppendFileReq) ProtoReflect 

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

func (*AppendFileReq) Reset 

func (x *AppendFileReq) Reset()

func (*AppendFileReq) String 

func (x *AppendFileReq) String() string

type AppendFileResp 

type AppendFileResp struct {
	Status    *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	PrimaryIP []string `protobuf:"bytes,2,rep,name=primaryIP,proto3" json:"primaryIP,omitempty"`
	// repeated uint32 chunkID = 3;
	ChunkHandle []string `protobuf:"bytes,3,rep,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendFileResp) Descriptor deprecated 

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

Deprecated: Use AppendFileResp.ProtoReflect.Descriptor instead.

func (*AppendFileResp) GetChunkHandle 

func (x *AppendFileResp) GetChunkHandle() []string

func (*AppendFileResp) GetPrimaryIP 

func (x *AppendFileResp) GetPrimaryIP() []string

func (*AppendFileResp) GetStatus 

func (x *AppendFileResp) GetStatus() *Status

func (*AppendFileResp) ProtoMessage 

func (*AppendFileResp) ProtoMessage()

func (*AppendFileResp) ProtoReflect 

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

func (*AppendFileResp) Reset 

func (x *AppendFileResp) Reset()

func (*AppendFileResp) String 

func (x *AppendFileResp) String() string

type AppendResultReq 

type AppendResultReq struct {
	ChunkHandle string  `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Size        uint32  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Status      *Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendResultReq) Descriptor deprecated 

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

Deprecated: Use AppendResultReq.ProtoReflect.Descriptor instead.

func (*AppendResultReq) GetChunkHandle 

func (x *AppendResultReq) GetChunkHandle() string

func (*AppendResultReq) GetSize 

func (x *AppendResultReq) GetSize() uint32

func (*AppendResultReq) GetStatus 

func (x *AppendResultReq) GetStatus() *Status

func (*AppendResultReq) ProtoMessage 

func (*AppendResultReq) ProtoMessage()

func (*AppendResultReq) ProtoReflect 

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

func (*AppendResultReq) Reset 

func (x *AppendResultReq) Reset()

func (*AppendResultReq) String 

func (x *AppendResultReq) String() string

type AppendResultResp 

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

func (*AppendResultResp) Descriptor deprecated 

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

Deprecated: Use AppendResultResp.ProtoReflect.Descriptor instead.

func (*AppendResultResp) ProtoMessage 

func (*AppendResultResp) ProtoMessage()

func (*AppendResultResp) ProtoReflect 

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

func (*AppendResultResp) Reset 

func (x *AppendResultResp) Reset()

func (*AppendResultResp) String 

func (x *AppendResultResp) String() string

type AssignNewPrimaryReq 

type AssignNewPrimaryReq struct {
	ChunkHandle string `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Primary     string `protobuf:"bytes,2,opt,name=primary,proto3" json:"primary,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignNewPrimaryReq) Descriptor deprecated 

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

Deprecated: Use AssignNewPrimaryReq.ProtoReflect.Descriptor instead.

func (*AssignNewPrimaryReq) GetChunkHandle 

func (x *AssignNewPrimaryReq) GetChunkHandle() string

func (*AssignNewPrimaryReq) GetPrimary 

func (x *AssignNewPrimaryReq) GetPrimary() string

func (*AssignNewPrimaryReq) ProtoMessage 

func (*AssignNewPrimaryReq) ProtoMessage()

func (*AssignNewPrimaryReq) ProtoReflect 

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

func (*AssignNewPrimaryReq) Reset 

func (x *AssignNewPrimaryReq) Reset()

func (*AssignNewPrimaryReq) String 

func (x *AssignNewPrimaryReq) String() string

type AssignNewPrimaryResp 

type AssignNewPrimaryResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignNewPrimaryResp) Descriptor deprecated 

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

Deprecated: Use AssignNewPrimaryResp.ProtoReflect.Descriptor instead.

func (*AssignNewPrimaryResp) GetStatus 

func (x *AssignNewPrimaryResp) GetStatus() *Status

func (*AssignNewPrimaryResp) ProtoMessage 

func (*AssignNewPrimaryResp) ProtoMessage()

func (*AssignNewPrimaryResp) ProtoReflect 

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

func (*AssignNewPrimaryResp) Reset 

func (x *AssignNewPrimaryResp) Reset()

func (*AssignNewPrimaryResp) String 

func (x *AssignNewPrimaryResp) String() string

type CSRegisterReq 

type CSRegisterReq struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*CSRegisterReq) Descriptor deprecated 

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

Deprecated: Use CSRegisterReq.ProtoReflect.Descriptor instead.

func (*CSRegisterReq) GetHost 

func (x *CSRegisterReq) GetHost() string

func (*CSRegisterReq) GetPort 

func (x *CSRegisterReq) GetPort() uint32

func (*CSRegisterReq) ProtoMessage 

func (*CSRegisterReq) ProtoMessage()

func (*CSRegisterReq) ProtoReflect 

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

func (*CSRegisterReq) Reset 

func (x *CSRegisterReq) Reset()

func (*CSRegisterReq) String 

func (x *CSRegisterReq) String() string

type CSRegisterResp 

type CSRegisterResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CSRegisterResp) Descriptor deprecated 

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

Deprecated: Use CSRegisterResp.ProtoReflect.Descriptor instead.

func (*CSRegisterResp) GetStatus 

func (x *CSRegisterResp) GetStatus() *Status

func (*CSRegisterResp) ProtoMessage 

func (*CSRegisterResp) ProtoMessage()

func (*CSRegisterResp) ProtoReflect 

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

func (*CSRegisterResp) Reset 

func (x *CSRegisterResp) Reset()

func (*CSRegisterResp) String 

func (x *CSRegisterResp) String() string

type ChangeToPrimaryReq 

type ChangeToPrimaryReq struct {
	ChunkHandle string   `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Role        uint32   `protobuf:"varint,2,opt,name=role,proto3" json:"role,omitempty"`
	Peers       []string `protobuf:"bytes,3,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeToPrimaryReq) Descriptor deprecated 

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

Deprecated: Use ChangeToPrimaryReq.ProtoReflect.Descriptor instead.

func (*ChangeToPrimaryReq) GetChunkHandle 

func (x *ChangeToPrimaryReq) GetChunkHandle() string

func (*ChangeToPrimaryReq) GetPeers 

func (x *ChangeToPrimaryReq) GetPeers() []string

func (*ChangeToPrimaryReq) GetRole 

func (x *ChangeToPrimaryReq) GetRole() uint32

func (*ChangeToPrimaryReq) ProtoMessage 

func (*ChangeToPrimaryReq) ProtoMessage()

func (*ChangeToPrimaryReq) ProtoReflect 

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

func (*ChangeToPrimaryReq) Reset 

func (x *ChangeToPrimaryReq) Reset()

func (*ChangeToPrimaryReq) String 

func (x *ChangeToPrimaryReq) String() string

type ChangeToPrimaryResp 

type ChangeToPrimaryResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeToPrimaryResp) Descriptor deprecated 

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

Deprecated: Use ChangeToPrimaryResp.ProtoReflect.Descriptor instead.

func (*ChangeToPrimaryResp) GetStatus 

func (x *ChangeToPrimaryResp) GetStatus() *Status

func (*ChangeToPrimaryResp) ProtoMessage 

func (*ChangeToPrimaryResp) ProtoMessage()

func (*ChangeToPrimaryResp) ProtoReflect 

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

func (*ChangeToPrimaryResp) Reset 

func (x *ChangeToPrimaryResp) Reset()

func (*ChangeToPrimaryResp) String 

func (x *ChangeToPrimaryResp) String() string

type ChunkServerClient 

type ChunkServerClient interface {
	// Master -> ChunkServer
	CreateChunk(ctx context.Context, in *CreateChunkReq, opts ...grpc.CallOption) (*CreateChunkResp, error)
	DeleteChunk(ctx context.Context, in *DeleteChunkReq, opts ...grpc.CallOption) (*DeleteChunkResp, error)
	// Use Read Version to check who is new primary
	ChangeToPrimary(ctx context.Context, in *ChangeToPrimaryReq, opts ...grpc.CallOption) (*ChangeToPrimaryResp, error)
	AssignNewPrimary(ctx context.Context, in *AssignNewPrimaryReq, opts ...grpc.CallOption) (*AssignNewPrimaryResp, error)
	UpdateBackup(ctx context.Context, in *UpdateBackupReq, opts ...grpc.CallOption) (*UpdateBackupResp, error)
	// Client -> ChunkServer
	ReadVersion(ctx context.Context, in *ReadVersionReq, opts ...grpc.CallOption) (*ReadVersionResp, error)
	Read(ctx context.Context, in *ReadReq, opts ...grpc.CallOption) (*ReadResp, error)
	AppendData(ctx context.Context, in *AppendDataReq, opts ...grpc.CallOption) (*AppendDataResp, error)
	// ChunkServer -> ChunkServer
	ForwardCreate(ctx context.Context, in *ForwardCreateReq, opts ...grpc.CallOption) (*ForwardCreateResp, error)
	Replicate(ctx context.Context, in *ReplicateReq, opts ...grpc.CallOption) (*ReplicateResp, error)
	GetVersion(ctx context.Context, in *GetVersionReq, opts ...grpc.CallOption) (*GetVersionResp, error)
}

ChunkServerClient is the client API for ChunkServer 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 NewChunkServerClient 

func NewChunkServerClient(cc grpc.ClientConnInterface) ChunkServerClient

type ChunkServerInfo 

type ChunkServerInfo struct {
	ChunkHandle    string   `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	PrimaryAddress string   `protobuf:"bytes,2,opt,name=primaryAddress,proto3" json:"primaryAddress,omitempty"`
	BackupAddress  []string `protobuf:"bytes,3,rep,name=backupAddress,proto3" json:"backupAddress,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkServerInfo) Descriptor deprecated 

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

Deprecated: Use ChunkServerInfo.ProtoReflect.Descriptor instead.

func (*ChunkServerInfo) GetBackupAddress 

func (x *ChunkServerInfo) GetBackupAddress() []string

func (*ChunkServerInfo) GetChunkHandle 

func (x *ChunkServerInfo) GetChunkHandle() string

func (*ChunkServerInfo) GetPrimaryAddress 

func (x *ChunkServerInfo) GetPrimaryAddress() string

func (*ChunkServerInfo) ProtoMessage 

func (*ChunkServerInfo) ProtoMessage()

func (*ChunkServerInfo) ProtoReflect 

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

func (*ChunkServerInfo) Reset 

func (x *ChunkServerInfo) Reset()

func (*ChunkServerInfo) String 

func (x *ChunkServerInfo) String() string

type ChunkServerServer 

type ChunkServerServer interface {
	// Master -> ChunkServer
	CreateChunk(context.Context, *CreateChunkReq) (*CreateChunkResp, error)
	DeleteChunk(context.Context, *DeleteChunkReq) (*DeleteChunkResp, error)
	// Use Read Version to check who is new primary
	ChangeToPrimary(context.Context, *ChangeToPrimaryReq) (*ChangeToPrimaryResp, error)
	AssignNewPrimary(context.Context, *AssignNewPrimaryReq) (*AssignNewPrimaryResp, error)
	UpdateBackup(context.Context, *UpdateBackupReq) (*UpdateBackupResp, error)
	// Client -> ChunkServer
	ReadVersion(context.Context, *ReadVersionReq) (*ReadVersionResp, error)
	Read(context.Context, *ReadReq) (*ReadResp, error)
	AppendData(context.Context, *AppendDataReq) (*AppendDataResp, error)
	// ChunkServer -> ChunkServer
	ForwardCreate(context.Context, *ForwardCreateReq) (*ForwardCreateResp, error)
	Replicate(context.Context, *ReplicateReq) (*ReplicateResp, error)
	GetVersion(context.Context, *GetVersionReq) (*GetVersionResp, error)
	// contains filtered or unexported methods
}

ChunkServerServer is the server API for ChunkServer service. All implementations must embed UnimplementedChunkServerServer for forward compatibility

type CreateChunkReq 

type CreateChunkReq struct {
	ChunkHandle string   `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Role        uint32   `protobuf:"varint,2,opt,name=role,proto3" json:"role,omitempty"`
	Primary     string   `protobuf:"bytes,3,opt,name=primary,proto3" json:"primary,omitempty"`
	Peers       []string `protobuf:"bytes,4,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateChunkReq) Descriptor deprecated 

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

Deprecated: Use CreateChunkReq.ProtoReflect.Descriptor instead.

func (*CreateChunkReq) GetChunkHandle 

func (x *CreateChunkReq) GetChunkHandle() string

func (*CreateChunkReq) GetPeers 

func (x *CreateChunkReq) GetPeers() []string

func (*CreateChunkReq) GetPrimary 

func (x *CreateChunkReq) GetPrimary() string

func (*CreateChunkReq) GetRole 

func (x *CreateChunkReq) GetRole() uint32

func (*CreateChunkReq) ProtoMessage 

func (*CreateChunkReq) ProtoMessage()

func (*CreateChunkReq) ProtoReflect 

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

func (*CreateChunkReq) Reset 

func (x *CreateChunkReq) Reset()

func (*CreateChunkReq) String 

func (x *CreateChunkReq) String() string

type CreateChunkResp 

type CreateChunkResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateChunkResp) Descriptor deprecated 

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

Deprecated: Use CreateChunkResp.ProtoReflect.Descriptor instead.

func (*CreateChunkResp) GetStatus 

func (x *CreateChunkResp) GetStatus() *Status

func (*CreateChunkResp) ProtoMessage 

func (*CreateChunkResp) ProtoMessage()

func (*CreateChunkResp) ProtoReflect 

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

func (*CreateChunkResp) Reset 

func (x *CreateChunkResp) Reset()

func (*CreateChunkResp) String 

func (x *CreateChunkResp) String() string

type CreateReq 

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

func (*CreateReq) Descriptor deprecated 

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

Deprecated: Use CreateReq.ProtoReflect.Descriptor instead.

func (*CreateReq) GetFileName 

func (x *CreateReq) GetFileName() string

func (*CreateReq) ProtoMessage 

func (*CreateReq) ProtoMessage()

func (*CreateReq) ProtoReflect 

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

func (*CreateReq) Reset 

func (x *CreateReq) Reset()

func (*CreateReq) String 

func (x *CreateReq) String() string

type CreateResp 

type CreateResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResp) Descriptor deprecated 

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

Deprecated: Use CreateResp.ProtoReflect.Descriptor instead.

func (*CreateResp) GetStatus 

func (x *CreateResp) GetStatus() *Status

func (*CreateResp) ProtoMessage 

func (*CreateResp) ProtoMessage()

func (*CreateResp) ProtoReflect 

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

func (*CreateResp) Reset 

func (x *CreateResp) Reset()

func (*CreateResp) String 

func (x *CreateResp) String() string

type DeleteChunkReq 

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

func (*DeleteChunkReq) Descriptor deprecated 

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

Deprecated: Use DeleteChunkReq.ProtoReflect.Descriptor instead.

func (*DeleteChunkReq) GetChunkHandle 

func (x *DeleteChunkReq) GetChunkHandle() string

func (*DeleteChunkReq) ProtoMessage 

func (*DeleteChunkReq) ProtoMessage()

func (*DeleteChunkReq) ProtoReflect 

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

func (*DeleteChunkReq) Reset 

func (x *DeleteChunkReq) Reset()

func (*DeleteChunkReq) String 

func (x *DeleteChunkReq) String() string

type DeleteChunkResp 

type DeleteChunkResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteChunkResp) Descriptor deprecated 

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

Deprecated: Use DeleteChunkResp.ProtoReflect.Descriptor instead.

func (*DeleteChunkResp) GetStatus 

func (x *DeleteChunkResp) GetStatus() *Status

func (*DeleteChunkResp) ProtoMessage 

func (*DeleteChunkResp) ProtoMessage()

func (*DeleteChunkResp) ProtoReflect 

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

func (*DeleteChunkResp) Reset 

func (x *DeleteChunkResp) Reset()

func (*DeleteChunkResp) String 

func (x *DeleteChunkResp) String() string

type DeleteReq 

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

func (*DeleteReq) Descriptor deprecated 

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

Deprecated: Use DeleteReq.ProtoReflect.Descriptor instead.

func (*DeleteReq) GetFileName 

func (x *DeleteReq) GetFileName() string

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) ProtoReflect 

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

func (*DeleteReq) Reset 

func (x *DeleteReq) Reset()

func (*DeleteReq) String 

func (x *DeleteReq) String() string

type DeleteStatus 

type DeleteStatus struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStatus) Descriptor deprecated 

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

Deprecated: Use DeleteStatus.ProtoReflect.Descriptor instead.

func (*DeleteStatus) GetStatus 

func (x *DeleteStatus) GetStatus() *Status

func (*DeleteStatus) ProtoMessage 

func (*DeleteStatus) ProtoMessage()

func (*DeleteStatus) ProtoReflect 

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

func (*DeleteStatus) Reset 

func (x *DeleteStatus) Reset()

func (*DeleteStatus) String 

func (x *DeleteStatus) String() string

type ForwardCreateReq 

type ForwardCreateReq struct {
	ChunkHandle string `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Primary     string `protobuf:"bytes,2,opt,name=primary,proto3" json:"primary,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardCreateReq) Descriptor deprecated 

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

Deprecated: Use ForwardCreateReq.ProtoReflect.Descriptor instead.

func (*ForwardCreateReq) GetChunkHandle 

func (x *ForwardCreateReq) GetChunkHandle() string

func (*ForwardCreateReq) GetPrimary 

func (x *ForwardCreateReq) GetPrimary() string

func (*ForwardCreateReq) ProtoMessage 

func (*ForwardCreateReq) ProtoMessage()

func (*ForwardCreateReq) ProtoReflect 

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

func (*ForwardCreateReq) Reset 

func (x *ForwardCreateReq) Reset()

func (*ForwardCreateReq) String 

func (x *ForwardCreateReq) String() string

type ForwardCreateResp 

type ForwardCreateResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardCreateResp) Descriptor deprecated 

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

Deprecated: Use ForwardCreateResp.ProtoReflect.Descriptor instead.

func (*ForwardCreateResp) GetStatus 

func (x *ForwardCreateResp) GetStatus() *Status

func (*ForwardCreateResp) ProtoMessage 

func (*ForwardCreateResp) ProtoMessage()

func (*ForwardCreateResp) ProtoReflect 

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

func (*ForwardCreateResp) Reset 

func (x *ForwardCreateResp) Reset()

func (*ForwardCreateResp) String 

func (x *ForwardCreateResp) String() string

type GetLocationReq 

type GetLocationReq struct {
	FileName string `protobuf:"bytes,1,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Offset   uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Size     uint32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

TODO: which of these msgs need a token?

func (*GetLocationReq) Descriptor deprecated 

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

Deprecated: Use GetLocationReq.ProtoReflect.Descriptor instead.

func (*GetLocationReq) GetFileName 

func (x *GetLocationReq) GetFileName() string

func (*GetLocationReq) GetOffset 

func (x *GetLocationReq) GetOffset() uint32

func (*GetLocationReq) GetSize 

func (x *GetLocationReq) GetSize() uint32

func (*GetLocationReq) ProtoMessage 

func (*GetLocationReq) ProtoMessage()

func (*GetLocationReq) ProtoReflect 

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

func (*GetLocationReq) Reset 

func (x *GetLocationReq) Reset()

func (*GetLocationReq) String 

func (x *GetLocationReq) String() string

type GetLocationResp 

type GetLocationResp struct {
	Status    *Status            `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ChunkInfo []*ChunkServerInfo `protobuf:"bytes,2,rep,name=chunkInfo,proto3" json:"chunkInfo,omitempty"`
	// offset only for first
	// start for the first chunk
	Start uint32 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	// end for the last chunk
	End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLocationResp) Descriptor deprecated 

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

Deprecated: Use GetLocationResp.ProtoReflect.Descriptor instead.

func (*GetLocationResp) GetChunkInfo 

func (x *GetLocationResp) GetChunkInfo() []*ChunkServerInfo

func (*GetLocationResp) GetEnd 

func (x *GetLocationResp) GetEnd() uint32

func (*GetLocationResp) GetStart 

func (x *GetLocationResp) GetStart() uint32

func (*GetLocationResp) GetStatus 

func (x *GetLocationResp) GetStatus() *Status

func (*GetLocationResp) ProtoMessage 

func (*GetLocationResp) ProtoMessage()

func (*GetLocationResp) ProtoReflect 

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

func (*GetLocationResp) Reset 

func (x *GetLocationResp) Reset()

func (*GetLocationResp) String 

func (x *GetLocationResp) String() string

type GetTokenReq 

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

func (*GetTokenReq) Descriptor deprecated 

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

Deprecated: Use GetTokenReq.ProtoReflect.Descriptor instead.

func (*GetTokenReq) ProtoMessage 

func (*GetTokenReq) ProtoMessage()

func (*GetTokenReq) ProtoReflect 

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

func (*GetTokenReq) Reset 

func (x *GetTokenReq) Reset()

func (*GetTokenReq) String 

func (x *GetTokenReq) String() string

type GetTokenResp 

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

func (*GetTokenResp) Descriptor deprecated 

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

Deprecated: Use GetTokenResp.ProtoReflect.Descriptor instead.

func (*GetTokenResp) GetUniqueToken 

func (x *GetTokenResp) GetUniqueToken() string

func (*GetTokenResp) ProtoMessage 

func (*GetTokenResp) ProtoMessage()

func (*GetTokenResp) ProtoReflect 

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

func (*GetTokenResp) Reset 

func (x *GetTokenResp) Reset()

func (*GetTokenResp) String 

func (x *GetTokenResp) String() string

type GetVersionReq 

type GetVersionReq struct {
	ChunkHandle string `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Version     uint32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersionReq) Descriptor deprecated 

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

Deprecated: Use GetVersionReq.ProtoReflect.Descriptor instead.

func (*GetVersionReq) GetChunkHandle 

func (x *GetVersionReq) GetChunkHandle() string

func (*GetVersionReq) GetVersion 

func (x *GetVersionReq) GetVersion() uint32

func (*GetVersionReq) ProtoMessage 

func (*GetVersionReq) ProtoMessage()

func (*GetVersionReq) ProtoReflect 

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

func (*GetVersionReq) Reset 

func (x *GetVersionReq) Reset()

func (*GetVersionReq) String 

func (x *GetVersionReq) String() string

type GetVersionResp 

type GetVersionResp struct {
	Status    *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Version   *uint32 `protobuf:"varint,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
	ChunkData []byte  `protobuf:"bytes,3,opt,name=chunkData,proto3,oneof" json:"chunkData,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersionResp) Descriptor deprecated 

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

Deprecated: Use GetVersionResp.ProtoReflect.Descriptor instead.

func (*GetVersionResp) GetChunkData 

func (x *GetVersionResp) GetChunkData() []byte

func (*GetVersionResp) GetStatus 

func (x *GetVersionResp) GetStatus() *Status

func (*GetVersionResp) GetVersion 

func (x *GetVersionResp) GetVersion() uint32

func (*GetVersionResp) ProtoMessage 

func (*GetVersionResp) ProtoMessage()

func (*GetVersionResp) ProtoReflect 

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

func (*GetVersionResp) Reset 

func (x *GetVersionResp) Reset()

func (*GetVersionResp) String 

func (x *GetVersionResp) String() string

type HeartBeatPayload 

type HeartBeatPayload struct {

	// repeated uint32 chunkID = 1;
	ChunkHandle []string `protobuf:"bytes,1,rep,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Used        []uint32 `protobuf:"varint,2,rep,packed,name=used,proto3" json:"used,omitempty"`
	Name        string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeatPayload) Descriptor deprecated 

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

Deprecated: Use HeartBeatPayload.ProtoReflect.Descriptor instead.

func (*HeartBeatPayload) GetChunkHandle 

func (x *HeartBeatPayload) GetChunkHandle() []string

func (*HeartBeatPayload) GetName 

func (x *HeartBeatPayload) GetName() string

func (*HeartBeatPayload) GetUsed 

func (x *HeartBeatPayload) GetUsed() []uint32

func (*HeartBeatPayload) ProtoMessage 

func (*HeartBeatPayload) ProtoMessage()

func (*HeartBeatPayload) ProtoReflect 

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

func (*HeartBeatPayload) Reset 

func (x *HeartBeatPayload) Reset()

func (*HeartBeatPayload) String 

func (x *HeartBeatPayload) String() string

type HeartBeatResp 

type HeartBeatResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeatResp) Descriptor deprecated 

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

Deprecated: Use HeartBeatResp.ProtoReflect.Descriptor instead.

func (*HeartBeatResp) GetStatus 

func (x *HeartBeatResp) GetStatus() *Status

func (*HeartBeatResp) ProtoMessage 

func (*HeartBeatResp) ProtoMessage()

func (*HeartBeatResp) ProtoReflect 

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

func (*HeartBeatResp) Reset 

func (x *HeartBeatResp) Reset()

func (*HeartBeatResp) String 

func (x *HeartBeatResp) String() string

type MasterClient 

type MasterClient interface {
	// Client <-> Master
	// First message client send to master
	GetToken(ctx context.Context, in *GetTokenReq, opts ...grpc.CallOption) (*GetTokenResp, error)
	GetLocation(ctx context.Context, in *GetLocationReq, opts ...grpc.CallOption) (*GetLocationResp, error)
	// rpc Write(fileName, chunkIndex) returns (WriteResp) {}
	AppendFile(ctx context.Context, in *AppendFileReq, opts ...grpc.CallOption) (*AppendFileResp, error)
	Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteStatus, error)
	Create(ctx context.Context, in *CreateReq, opts ...grpc.CallOption) (*CreateResp, error)
	// chunk server <-> Master
	HeartBeat(ctx context.Context, in *HeartBeatPayload, opts ...grpc.CallOption) (*HeartBeatResp, error)
	CSRegister(ctx context.Context, in *CSRegisterReq, opts ...grpc.CallOption) (*CSRegisterResp, error)
	AppendResult(ctx context.Context, in *AppendResultReq, opts ...grpc.CallOption) (*AppendResultResp, error)
}

MasterClient is the client API for Master 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 NewMasterClient 

func NewMasterClient(cc grpc.ClientConnInterface) MasterClient

type MasterServer 

type MasterServer interface {
	// Client <-> Master
	// First message client send to master
	GetToken(context.Context, *GetTokenReq) (*GetTokenResp, error)
	GetLocation(context.Context, *GetLocationReq) (*GetLocationResp, error)
	// rpc Write(fileName, chunkIndex) returns (WriteResp) {}
	AppendFile(context.Context, *AppendFileReq) (*AppendFileResp, error)
	Delete(context.Context, *DeleteReq) (*DeleteStatus, error)
	Create(context.Context, *CreateReq) (*CreateResp, error)
	// chunk server <-> Master
	HeartBeat(context.Context, *HeartBeatPayload) (*HeartBeatResp, error)
	CSRegister(context.Context, *CSRegisterReq) (*CSRegisterResp, error)
	AppendResult(context.Context, *AppendResultReq) (*AppendResultResp, error)
	// contains filtered or unexported methods
}

MasterServer is the server API for Master service. All implementations must embed UnimplementedMasterServer for forward compatibility

type ReadReq 

type ReadReq struct {

	// uint32 seqNum = 1;
	// was uint32 chunkID = 2;
	ChunkHandle string `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Token       string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Start       uint32 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	// if end == 0, read the whole chunk
	End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadReq) Descriptor deprecated 

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

Deprecated: Use ReadReq.ProtoReflect.Descriptor instead.

func (*ReadReq) GetChunkHandle 

func (x *ReadReq) GetChunkHandle() string

func (*ReadReq) GetEnd 

func (x *ReadReq) GetEnd() uint32

func (*ReadReq) GetStart 

func (x *ReadReq) GetStart() uint32

func (*ReadReq) GetToken 

func (x *ReadReq) GetToken() string

func (*ReadReq) ProtoMessage 

func (*ReadReq) ProtoMessage()

func (*ReadReq) ProtoReflect 

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

func (*ReadReq) Reset 

func (x *ReadReq) Reset()

func (*ReadReq) String 

func (x *ReadReq) String() string

type ReadResp 

type ReadResp struct {

	// uint32 seqNum = 1;
	FileData []byte  `protobuf:"bytes,1,opt,name=fileData,proto3" json:"fileData,omitempty"`
	Status   *Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Version  *uint32 `protobuf:"varint,3,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResp) Descriptor deprecated 

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

Deprecated: Use ReadResp.ProtoReflect.Descriptor instead.

func (*ReadResp) GetFileData 

func (x *ReadResp) GetFileData() []byte

func (*ReadResp) GetStatus 

func (x *ReadResp) GetStatus() *Status

func (*ReadResp) GetVersion 

func (x *ReadResp) GetVersion() uint32

func (*ReadResp) ProtoMessage 

func (*ReadResp) ProtoMessage()

func (*ReadResp) ProtoReflect 

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

func (*ReadResp) Reset 

func (x *ReadResp) Reset()

func (*ReadResp) String 

func (x *ReadResp) String() string

type ReadVersionReq 

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

func (*ReadVersionReq) Descriptor deprecated 

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

Deprecated: Use ReadVersionReq.ProtoReflect.Descriptor instead.

func (*ReadVersionReq) GetChunkHandle 

func (x *ReadVersionReq) GetChunkHandle() string

func (*ReadVersionReq) ProtoMessage 

func (*ReadVersionReq) ProtoMessage()

func (*ReadVersionReq) ProtoReflect 

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

func (*ReadVersionReq) Reset 

func (x *ReadVersionReq) Reset()

func (*ReadVersionReq) String 

func (x *ReadVersionReq) String() string

type ReadVersionResp 

type ReadVersionResp struct {
	Status  *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Version *uint32 `protobuf:"varint,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVersionResp) Descriptor deprecated 

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

Deprecated: Use ReadVersionResp.ProtoReflect.Descriptor instead.

func (*ReadVersionResp) GetStatus 

func (x *ReadVersionResp) GetStatus() *Status

func (*ReadVersionResp) GetVersion 

func (x *ReadVersionResp) GetVersion() uint32

func (*ReadVersionResp) ProtoMessage 

func (*ReadVersionResp) ProtoMessage()

func (*ReadVersionResp) ProtoReflect 

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

func (*ReadVersionResp) Reset 

func (x *ReadVersionResp) Reset()

func (*ReadVersionResp) String 

func (x *ReadVersionResp) String() string

type ReplicateReq 

type ReplicateReq struct {

	// uint32 seqNum = 1;
	// was clientIP
	ClientToken string `protobuf:"bytes,1,opt,name=clientToken,proto3" json:"clientToken,omitempty"`
	// was uint32 chunkID = 3;
	ChunkHandle string `protobuf:"bytes,2,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	FileData    []byte `protobuf:"bytes,3,opt,name=fileData,proto3" json:"fileData,omitempty"`
	ReqID       string `protobuf:"bytes,4,opt,name=reqID,proto3" json:"reqID,omitempty"`
	Version     uint32 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicateReq) Descriptor deprecated 

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

Deprecated: Use ReplicateReq.ProtoReflect.Descriptor instead.

func (*ReplicateReq) GetChunkHandle 

func (x *ReplicateReq) GetChunkHandle() string

func (*ReplicateReq) GetClientToken 

func (x *ReplicateReq) GetClientToken() string

func (*ReplicateReq) GetFileData 

func (x *ReplicateReq) GetFileData() []byte

func (*ReplicateReq) GetReqID 

func (x *ReplicateReq) GetReqID() string

func (*ReplicateReq) GetVersion 

func (x *ReplicateReq) GetVersion() uint32

func (*ReplicateReq) ProtoMessage 

func (*ReplicateReq) ProtoMessage()

func (*ReplicateReq) ProtoReflect 

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

func (*ReplicateReq) Reset 

func (x *ReplicateReq) Reset()

func (*ReplicateReq) String 

func (x *ReplicateReq) String() string

type ReplicateResp 

type ReplicateResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Uuid   string  `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicateResp) Descriptor deprecated 

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

Deprecated: Use ReplicateResp.ProtoReflect.Descriptor instead.

func (*ReplicateResp) GetStatus 

func (x *ReplicateResp) GetStatus() *Status

func (*ReplicateResp) GetUuid 

func (x *ReplicateResp) GetUuid() string

func (*ReplicateResp) ProtoMessage 

func (*ReplicateResp) ProtoMessage()

func (*ReplicateResp) ProtoReflect 

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

func (*ReplicateResp) Reset 

func (x *ReplicateResp) Reset()

func (*ReplicateResp) String 

func (x *ReplicateResp) String() string

type Status 

type Status struct {
	StatusCode   int32  `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetErrorMessage 

func (x *Status) GetErrorMessage() string

func (*Status) GetStatusCode 

func (x *Status) GetStatusCode() int32

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedChunkServerServer 

type UnimplementedChunkServerServer struct {
}

UnimplementedChunkServerServer must be embedded to have forward compatible implementations.

func (UnimplementedChunkServerServer) AppendData 

func (UnimplementedChunkServerServer) AppendData(context.Context, *AppendDataReq) (*AppendDataResp, error)

func (UnimplementedChunkServerServer) AssignNewPrimary 

func (UnimplementedChunkServerServer) AssignNewPrimary(context.Context, *AssignNewPrimaryReq) (*AssignNewPrimaryResp, error)

func (UnimplementedChunkServerServer) ChangeToPrimary 

func (UnimplementedChunkServerServer) ChangeToPrimary(context.Context, *ChangeToPrimaryReq) (*ChangeToPrimaryResp, error)

func (UnimplementedChunkServerServer) CreateChunk 

func (UnimplementedChunkServerServer) CreateChunk(context.Context, *CreateChunkReq) (*CreateChunkResp, error)

func (UnimplementedChunkServerServer) DeleteChunk 

func (UnimplementedChunkServerServer) DeleteChunk(context.Context, *DeleteChunkReq) (*DeleteChunkResp, error)

func (UnimplementedChunkServerServer) ForwardCreate 

func (UnimplementedChunkServerServer) ForwardCreate(context.Context, *ForwardCreateReq) (*ForwardCreateResp, error)

func (UnimplementedChunkServerServer) GetVersion 

func (UnimplementedChunkServerServer) GetVersion(context.Context, *GetVersionReq) (*GetVersionResp, error)

func (UnimplementedChunkServerServer) Read 

func (UnimplementedChunkServerServer) Read(context.Context, *ReadReq) (*ReadResp, error)

func (UnimplementedChunkServerServer) ReadVersion 

func (UnimplementedChunkServerServer) ReadVersion(context.Context, *ReadVersionReq) (*ReadVersionResp, error)

func (UnimplementedChunkServerServer) Replicate 

func (UnimplementedChunkServerServer) Replicate(context.Context, *ReplicateReq) (*ReplicateResp, error)

func (UnimplementedChunkServerServer) UpdateBackup 

func (UnimplementedChunkServerServer) UpdateBackup(context.Context, *UpdateBackupReq) (*UpdateBackupResp, error)

type UnimplementedMasterServer 

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer must be embedded to have forward compatible implementations.

func (UnimplementedMasterServer) AppendFile 

func (UnimplementedMasterServer) AppendFile(context.Context, *AppendFileReq) (*AppendFileResp, error)

func (UnimplementedMasterServer) AppendResult 

func (UnimplementedMasterServer) AppendResult(context.Context, *AppendResultReq) (*AppendResultResp, error)

func (UnimplementedMasterServer) CSRegister 

func (UnimplementedMasterServer) CSRegister(context.Context, *CSRegisterReq) (*CSRegisterResp, error)

func (UnimplementedMasterServer) Create 

func (UnimplementedMasterServer) Create(context.Context, *CreateReq) (*CreateResp, error)

func (UnimplementedMasterServer) Delete 

func (UnimplementedMasterServer) Delete(context.Context, *DeleteReq) (*DeleteStatus, error)

func (UnimplementedMasterServer) GetLocation 

func (UnimplementedMasterServer) GetLocation(context.Context, *GetLocationReq) (*GetLocationResp, error)

func (UnimplementedMasterServer) GetToken 

func (UnimplementedMasterServer) GetToken(context.Context, *GetTokenReq) (*GetTokenResp, error)

func (UnimplementedMasterServer) HeartBeat 

func (UnimplementedMasterServer) HeartBeat(context.Context, *HeartBeatPayload) (*HeartBeatResp, error)

type UnsafeChunkServerServer 

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

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

type UnsafeMasterServer 

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

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

type UpdateBackupReq 

type UpdateBackupReq struct {
	ChunkHandle string   `protobuf:"bytes,1,opt,name=chunkHandle,proto3" json:"chunkHandle,omitempty"`
	Peers       []string `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBackupReq) Descriptor deprecated 

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

Deprecated: Use UpdateBackupReq.ProtoReflect.Descriptor instead.

func (*UpdateBackupReq) GetChunkHandle 

func (x *UpdateBackupReq) GetChunkHandle() string

func (*UpdateBackupReq) GetPeers 

func (x *UpdateBackupReq) GetPeers() []string

func (*UpdateBackupReq) ProtoMessage 

func (*UpdateBackupReq) ProtoMessage()

func (*UpdateBackupReq) ProtoReflect 

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

func (*UpdateBackupReq) Reset 

func (x *UpdateBackupReq) Reset()

func (*UpdateBackupReq) String 

func (x *UpdateBackupReq) String() string

type UpdateBackupResp 

type UpdateBackupResp struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBackupResp) Descriptor deprecated 

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

Deprecated: Use UpdateBackupResp.ProtoReflect.Descriptor instead.

func (*UpdateBackupResp) GetStatus 

func (x *UpdateBackupResp) GetStatus() *Status

func (*UpdateBackupResp) ProtoMessage 

func (*UpdateBackupResp) ProtoMessage()

func (*UpdateBackupResp) ProtoReflect 

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

func (*UpdateBackupResp) Reset 

func (x *UpdateBackupResp) Reset()

func (*UpdateBackupResp) String 

func (x *UpdateBackupResp) String() string

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.