store

package
v0.0.0-...-9fce2f1 Latest Latest
Warning

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

 Go to latest Published: May 2, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_store_store_proto protoreflect.FileDescriptor
View Source 
var Store_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "store.Store",
	HandlerType: (*StoreServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WriteStream",
			Handler:       _Store_WriteStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ReadStream",
			Handler:       _Store_ReadStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/store/store.proto",
}

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

Functions

func RegisterStoreServer 

func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)

Types

type Options 

type Options struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Bucket    string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Name      string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Expiry    int64  `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"`
	// contains filtered or unexported fields
}

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetBucket 

func (x *Options) GetBucket() string

func (*Options) GetExpiry 

func (x *Options) GetExpiry() int64

func (*Options) GetName 

func (x *Options) GetName() string

func (*Options) GetNamespace 

func (x *Options) GetNamespace() string

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect 

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

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type ReadStreamRequest 

type ReadStreamRequest struct {
	Uri     string   `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStreamRequest) Descriptor deprecated 

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

Deprecated: Use ReadStreamRequest.ProtoReflect.Descriptor instead.

func (*ReadStreamRequest) GetOptions 

func (x *ReadStreamRequest) GetOptions() *Options

func (*ReadStreamRequest) GetUri 

func (x *ReadStreamRequest) GetUri() string

func (*ReadStreamRequest) ProtoMessage 

func (*ReadStreamRequest) ProtoMessage()

func (*ReadStreamRequest) ProtoReflect 

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

func (*ReadStreamRequest) Reset 

func (x *ReadStreamRequest) Reset()

func (*ReadStreamRequest) String 

func (x *ReadStreamRequest) String() string

type ReadStreamResponse 

type ReadStreamResponse struct {
	Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStreamResponse) Descriptor deprecated 

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

Deprecated: Use ReadStreamResponse.ProtoReflect.Descriptor instead.

func (*ReadStreamResponse) GetChunk 

func (x *ReadStreamResponse) GetChunk() []byte

func (*ReadStreamResponse) ProtoMessage 

func (*ReadStreamResponse) ProtoMessage()

func (*ReadStreamResponse) ProtoReflect 

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

func (*ReadStreamResponse) Reset 

func (x *ReadStreamResponse) Reset()

func (*ReadStreamResponse) String 

func (x *ReadStreamResponse) String() string

type StoreClient 

type StoreClient interface {
	WriteStream(ctx context.Context, opts ...grpc.CallOption) (Store_WriteStreamClient, error)
	ReadStream(ctx context.Context, in *ReadStreamRequest, opts ...grpc.CallOption) (Store_ReadStreamClient, error)
}

StoreClient is the client API for Store 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 NewStoreClient 

func NewStoreClient(cc grpc.ClientConnInterface) StoreClient

type StoreServer 

type StoreServer interface {
	WriteStream(Store_WriteStreamServer) error
	ReadStream(*ReadStreamRequest, Store_ReadStreamServer) error
	// contains filtered or unexported methods
}

StoreServer is the server API for Store service. All implementations must embed UnimplementedStoreServer for forward compatibility

type Store_ReadStreamClient 

type Store_ReadStreamClient interface {
	Recv() (*ReadStreamResponse, error)
	grpc.ClientStream
}

type Store_ReadStreamServer 

type Store_ReadStreamServer interface {
	Send(*ReadStreamResponse) error
	grpc.ServerStream
}

type Store_WriteStreamClient 

type Store_WriteStreamClient interface {
	Send(*WriteStreamRequest) error
	CloseAndRecv() (*WriteStreamResponse, error)
	grpc.ClientStream
}

type Store_WriteStreamServer 

type Store_WriteStreamServer interface {
	SendAndClose(*WriteStreamResponse) error
	Recv() (*WriteStreamRequest, error)
	grpc.ServerStream
}

type UnimplementedStoreServer 

type UnimplementedStoreServer struct {
}

UnimplementedStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedStoreServer) ReadStream 

func (UnimplementedStoreServer) ReadStream(*ReadStreamRequest, Store_ReadStreamServer) error

func (UnimplementedStoreServer) WriteStream 

func (UnimplementedStoreServer) WriteStream(Store_WriteStreamServer) error

type UnsafeStoreServer 

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

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

type WriteStreamRequest 

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

func (*WriteStreamRequest) Descriptor deprecated 

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

Deprecated: Use WriteStreamRequest.ProtoReflect.Descriptor instead.

func (*WriteStreamRequest) ProtoMessage 

func (*WriteStreamRequest) ProtoMessage()

func (*WriteStreamRequest) ProtoReflect 

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

func (*WriteStreamRequest) Reset 

func (x *WriteStreamRequest) Reset()

func (*WriteStreamRequest) String 

func (x *WriteStreamRequest) String() string

type WriteStreamResponse 

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

func (*WriteStreamResponse) Descriptor deprecated 

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

Deprecated: Use WriteStreamResponse.ProtoReflect.Descriptor instead.

func (*WriteStreamResponse) ProtoMessage 

func (*WriteStreamResponse) ProtoMessage()

func (*WriteStreamResponse) ProtoReflect 

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

func (*WriteStreamResponse) Reset 

func (x *WriteStreamResponse) Reset()

func (*WriteStreamResponse) String 

func (x *WriteStreamResponse) 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.