Documentation ¶
Index ¶
- Variables
- func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)
- type Client
- type Partition
- type PartitionID
- type Picker
- type PickerBuilder
- 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
- type RSMConfig
- func (*RSMConfig) Descriptor() ([]byte, []int)
- func (m *RSMConfig) GetReadSync() bool
- func (m *RSMConfig) Marshal() (dAtA []byte, err error)
- func (m *RSMConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *RSMConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RSMConfig) ProtoMessage()
- func (m *RSMConfig) Reset()
- func (m *RSMConfig) Size() (n int)
- func (m *RSMConfig) String() string
- func (m *RSMConfig) Unmarshal(dAtA []byte) error
- func (m *RSMConfig) XXX_DiscardUnknown()
- func (m *RSMConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RSMConfig) XXX_Merge(src proto.Message)
- func (m *RSMConfig) XXX_Size() int
- func (m *RSMConfig) XXX_Unmarshal(b []byte) error
- type Resolver
- type ResolverBuilder
- type Service
- func (s *Service) DoCommand(ctx context.Context, operationID rsm.OperationID, input []byte) ([]byte, error)
- func (s *Service) DoCommandStream(ctx context.Context, operationID rsm.OperationID, input []byte, ...) error
- func (s *Service) DoQuery(ctx context.Context, operationID rsm.OperationID, input []byte, sync bool) ([]byte, error)
- func (s *Service) DoQueryStream(ctx context.Context, operationID rsm.OperationID, input []byte, ...) error
- type Session
- type SessionOption
Constants ¶
This section is empty.
Variables ¶
Functions ¶
Types ¶
type Client ¶
type Client struct { Namespace string // contains filtered or unexported fields }
Client is a client for communicating with the storage layer
func (*Client) Partition ¶
func (p *Client) Partition(partitionID PartitionID) *Partition
func (*Client) PartitionBy ¶
func (*Client) Partitions ¶
type Partition ¶
type Partition struct { cluster.Partition *Session ID PartitionID }
Partition is a proxy partition
func NewPartition ¶
NewPartition creates a new proxy partition
type PickerBuilder ¶ added in v0.9.1
type PickerBuilder struct{}
func (*PickerBuilder) Build ¶ added in v0.9.1
func (p *PickerBuilder) Build(info base.PickerBuildInfo) balancer.Picker
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
type RSMConfig ¶ added in v0.8.0
type RSMConfig struct {
ReadSync bool `protobuf:"varint,1,opt,name=read_sync,json=readSync,proto3" json:"read_sync,omitempty"`
}
func (*RSMConfig) Descriptor ¶ added in v0.8.0
func (*RSMConfig) GetReadSync ¶ added in v0.8.0
func (*RSMConfig) MarshalToSizedBuffer ¶ added in v0.8.0
func (*RSMConfig) ProtoMessage ¶ added in v0.8.0
func (*RSMConfig) ProtoMessage()
func (*RSMConfig) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *RSMConfig) XXX_DiscardUnknown()
func (*RSMConfig) XXX_Marshal ¶ added in v0.8.0
func (*RSMConfig) XXX_Unmarshal ¶ added in v0.8.0
type Resolver ¶ added in v0.9.1
type Resolver struct {
// contains filtered or unexported fields
}
func (*Resolver) ResolveNow ¶ added in v0.9.1
func (r *Resolver) ResolveNow(resolver.ResolveNowOptions)
type ResolverBuilder ¶ added in v0.9.1
type ResolverBuilder struct {
// contains filtered or unexported fields
}
func (*ResolverBuilder) Build ¶ added in v0.9.1
func (b *ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
func (*ResolverBuilder) Scheme ¶ added in v0.9.1
func (b *ResolverBuilder) Scheme() string
type Service ¶ added in v0.9.1
type Service struct { *Session // contains filtered or unexported fields }
Service maintains the session for a primitive
func (*Service) DoCommand ¶ added in v0.9.1
func (s *Service) DoCommand(ctx context.Context, operationID rsm.OperationID, input []byte) ([]byte, error)
DoCommand submits a command to the service
func (*Service) DoCommandStream ¶ added in v0.9.1
func (s *Service) DoCommandStream(ctx context.Context, operationID rsm.OperationID, input []byte, stream streams.WriteStream) error
DoCommandStream submits a streaming command to the service
func (*Service) DoQuery ¶ added in v0.9.1
func (s *Service) DoQuery(ctx context.Context, operationID rsm.OperationID, input []byte, sync bool) ([]byte, error)
DoQuery submits a query to the service
func (*Service) DoQueryStream ¶ added in v0.9.1
func (s *Service) DoQueryStream(ctx context.Context, operationID rsm.OperationID, input []byte, stream streams.WriteStream, sync bool) error
DoQueryStream submits a streaming query to the service
type Session ¶
Session maintains the session for a primitive
func NewSession ¶
func NewSession(partition cluster.Partition, opts ...SessionOption) *Session
NewSession creates a new Session for the given partition name is the name of the primitive handler is the primitive's session handler
func (*Session) GetService ¶ added in v0.9.1
type SessionOption ¶
type SessionOption interface {
// contains filtered or unexported methods
}
SessionOption implements a session option
func WithSessionTimeout ¶
func WithSessionTimeout(timeout time.Duration) SessionOption
WithSessionTimeout returns a session SessionOption to configure the session timeout
Source Files ¶
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. |
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. |