Documentation
¶
Index ¶
- Variables
- func DeregisterStorageEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)
- func RegisterStorageEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedStorageEndpointServer)
- func RegisterStorageEndpointServer(s grpc.ServiceRegistrar, srv StorageEndpointServer)
- type LookupRequest
- func (*LookupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupRequest) GetKey() string
- func (*LookupRequest) ProtoMessage()
- func (x *LookupRequest) ProtoReflect() protoreflect.Message
- func (x *LookupRequest) Reset()
- func (x *LookupRequest) String() string
- func (this *LookupRequest) Validate() error
- type LookupResponse
- func (*LookupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupResponse) GetValue() []byte
- func (*LookupResponse) ProtoMessage()
- func (x *LookupResponse) ProtoReflect() protoreflect.Message
- func (x *LookupResponse) Reset()
- func (x *LookupResponse) String() string
- func (this *LookupResponse) Validate() error
- type NamedStorageEndpointServer
- type ProposeRequest
- func (*ProposeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ProposeRequest) GetKey() string
- func (x *ProposeRequest) GetValue() []byte
- func (*ProposeRequest) ProtoMessage()
- func (x *ProposeRequest) ProtoReflect() protoreflect.Message
- func (x *ProposeRequest) Reset()
- func (x *ProposeRequest) String() string
- func (this *ProposeRequest) Validate() error
- type ProposeResponse
- type StorageEndpointClient
- type StorageEndpointEnhancedServer
- type StorageEndpointServer
- type UnimplementedStorageEndpointServer
- type UnsafeStorageEndpointServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_cells_storage_proto protoreflect.FileDescriptor
View Source
var StorageEndpoint_ServiceDesc = grpc.ServiceDesc{ ServiceName: "storage.StorageEndpoint", HandlerType: (*StorageEndpointServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Propose", Handler: _StorageEndpoint_Propose_Handler, }, { MethodName: "Lookup", Handler: _StorageEndpoint_Lookup_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cells-storage.proto", }
StorageEndpoint_ServiceDesc is the grpc.ServiceDesc for StorageEndpoint service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DeregisterStorageEndpointEnhancedServer ¶
func DeregisterStorageEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)
func RegisterStorageEndpointEnhancedServer ¶
func RegisterStorageEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedStorageEndpointServer)
func RegisterStorageEndpointServer ¶
func RegisterStorageEndpointServer(s grpc.ServiceRegistrar, srv StorageEndpointServer)
Types ¶
type LookupRequest ¶
type LookupRequest struct {
Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
// contains filtered or unexported fields
}
func (*LookupRequest) Descriptor
deprecated
func (*LookupRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.
func (*LookupRequest) GetKey ¶
func (x *LookupRequest) GetKey() string
func (*LookupRequest) ProtoMessage ¶
func (*LookupRequest) ProtoMessage()
func (*LookupRequest) ProtoReflect ¶
func (x *LookupRequest) ProtoReflect() protoreflect.Message
func (*LookupRequest) Reset ¶
func (x *LookupRequest) Reset()
func (*LookupRequest) String ¶
func (x *LookupRequest) String() string
func (*LookupRequest) Validate ¶
func (this *LookupRequest) Validate() error
type LookupResponse ¶
type LookupResponse struct {
Value []byte `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
// contains filtered or unexported fields
}
func (*LookupResponse) Descriptor
deprecated
func (*LookupResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupResponse.ProtoReflect.Descriptor instead.
func (*LookupResponse) GetValue ¶
func (x *LookupResponse) GetValue() []byte
func (*LookupResponse) ProtoMessage ¶
func (*LookupResponse) ProtoMessage()
func (*LookupResponse) ProtoReflect ¶
func (x *LookupResponse) ProtoReflect() protoreflect.Message
func (*LookupResponse) Reset ¶
func (x *LookupResponse) Reset()
func (*LookupResponse) String ¶
func (x *LookupResponse) String() string
func (*LookupResponse) Validate ¶
func (this *LookupResponse) Validate() error
type NamedStorageEndpointServer ¶
type NamedStorageEndpointServer interface {
StorageEndpointServer
Name() string
}
type ProposeRequest ¶
type ProposeRequest struct {
Key string `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
Value []byte `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
// contains filtered or unexported fields
}
func (*ProposeRequest) Descriptor
deprecated
func (*ProposeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProposeRequest.ProtoReflect.Descriptor instead.
func (*ProposeRequest) GetKey ¶
func (x *ProposeRequest) GetKey() string
func (*ProposeRequest) GetValue ¶
func (x *ProposeRequest) GetValue() []byte
func (*ProposeRequest) ProtoMessage ¶
func (*ProposeRequest) ProtoMessage()
func (*ProposeRequest) ProtoReflect ¶
func (x *ProposeRequest) ProtoReflect() protoreflect.Message
func (*ProposeRequest) Reset ¶
func (x *ProposeRequest) Reset()
func (*ProposeRequest) String ¶
func (x *ProposeRequest) String() string
func (*ProposeRequest) Validate ¶
func (this *ProposeRequest) Validate() error
type ProposeResponse ¶
type ProposeResponse struct {
// contains filtered or unexported fields
}
func (*ProposeResponse) Descriptor
deprecated
func (*ProposeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProposeResponse.ProtoReflect.Descriptor instead.
func (*ProposeResponse) ProtoMessage ¶
func (*ProposeResponse) ProtoMessage()
func (*ProposeResponse) ProtoReflect ¶
func (x *ProposeResponse) ProtoReflect() protoreflect.Message
func (*ProposeResponse) Reset ¶
func (x *ProposeResponse) Reset()
func (*ProposeResponse) String ¶
func (x *ProposeResponse) String() string
func (*ProposeResponse) Validate ¶
func (this *ProposeResponse) Validate() error
type StorageEndpointClient ¶
type StorageEndpointClient interface {
Propose(ctx context.Context, in *ProposeRequest, opts ...grpc.CallOption) (*ProposeResponse, error)
Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
}
StorageEndpointClient is the client API for StorageEndpoint 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 NewStorageEndpointClient ¶
func NewStorageEndpointClient(cc grpc.ClientConnInterface) StorageEndpointClient
type StorageEndpointEnhancedServer ¶
type StorageEndpointEnhancedServer map[string]NamedStorageEndpointServer
func (StorageEndpointEnhancedServer) Lookup ¶
func (m StorageEndpointEnhancedServer) Lookup(ctx context.Context, r *LookupRequest) (*LookupResponse, error)
func (StorageEndpointEnhancedServer) Propose ¶
func (m StorageEndpointEnhancedServer) Propose(ctx context.Context, r *ProposeRequest) (*ProposeResponse, error)
type StorageEndpointServer ¶
type StorageEndpointServer interface {
Propose(context.Context, *ProposeRequest) (*ProposeResponse, error)
Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
// contains filtered or unexported methods
}
StorageEndpointServer is the server API for StorageEndpoint service. All implementations must embed UnimplementedStorageEndpointServer for forward compatibility
type UnimplementedStorageEndpointServer ¶
type UnimplementedStorageEndpointServer struct {
}
UnimplementedStorageEndpointServer must be embedded to have forward compatible implementations.
func (UnimplementedStorageEndpointServer) Lookup ¶
func (UnimplementedStorageEndpointServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
func (UnimplementedStorageEndpointServer) Propose ¶
func (UnimplementedStorageEndpointServer) Propose(context.Context, *ProposeRequest) (*ProposeResponse, error)
type UnsafeStorageEndpointServer ¶
type UnsafeStorageEndpointServer interface {
// contains filtered or unexported methods
}
UnsafeStorageEndpointServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageEndpointServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.