v1

package
v0.0.0-...-e2d6795 Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BlobStore_GetBlob_FullMethodName    = "/blobstore.BlobStore/GetBlob"
	BlobStore_CreateBlob_FullMethodName = "/blobstore.BlobStore/CreateBlob"
)

Variables

View Source 
var BlobStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "blobstore.BlobStore",
	HandlerType: (*BlobStoreServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetBlob",
			Handler:       _BlobStore_GetBlob_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CreateBlob",
			Handler:       _BlobStore_CreateBlob_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "services/blobstore/api/v1/blobstore.proto",
}

BlobStore_ServiceDesc is the grpc.ServiceDesc for BlobStore 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_services_blobstore_api_v1_blobstore_proto protoreflect.FileDescriptor

Functions

func RegisterBlobStoreServer 

func RegisterBlobStoreServer(s grpc.ServiceRegistrar, srv BlobStoreServer)

Types

type BlobStoreClient 

type BlobStoreClient interface {
	GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (BlobStore_GetBlobClient, error)
	CreateBlob(ctx context.Context, opts ...grpc.CallOption) (BlobStore_CreateBlobClient, error)
}

BlobStoreClient is the client API for BlobStore 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 NewBlobStoreClient 

func NewBlobStoreClient(cc grpc.ClientConnInterface) BlobStoreClient

type BlobStoreServer 

type BlobStoreServer interface {
	GetBlob(*GetBlobRequest, BlobStore_GetBlobServer) error
	CreateBlob(BlobStore_CreateBlobServer) error
	// contains filtered or unexported methods
}

BlobStoreServer is the server API for BlobStore service. All implementations must embed UnimplementedBlobStoreServer for forward compatibility

type BlobStore_CreateBlobClient 

type BlobStore_CreateBlobClient interface {
	Send(*CreateBlobRequest) error
	CloseAndRecv() (*CreateBlobReply, error)
	grpc.ClientStream
}

type BlobStore_CreateBlobServer 

type BlobStore_CreateBlobServer interface {
	SendAndClose(*CreateBlobReply) error
	Recv() (*CreateBlobRequest, error)
	grpc.ServerStream
}

type BlobStore_GetBlobClient 

type BlobStore_GetBlobClient interface {
	Recv() (*GetBlobReply, error)
	grpc.ClientStream
}

type BlobStore_GetBlobServer 

type BlobStore_GetBlobServer interface {
	Send(*GetBlobReply) error
	grpc.ServerStream
}

type CreateBlobReply 

type CreateBlobReply struct {
	Store  string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBlobReply) Descriptor deprecated 

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

Deprecated: Use CreateBlobReply.ProtoReflect.Descriptor instead.

func (*CreateBlobReply) GetLength 

func (x *CreateBlobReply) GetLength() int64

func (*CreateBlobReply) GetSha256 

func (x *CreateBlobReply) GetSha256() []byte

func (*CreateBlobReply) GetStore 

func (x *CreateBlobReply) GetStore() string

func (*CreateBlobReply) ProtoMessage 

func (*CreateBlobReply) ProtoMessage()

func (*CreateBlobReply) ProtoReflect 

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

func (*CreateBlobReply) Reset 

func (x *CreateBlobReply) Reset()

func (*CreateBlobReply) String 

func (x *CreateBlobReply) String() string

type CreateBlobRequest 

type CreateBlobRequest struct {
	Store  string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Done   bool   `protobuf:"varint,4,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBlobRequest) Descriptor deprecated 

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

Deprecated: Use CreateBlobRequest.ProtoReflect.Descriptor instead.

func (*CreateBlobRequest) GetData 

func (x *CreateBlobRequest) GetData() []byte

func (*CreateBlobRequest) GetDone 

func (x *CreateBlobRequest) GetDone() bool

func (*CreateBlobRequest) GetSha256 

func (x *CreateBlobRequest) GetSha256() []byte

func (*CreateBlobRequest) GetStore 

func (x *CreateBlobRequest) GetStore() string

func (*CreateBlobRequest) ProtoMessage 

func (*CreateBlobRequest) ProtoMessage()

func (*CreateBlobRequest) ProtoReflect 

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

func (*CreateBlobRequest) Reset 

func (x *CreateBlobRequest) Reset()

func (*CreateBlobRequest) String 

func (x *CreateBlobRequest) String() string

type GetBlobReply 

type GetBlobReply struct {
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlobReply) Descriptor deprecated 

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

Deprecated: Use GetBlobReply.ProtoReflect.Descriptor instead.

func (*GetBlobReply) GetData 

func (x *GetBlobReply) GetData() []byte

func (*GetBlobReply) ProtoMessage 

func (*GetBlobReply) ProtoMessage()

func (*GetBlobReply) ProtoReflect 

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

func (*GetBlobReply) Reset 

func (x *GetBlobReply) Reset()

func (*GetBlobReply) String 

func (x *GetBlobReply) String() string

type GetBlobRequest 

type GetBlobRequest struct {
	Store  string `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlobRequest) Descriptor deprecated 

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

Deprecated: Use GetBlobRequest.ProtoReflect.Descriptor instead.

func (*GetBlobRequest) GetSha256 

func (x *GetBlobRequest) GetSha256() []byte

func (*GetBlobRequest) GetStore 

func (x *GetBlobRequest) GetStore() string

func (*GetBlobRequest) ProtoMessage 

func (*GetBlobRequest) ProtoMessage()

func (*GetBlobRequest) ProtoReflect 

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

func (*GetBlobRequest) Reset 

func (x *GetBlobRequest) Reset()

func (*GetBlobRequest) String 

func (x *GetBlobRequest) String() string

type UnimplementedBlobStoreServer 

type UnimplementedBlobStoreServer struct {
}

UnimplementedBlobStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedBlobStoreServer) CreateBlob 

func (UnimplementedBlobStoreServer) CreateBlob(BlobStore_CreateBlobServer) error

func (UnimplementedBlobStoreServer) GetBlob 

func (UnimplementedBlobStoreServer) GetBlob(*GetBlobRequest, BlobStore_GetBlobServer) error

type UnsafeBlobStoreServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.