proto

package

v0.0.0-...-b83a8b2 Latest Latest Go to latest Published: Apr 8, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Raobian/bgofs

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterVolumeServiceServer(s *grpc.Server, srv VolumeServiceServer)
type Chkid
type Chunk
type ChunkResponse
type UnimplementedVolumeServiceServer
- func (*UnimplementedVolumeServiceServer) Upload(srv VolumeService_UploadServer) error
type VolumeServiceClient
- func NewVolumeServiceClient(cc *grpc.ClientConn) VolumeServiceClient
type VolumeServiceServer
type VolumeService_UploadClient
type VolumeService_UploadServer

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrInvalidLengthVolume        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowVolume          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupVolume = fmt.Errorf("proto: unexpected end of group")
)

Functions ¶

func RegisterVolumeServiceServer ¶

func RegisterVolumeServiceServer(s *grpc.Server, srv VolumeServiceServer)

Types ¶

type Chkid ¶

type Chkid struct {
	Volid                uint32   `protobuf:"varint,1,opt,name=volid,proto3" json:"volid,omitempty"`
	Id                   uint32   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Chkid) Descriptor ¶

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

func (*Chkid) GetId ¶

func (m *Chkid) GetId() uint32

func (*Chkid) GetVolid ¶

func (m *Chkid) GetVolid() uint32

func (*Chkid) Marshal ¶

func (m *Chkid) Marshal() (dAtA []byte, err error)

func (*Chkid) MarshalTo ¶

func (m *Chkid) MarshalTo(dAtA []byte) (int, error)

func (*Chkid) MarshalToSizedBuffer ¶

func (m *Chkid) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chkid) ProtoMessage ¶

func (*Chkid) ProtoMessage()

func (*Chkid) Reset ¶

func (m *Chkid) Reset()

func (*Chkid) Size ¶

func (m *Chkid) Size() (n int)

func (*Chkid) String ¶

func (m *Chkid) String() string

func (*Chkid) Unmarshal ¶

func (m *Chkid) Unmarshal(dAtA []byte) error

func (*Chkid) XXX_DiscardUnknown ¶

func (m *Chkid) XXX_DiscardUnknown()

func (*Chkid) XXX_Marshal ¶

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

func (*Chkid) XXX_Merge ¶

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

func (*Chkid) XXX_Size ¶

func (m *Chkid) XXX_Size() int

func (*Chkid) XXX_Unmarshal ¶

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

type Chunk ¶

type Chunk struct {
	Chkid                *Chkid   `protobuf:"bytes,1,opt,name=Chkid,proto3" json:"Chkid,omitempty"`
	Offset               uint32   `protobuf:"varint,2,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Length               uint32   `protobuf:"varint,3,opt,name=Length,proto3" json:"Length,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Chunk) Descriptor ¶

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

func (*Chunk) GetChkid ¶

func (m *Chunk) GetChkid() *Chkid

func (*Chunk) GetData ¶

func (m *Chunk) GetData() []byte

func (*Chunk) GetLength ¶

func (m *Chunk) GetLength() uint32

func (*Chunk) GetOffset ¶

func (m *Chunk) GetOffset() uint32

func (*Chunk) Marshal ¶

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo ¶

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) MarshalToSizedBuffer ¶

func (m *Chunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage ¶

func (*Chunk) ProtoMessage()

func (*Chunk) Reset ¶

func (m *Chunk) Reset()

func (*Chunk) Size ¶

func (m *Chunk) Size() (n int)

func (*Chunk) String ¶

func (m *Chunk) String() string

func (*Chunk) Unmarshal ¶

func (m *Chunk) Unmarshal(dAtA []byte) error

func (*Chunk) XXX_DiscardUnknown ¶

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal ¶

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

func (*Chunk) XXX_Merge ¶

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

func (*Chunk) XXX_Size ¶

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal ¶

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

type ChunkResponse ¶

type ChunkResponse struct {
	Code                 int32    `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChunkResponse) Descriptor ¶

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

func (*ChunkResponse) GetCode ¶

func (m *ChunkResponse) GetCode() int32

func (*ChunkResponse) GetMsg ¶

func (m *ChunkResponse) GetMsg() string

func (*ChunkResponse) Marshal ¶

func (m *ChunkResponse) Marshal() (dAtA []byte, err error)

func (*ChunkResponse) MarshalTo ¶

func (m *ChunkResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChunkResponse) MarshalToSizedBuffer ¶

func (m *ChunkResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChunkResponse) ProtoMessage ¶

func (*ChunkResponse) ProtoMessage()

func (*ChunkResponse) Reset ¶

func (m *ChunkResponse) Reset()

func (*ChunkResponse) Size ¶

func (m *ChunkResponse) Size() (n int)

func (*ChunkResponse) String ¶

func (m *ChunkResponse) String() string

func (*ChunkResponse) Unmarshal ¶

func (m *ChunkResponse) Unmarshal(dAtA []byte) error

func (*ChunkResponse) XXX_DiscardUnknown ¶

func (m *ChunkResponse) XXX_DiscardUnknown()

func (*ChunkResponse) XXX_Marshal ¶

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

func (*ChunkResponse) XXX_Merge ¶

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

func (*ChunkResponse) XXX_Size ¶

func (m *ChunkResponse) XXX_Size() int

func (*ChunkResponse) XXX_Unmarshal ¶

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

type UnimplementedVolumeServiceServer ¶

type UnimplementedVolumeServiceServer struct {
}

UnimplementedVolumeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVolumeServiceServer) Upload ¶

func (*UnimplementedVolumeServiceServer) Upload(srv VolumeService_UploadServer) error

type VolumeServiceClient ¶

type VolumeServiceClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (VolumeService_UploadClient, error)
}

VolumeServiceClient is the client API for VolumeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVolumeServiceClient ¶

func NewVolumeServiceClient(cc *grpc.ClientConn) VolumeServiceClient

type VolumeServiceServer ¶

type VolumeServiceServer interface {
	Upload(VolumeService_UploadServer) error
}

VolumeServiceServer is the server API for VolumeService service.

type VolumeService_UploadClient ¶

type VolumeService_UploadClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*ChunkResponse, error)
	grpc.ClientStream
}

type VolumeService_UploadServer ¶

type VolumeService_UploadServer interface {
	SendAndClose(*ChunkResponse) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

Source Files ¶

View all Source files

volume.pb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL