Documentation ¶
Index ¶
- func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)
- type Client
- type Partition
- type PartitionID
- type PrimitiveServer
- func (s *PrimitiveServer) Close(ctx context.Context, request *primitiveapi.CloseRequest) (*primitiveapi.CloseResponse, error)
- func (s *PrimitiveServer) Create(ctx context.Context, request *primitiveapi.CreateRequest) (*primitiveapi.CreateResponse, error)
- func (s *PrimitiveServer) Delete(ctx context.Context, request *primitiveapi.DeleteRequest) (*primitiveapi.DeleteResponse, error)
- type Protocol
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
Client is a client for communicating with the storage layer
func (*Client) AddResponseHeaders ¶
func (c *Client) AddResponseHeaders(headers *primitive.ResponseHeaders)
func (*Client) Partition ¶
func (c *Client) Partition(partitionID PartitionID) *Partition
func (*Client) PartitionBy ¶
func (*Client) Partitions ¶
type Partition ¶
type Partition struct { cluster.Partition ID PartitionID // contains filtered or unexported fields }
Partition is a proxy partition
func NewPartition ¶
NewPartition creates a new proxy partition
func (*Partition) AddRequestHeaders ¶
func (*Partition) AddResponseHeaders ¶
func (p *Partition) AddResponseHeaders(headers *primitive.ResponseHeaders)
type PrimitiveServer ¶
type PrimitiveServer struct { *Client // contains filtered or unexported fields }
func (*PrimitiveServer) Close ¶
func (s *PrimitiveServer) Close(ctx context.Context, request *primitiveapi.CloseRequest) (*primitiveapi.CloseResponse, error)
func (*PrimitiveServer) Create ¶
func (s *PrimitiveServer) Create(ctx context.Context, request *primitiveapi.CreateRequest) (*primitiveapi.CreateResponse, error)
func (*PrimitiveServer) Delete ¶
func (s *PrimitiveServer) Delete(ctx context.Context, request *primitiveapi.DeleteRequest) (*primitiveapi.DeleteResponse, error)
type Protocol ¶
type Protocol struct { *server.Server Client *Client Env env.DriverEnv // contains filtered or unexported fields }
Protocol is a state machine protocol
func NewProtocol ¶
NewProtocol creates a new state machine protocol
func (*Protocol) Configure ¶
func (n *Protocol) Configure(config protocolapi.ProtocolConfig) error
Configure configures the protocol
func (*Protocol) Primitives ¶
func (n *Protocol) Primitives() *primitive.PrimitiveTypeRegistry
Primitives returns the protocol primitives
Directories ¶
Path | Synopsis |
---|---|
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Click to show internal directories.
Click to hide internal directories.