cockroach: github.com/cockroachdb/cockroach/pkg/blobs/blobspb Index | Files

package blobspb

import "github.com/cockroachdb/cockroach/pkg/blobs/blobspb"

Index

Package Files

blobs.pb.go

Variables

var (
    ErrInvalidLengthBlobs = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowBlobs   = fmt.Errorf("proto: integer overflow")
)

func RegisterBlobServer Uses

func RegisterBlobServer(s *grpc.Server, srv BlobServer)

type BlobClient Uses

type BlobClient interface {
    List(ctx context.Context, in *GlobRequest, opts ...grpc.CallOption) (*GlobResponse, error)
    Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
    Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*BlobStat, error)
    GetStream(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Blob_GetStreamClient, error)
    PutStream(ctx context.Context, opts ...grpc.CallOption) (Blob_PutStreamClient, error)
}

BlobClient is the client API for Blob service.

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

func NewBlobClient Uses

func NewBlobClient(cc *grpc.ClientConn) BlobClient

type BlobServer Uses

type BlobServer interface {
    List(context.Context, *GlobRequest) (*GlobResponse, error)
    Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
    Stat(context.Context, *StatRequest) (*BlobStat, error)
    GetStream(*GetRequest, Blob_GetStreamServer) error
    PutStream(Blob_PutStreamServer) error
}

BlobServer is the server API for Blob service.

type BlobStat Uses

type BlobStat struct {
    Filesize int64 `protobuf:"varint,1,opt,name=filesize,proto3" json:"filesize,omitempty"`
}

BlobStat returns the file size of the file requested in StatRequest.

func (*BlobStat) Descriptor Uses

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

func (*BlobStat) Marshal Uses

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

func (*BlobStat) MarshalTo Uses

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

func (*BlobStat) ProtoMessage Uses

func (*BlobStat) ProtoMessage()

func (*BlobStat) Reset Uses

func (m *BlobStat) Reset()

func (*BlobStat) Size Uses

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

func (*BlobStat) String Uses

func (m *BlobStat) String() string

func (*BlobStat) Unmarshal Uses

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

func (*BlobStat) XXX_DiscardUnknown Uses

func (m *BlobStat) XXX_DiscardUnknown()

func (*BlobStat) XXX_Marshal Uses

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

func (*BlobStat) XXX_Merge Uses

func (dst *BlobStat) XXX_Merge(src proto.Message)

func (*BlobStat) XXX_Size Uses

func (m *BlobStat) XXX_Size() int

func (*BlobStat) XXX_Unmarshal Uses

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

type Blob_GetStreamClient Uses

type Blob_GetStreamClient interface {
    Recv() (*StreamChunk, error)
    grpc.ClientStream
}

type Blob_GetStreamServer Uses

type Blob_GetStreamServer interface {
    Send(*StreamChunk) error
    grpc.ServerStream
}

type Blob_PutStreamClient Uses

type Blob_PutStreamClient interface {
    Send(*StreamChunk) error
    CloseAndRecv() (*StreamResponse, error)
    grpc.ClientStream
}

type Blob_PutStreamServer Uses

type Blob_PutStreamServer interface {
    SendAndClose(*StreamResponse) error
    Recv() (*StreamChunk, error)
    grpc.ServerStream
}

type DeleteRequest Uses

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

DeleteRequest is used to delete a file or empty directory on a remote node. It's path is specified by `filename`, as described in GetRequest.

func (*DeleteRequest) Descriptor Uses

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

func (*DeleteRequest) Marshal Uses

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

func (*DeleteRequest) MarshalTo Uses

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

func (*DeleteRequest) ProtoMessage Uses

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset Uses

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size Uses

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

func (*DeleteRequest) String Uses

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal Uses

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

func (*DeleteRequest) XXX_DiscardUnknown Uses

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal Uses

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

func (*DeleteRequest) XXX_Merge Uses

func (dst *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size Uses

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal Uses

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

type DeleteResponse Uses

type DeleteResponse struct {
}

DeleteResponse is returned once a file has been successfully deleted by DeleteRequest.

func (*DeleteResponse) Descriptor Uses

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

func (*DeleteResponse) Marshal Uses

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

func (*DeleteResponse) MarshalTo Uses

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

func (*DeleteResponse) ProtoMessage Uses

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset Uses

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size Uses

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

func (*DeleteResponse) String Uses

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal Uses

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

func (*DeleteResponse) XXX_DiscardUnknown Uses

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal Uses

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

func (*DeleteResponse) XXX_Merge Uses

func (dst *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size Uses

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal Uses

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

type GetRequest Uses

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

GetRequest is used to read a file from a remote node. It's path is specified by `filename`, which can either be a relative path from the base of external IO dir, or an absolute path, which must be contained in external IO dir.

func (*GetRequest) Descriptor Uses

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

func (*GetRequest) Marshal Uses

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

func (*GetRequest) MarshalTo Uses

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

func (*GetRequest) ProtoMessage Uses

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset Uses

func (m *GetRequest) Reset()

func (*GetRequest) Size Uses

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

func (*GetRequest) String Uses

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal Uses

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

func (*GetRequest) XXX_DiscardUnknown Uses

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal Uses

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

func (*GetRequest) XXX_Merge Uses

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

func (*GetRequest) XXX_Size Uses

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal Uses

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

type GetResponse Uses

type GetResponse struct {
    Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

GetResponse returns contents of the file requested by GetRequest.

func (*GetResponse) Descriptor Uses

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

func (*GetResponse) Marshal Uses

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

func (*GetResponse) MarshalTo Uses

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

func (*GetResponse) ProtoMessage Uses

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset Uses

func (m *GetResponse) Reset()

func (*GetResponse) Size Uses

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

func (*GetResponse) String Uses

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal Uses

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

func (*GetResponse) XXX_DiscardUnknown Uses

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal Uses

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

func (*GetResponse) XXX_Merge Uses

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

func (*GetResponse) XXX_Size Uses

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal Uses

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

type GlobRequest Uses

type GlobRequest struct {
    Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
}

GlobRequest is used to list all files that match the glob pattern on a given node.

func (*GlobRequest) Descriptor Uses

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

func (*GlobRequest) Marshal Uses

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

func (*GlobRequest) MarshalTo Uses

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

func (*GlobRequest) ProtoMessage Uses

func (*GlobRequest) ProtoMessage()

func (*GlobRequest) Reset Uses

func (m *GlobRequest) Reset()

func (*GlobRequest) Size Uses

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

func (*GlobRequest) String Uses

func (m *GlobRequest) String() string

func (*GlobRequest) Unmarshal Uses

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

func (*GlobRequest) XXX_DiscardUnknown Uses

func (m *GlobRequest) XXX_DiscardUnknown()

func (*GlobRequest) XXX_Marshal Uses

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

func (*GlobRequest) XXX_Merge Uses

func (dst *GlobRequest) XXX_Merge(src proto.Message)

func (*GlobRequest) XXX_Size Uses

func (m *GlobRequest) XXX_Size() int

func (*GlobRequest) XXX_Unmarshal Uses

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

type GlobResponse Uses

type GlobResponse struct {
    Files []string `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
}

GlobResponse responds with the list of files that matched the given pattern.

func (*GlobResponse) Descriptor Uses

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

func (*GlobResponse) Marshal Uses

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

func (*GlobResponse) MarshalTo Uses

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

func (*GlobResponse) ProtoMessage Uses

func (*GlobResponse) ProtoMessage()

func (*GlobResponse) Reset Uses

func (m *GlobResponse) Reset()

func (*GlobResponse) Size Uses

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

func (*GlobResponse) String Uses

func (m *GlobResponse) String() string

func (*GlobResponse) Unmarshal Uses

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

func (*GlobResponse) XXX_DiscardUnknown Uses

func (m *GlobResponse) XXX_DiscardUnknown()

func (*GlobResponse) XXX_Marshal Uses

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

func (*GlobResponse) XXX_Merge Uses

func (dst *GlobResponse) XXX_Merge(src proto.Message)

func (*GlobResponse) XXX_Size Uses

func (m *GlobResponse) XXX_Size() int

func (*GlobResponse) XXX_Unmarshal Uses

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

type PutRequest Uses

type PutRequest struct {
    Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
    Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

PutRequest is used to write a payload to a remote node. It's path is specified by `filename`, as described in GetRequest.

func (*PutRequest) Descriptor Uses

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

func (*PutRequest) Marshal Uses

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

func (*PutRequest) MarshalTo Uses

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

func (*PutRequest) ProtoMessage Uses

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset Uses

func (m *PutRequest) Reset()

func (*PutRequest) Size Uses

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

func (*PutRequest) String Uses

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal Uses

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

func (*PutRequest) XXX_DiscardUnknown Uses

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal Uses

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

func (*PutRequest) XXX_Merge Uses

func (dst *PutRequest) XXX_Merge(src proto.Message)

func (*PutRequest) XXX_Size Uses

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal Uses

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

type PutResponse Uses

type PutResponse struct {
}

PutResponse is returned once a file has successfully been written by a PutRequest.

func (*PutResponse) Descriptor Uses

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

func (*PutResponse) Marshal Uses

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

func (*PutResponse) MarshalTo Uses

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

func (*PutResponse) ProtoMessage Uses

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset Uses

func (m *PutResponse) Reset()

func (*PutResponse) Size Uses

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

func (*PutResponse) String Uses

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal Uses

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

func (*PutResponse) XXX_DiscardUnknown Uses

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal Uses

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

func (*PutResponse) XXX_Merge Uses

func (dst *PutResponse) XXX_Merge(src proto.Message)

func (*PutResponse) XXX_Size Uses

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal Uses

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

type StatRequest Uses

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

StatRequest is used to get the file size of a file. It's path is specified by `filename`, as described in GetRequest.

func (*StatRequest) Descriptor Uses

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

func (*StatRequest) Marshal Uses

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

func (*StatRequest) MarshalTo Uses

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

func (*StatRequest) ProtoMessage Uses

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset Uses

func (m *StatRequest) Reset()

func (*StatRequest) Size Uses

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

func (*StatRequest) String Uses

func (m *StatRequest) String() string

func (*StatRequest) Unmarshal Uses

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

func (*StatRequest) XXX_DiscardUnknown Uses

func (m *StatRequest) XXX_DiscardUnknown()

func (*StatRequest) XXX_Marshal Uses

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

func (*StatRequest) XXX_Merge Uses

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

func (*StatRequest) XXX_Size Uses

func (m *StatRequest) XXX_Size() int

func (*StatRequest) XXX_Unmarshal Uses

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

type StreamChunk Uses

type StreamChunk struct {
    Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

StreamChunk contains a chunk of the payload we are streaming

func (*StreamChunk) Descriptor Uses

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

func (*StreamChunk) Marshal Uses

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

func (*StreamChunk) MarshalTo Uses

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

func (*StreamChunk) ProtoMessage Uses

func (*StreamChunk) ProtoMessage()

func (*StreamChunk) Reset Uses

func (m *StreamChunk) Reset()

func (*StreamChunk) Size Uses

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

func (*StreamChunk) String Uses

func (m *StreamChunk) String() string

func (*StreamChunk) Unmarshal Uses

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

func (*StreamChunk) XXX_DiscardUnknown Uses

func (m *StreamChunk) XXX_DiscardUnknown()

func (*StreamChunk) XXX_Marshal Uses

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

func (*StreamChunk) XXX_Merge Uses

func (dst *StreamChunk) XXX_Merge(src proto.Message)

func (*StreamChunk) XXX_Size Uses

func (m *StreamChunk) XXX_Size() int

func (*StreamChunk) XXX_Unmarshal Uses

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

type StreamResponse Uses

type StreamResponse struct {
}

StreamResponse is used to acknowledge a stream ending.

func (*StreamResponse) Descriptor Uses

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

func (*StreamResponse) Marshal Uses

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

func (*StreamResponse) MarshalTo Uses

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

func (*StreamResponse) ProtoMessage Uses

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset Uses

func (m *StreamResponse) Reset()

func (*StreamResponse) Size Uses

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

func (*StreamResponse) String Uses

func (m *StreamResponse) String() string

func (*StreamResponse) Unmarshal Uses

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

func (*StreamResponse) XXX_DiscardUnknown Uses

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal Uses

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

func (*StreamResponse) XXX_Merge Uses

func (dst *StreamResponse) XXX_Merge(src proto.Message)

func (*StreamResponse) XXX_Size Uses

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal Uses

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

Package blobspb imports 6 packages (graph) and is imported by 8 packages. Updated 2020-01-07. Refresh now. Tools for package owners.