storage

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)
  • 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)
  • 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)
  • 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
  • func (*ProposeResponse) Descriptor() ([]byte, []int)
  • func (*ProposeResponse) ProtoMessage()
  • func (x *ProposeResponse) ProtoReflect() protoreflect.Message
  • func (x *ProposeResponse) Reset()
  • func (x *ProposeResponse) String() string
  • func (this *ProposeResponse) Validate() error
• type StorageEndpointClient
  • func NewStorageEndpointClient(cc grpc.ClientConnInterface) StorageEndpointClient
• type StorageEndpointEnhancedServer
  • func (m StorageEndpointEnhancedServer) Lookup(ctx context.Context, r *LookupRequest) (*LookupResponse, error)
  • func (m StorageEndpointEnhancedServer) Propose(ctx context.Context, r *ProposeRequest) (*ProposeResponse, error)
• type StorageEndpointServer
• type UnimplementedStorageEndpointServer
  • func (UnimplementedStorageEndpointServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
  • func (UnimplementedStorageEndpointServer) Propose(context.Context, *ProposeRequest) (*ProposeResponse, error)
• type UnsafeStorageEndpointServer

Variables

var File_cells_storage_proto protoreflect.FileDescriptor

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

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

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

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

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.