file

package
v0.10.20 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthFile        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFile          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFile = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewFileEndpoints 

func NewFileEndpoints() []*apipb.Endpoint

API Endpoints for File service

func RegisterFileHandler 

func RegisterFileHandler(s server.Server, hdlr FileHandler, opts ...server.HandlerOption) error

func RegisterFileServer 

func RegisterFileServer(s *grpc.Server, srv FileServer)

Types

type CloseRequest 

type CloseRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) GetId 

func (m *CloseRequest) GetId() int64

func (*CloseRequest) Marshal 

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

func (*CloseRequest) MarshalTo 

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

func (*CloseRequest) MarshalToSizedBuffer 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) Size 

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

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal 

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

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

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

func (*CloseRequest) XXX_Merge 

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

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

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

type CloseResponse 

type CloseResponse struct {
}

func (*CloseResponse) Descriptor 

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

func (*CloseResponse) Marshal 

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

func (*CloseResponse) MarshalTo 

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

func (*CloseResponse) MarshalToSizedBuffer 

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

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset 

func (m *CloseResponse) Reset()

func (*CloseResponse) Size 

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

func (*CloseResponse) String 

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal 

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

func (*CloseResponse) XXX_DiscardUnknown 

func (m *CloseResponse) XXX_DiscardUnknown()

func (*CloseResponse) XXX_Marshal 

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

func (*CloseResponse) XXX_Merge 

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

func (*CloseResponse) XXX_Size 

func (m *CloseResponse) XXX_Size() int

func (*CloseResponse) XXX_Unmarshal 

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

type FileClient 

type FileClient interface {
	Open(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenResponse, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
}

FileClient is the client API for File service.

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

func NewFileClient 

func NewFileClient(cc *grpc.ClientConn) FileClient

type FileHandler 

type FileHandler interface {
	Open(context.Context, *OpenRequest, *OpenResponse) error
	Stat(context.Context, *StatRequest, *StatResponse) error
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Write(context.Context, *WriteRequest, *WriteResponse) error
	Close(context.Context, *CloseRequest, *CloseResponse) error
}

Server API for File service

type FileServer 

type FileServer interface {
	Open(context.Context, *OpenRequest) (*OpenResponse, error)
	Stat(context.Context, *StatRequest) (*StatResponse, error)
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
}

FileServer is the server API for File service.

type FileService 

type FileService interface {
	Open(ctx context.Context, in *OpenRequest, opts ...client.CallOption) (*OpenResponse, error)
	Stat(ctx context.Context, in *StatRequest, opts ...client.CallOption) (*StatResponse, error)
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...client.CallOption) (*CloseResponse, error)
}

Client API for File service

func NewFileService 

func NewFileService(name string, c client.Client) FileService

type GetRequest 

type GetRequest struct {
	Id      int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	BlockId int64 `protobuf:"varint,2,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetBlockId 

func (m *GetRequest) GetBlockId() int64

func (*GetRequest) GetId 

func (m *GetRequest) GetId() int64

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetResponse 

type GetResponse struct {
	BlockId int64  `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Size_   int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetBlockId 

func (m *GetResponse) GetBlockId() int64

func (*GetResponse) GetData 

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

func (*GetResponse) GetSize_ 

func (m *GetResponse) GetSize_() int64

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type OpenRequest 

type OpenRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	Truncate bool   `protobuf:"varint,2,opt,name=truncate,proto3" json:"truncate,omitempty"`
}

func (*OpenRequest) Descriptor 

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

func (*OpenRequest) GetFilename 

func (m *OpenRequest) GetFilename() string

func (*OpenRequest) GetTruncate 

func (m *OpenRequest) GetTruncate() bool

func (*OpenRequest) Marshal 

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

func (*OpenRequest) MarshalTo 

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

func (*OpenRequest) MarshalToSizedBuffer 

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

func (*OpenRequest) ProtoMessage 

func (*OpenRequest) ProtoMessage()

func (*OpenRequest) Reset 

func (m *OpenRequest) Reset()

func (*OpenRequest) Size 

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

func (*OpenRequest) String 

func (m *OpenRequest) String() string

func (*OpenRequest) Unmarshal 

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

func (*OpenRequest) XXX_DiscardUnknown 

func (m *OpenRequest) XXX_DiscardUnknown()

func (*OpenRequest) XXX_Marshal 

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

func (*OpenRequest) XXX_Merge 

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

func (*OpenRequest) XXX_Size 

func (m *OpenRequest) XXX_Size() int

func (*OpenRequest) XXX_Unmarshal 

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

type OpenResponse 

type OpenResponse struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Result bool  `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"`
}

func (*OpenResponse) Descriptor 

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

func (*OpenResponse) GetId 

func (m *OpenResponse) GetId() int64

func (*OpenResponse) GetResult 

func (m *OpenResponse) GetResult() bool

func (*OpenResponse) Marshal 

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

func (*OpenResponse) MarshalTo 

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

func (*OpenResponse) MarshalToSizedBuffer 

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

func (*OpenResponse) ProtoMessage 

func (*OpenResponse) ProtoMessage()

func (*OpenResponse) Reset 

func (m *OpenResponse) Reset()

func (*OpenResponse) Size 

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

func (*OpenResponse) String 

func (m *OpenResponse) String() string

func (*OpenResponse) Unmarshal 

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

func (*OpenResponse) XXX_DiscardUnknown 

func (m *OpenResponse) XXX_DiscardUnknown()

func (*OpenResponse) XXX_Marshal 

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

func (*OpenResponse) XXX_Merge 

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

func (*OpenResponse) XXX_Size 

func (m *OpenResponse) XXX_Size() int

func (*OpenResponse) XXX_Unmarshal 

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

type ReadRequest 

type ReadRequest struct {
	Id     int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Size_  int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
}

func (*ReadRequest) Descriptor 

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

func (*ReadRequest) GetId 

func (m *ReadRequest) GetId() int64

func (*ReadRequest) GetOffset 

func (m *ReadRequest) GetOffset() int64

func (*ReadRequest) GetSize_ 

func (m *ReadRequest) GetSize_() int64

func (*ReadRequest) Marshal 

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

func (*ReadRequest) MarshalTo 

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

func (*ReadRequest) MarshalToSizedBuffer 

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

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) Size 

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

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) Unmarshal 

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

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

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

func (*ReadRequest) XXX_Merge 

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

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

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

type ReadResponse 

type ReadResponse struct {
	Size_ int64  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Eof   bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
}

func (*ReadResponse) Descriptor 

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

func (*ReadResponse) GetData 

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

func (*ReadResponse) GetEof 

func (m *ReadResponse) GetEof() bool

func (*ReadResponse) GetSize_ 

func (m *ReadResponse) GetSize_() int64

func (*ReadResponse) Marshal 

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

func (*ReadResponse) MarshalTo 

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

func (*ReadResponse) MarshalToSizedBuffer 

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

func (*ReadResponse) ProtoMessage 

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset 

func (m *ReadResponse) Reset()

func (*ReadResponse) Size 

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

func (*ReadResponse) String 

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal 

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

func (*ReadResponse) XXX_DiscardUnknown 

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal 

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

func (*ReadResponse) XXX_Merge 

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

func (*ReadResponse) XXX_Size 

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal 

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

type StatRequest 

type StatRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
}

func (*StatRequest) Descriptor 

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

func (*StatRequest) GetFilename 

func (m *StatRequest) GetFilename() string

func (*StatRequest) Marshal 

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

func (*StatRequest) MarshalTo 

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

func (*StatRequest) MarshalToSizedBuffer 

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

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset 

func (m *StatRequest) Reset()

func (*StatRequest) Size 

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

func (*StatRequest) String 

func (m *StatRequest) String() string

func (*StatRequest) Unmarshal 

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

func (*StatRequest) XXX_DiscardUnknown 

func (m *StatRequest) XXX_DiscardUnknown()

func (*StatRequest) XXX_Marshal 

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

func (*StatRequest) XXX_Merge 

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

func (*StatRequest) XXX_Size 

func (m *StatRequest) XXX_Size() int

func (*StatRequest) XXX_Unmarshal 

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

type StatResponse 

type StatResponse struct {
	Type         string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Size_        int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	LastModified int64  `protobuf:"varint,3,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
}

func (*StatResponse) Descriptor 

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

func (*StatResponse) GetLastModified 

func (m *StatResponse) GetLastModified() int64

func (*StatResponse) GetSize_ 

func (m *StatResponse) GetSize_() int64

func (*StatResponse) GetType 

func (m *StatResponse) GetType() string

func (*StatResponse) Marshal 

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

func (*StatResponse) MarshalTo 

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

func (*StatResponse) MarshalToSizedBuffer 

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

func (*StatResponse) ProtoMessage 

func (*StatResponse) ProtoMessage()

func (*StatResponse) Reset 

func (m *StatResponse) Reset()

func (*StatResponse) Size 

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

func (*StatResponse) String 

func (m *StatResponse) String() string

func (*StatResponse) Unmarshal 

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

func (*StatResponse) XXX_DiscardUnknown 

func (m *StatResponse) XXX_DiscardUnknown()

func (*StatResponse) XXX_Marshal 

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

func (*StatResponse) XXX_Merge 

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

func (*StatResponse) XXX_Size 

func (m *StatResponse) XXX_Size() int

func (*StatResponse) XXX_Unmarshal 

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

type UnimplementedFileServer 

type UnimplementedFileServer struct {
}

UnimplementedFileServer can be embedded to have forward compatible implementations.

func (*UnimplementedFileServer) Close 

func (*UnimplementedFileServer) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

func (*UnimplementedFileServer) Open 

func (*UnimplementedFileServer) Open(ctx context.Context, req *OpenRequest) (*OpenResponse, error)

func (*UnimplementedFileServer) Read 

func (*UnimplementedFileServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)

func (*UnimplementedFileServer) Stat 

func (*UnimplementedFileServer) Stat(ctx context.Context, req *StatRequest) (*StatResponse, error)

func (*UnimplementedFileServer) Write 

func (*UnimplementedFileServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

type WriteRequest 

type WriteRequest struct {
	Id     int64  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetData 

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

func (*WriteRequest) GetId 

func (m *WriteRequest) GetId() int64

func (*WriteRequest) GetOffset 

func (m *WriteRequest) GetOffset() int64

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteResponse 

type WriteResponse struct {
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

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

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.