Documentation ¶
Index ¶
- Variables
- func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)
- type Client
- type EpochClock
- func (*EpochClock) Descriptor() ([]byte, []int)
- func (m *EpochClock) GetElection() *EpochClockElection
- func (m *EpochClock) Marshal() (dAtA []byte, err error)
- func (m *EpochClock) MarshalTo(dAtA []byte) (int, error)
- func (m *EpochClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EpochClock) ProtoMessage()
- func (m *EpochClock) Reset()
- func (m *EpochClock) Size() (n int)
- func (m *EpochClock) String() string
- func (m *EpochClock) Unmarshal(dAtA []byte) error
- func (m *EpochClock) XXX_DiscardUnknown()
- func (m *EpochClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EpochClock) XXX_Merge(src proto.Message)
- func (m *EpochClock) XXX_Size() int
- func (m *EpochClock) XXX_Unmarshal(b []byte) error
- type EpochClockElection
- func (*EpochClockElection) Descriptor() ([]byte, []int)
- func (m *EpochClockElection) GetName() string
- func (m *EpochClockElection) Marshal() (dAtA []byte, err error)
- func (m *EpochClockElection) MarshalTo(dAtA []byte) (int, error)
- func (m *EpochClockElection) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EpochClockElection) ProtoMessage()
- func (m *EpochClockElection) Reset()
- func (m *EpochClockElection) Size() (n int)
- func (m *EpochClockElection) String() string
- func (m *EpochClockElection) Unmarshal(dAtA []byte) error
- func (m *EpochClockElection) XXX_DiscardUnknown()
- func (m *EpochClockElection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EpochClockElection) XXX_Merge(src proto.Message)
- func (m *EpochClockElection) XXX_Size() int
- func (m *EpochClockElection) XXX_Unmarshal(b []byte) error
- type GossipClock
- func (*GossipClock) Descriptor() ([]byte, []int)
- func (m *GossipClock) GetClock() isGossipClock_Clock
- func (m *GossipClock) GetEpoch() *EpochClock
- func (m *GossipClock) GetLogical() *LogicalClock
- func (m *GossipClock) GetPhysical() *PhysicalClock
- func (m *GossipClock) Marshal() (dAtA []byte, err error)
- func (m *GossipClock) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipClock) ProtoMessage()
- func (m *GossipClock) Reset()
- func (m *GossipClock) Size() (n int)
- func (m *GossipClock) String() string
- func (m *GossipClock) Unmarshal(dAtA []byte) error
- func (m *GossipClock) XXX_DiscardUnknown()
- func (m *GossipClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipClock) XXX_Merge(src proto.Message)
- func (*GossipClock) XXX_OneofWrappers() []interface{}
- func (m *GossipClock) XXX_Size() int
- func (m *GossipClock) XXX_Unmarshal(b []byte) error
- type GossipClock_Epoch
- type GossipClock_Logical
- type GossipClock_Physical
- type GossipConfig
- func (*GossipConfig) Descriptor() ([]byte, []int)
- func (m *GossipConfig) GetClock() *GossipClock
- func (m *GossipConfig) GetReplicationFactor() uint32
- func (m *GossipConfig) Marshal() (dAtA []byte, err error)
- func (m *GossipConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipConfig) ProtoMessage()
- func (m *GossipConfig) Reset()
- func (m *GossipConfig) Size() (n int)
- func (m *GossipConfig) String() string
- func (m *GossipConfig) Unmarshal(dAtA []byte) error
- func (m *GossipConfig) XXX_DiscardUnknown()
- func (m *GossipConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipConfig) XXX_Merge(src proto.Message)
- func (m *GossipConfig) XXX_Size() int
- func (m *GossipConfig) XXX_Unmarshal(b []byte) error
- type LogicalClock
- func (*LogicalClock) Descriptor() ([]byte, []int)
- func (m *LogicalClock) Marshal() (dAtA []byte, err error)
- func (m *LogicalClock) MarshalTo(dAtA []byte) (int, error)
- func (m *LogicalClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogicalClock) ProtoMessage()
- func (m *LogicalClock) Reset()
- func (m *LogicalClock) Size() (n int)
- func (m *LogicalClock) String() string
- func (m *LogicalClock) Unmarshal(dAtA []byte) error
- func (m *LogicalClock) XXX_DiscardUnknown()
- func (m *LogicalClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogicalClock) XXX_Merge(src proto.Message)
- func (m *LogicalClock) XXX_Size() int
- func (m *LogicalClock) XXX_Unmarshal(b []byte) error
- type Partition
- type PartitionClient
- type PartitionID
- type PhysicalClock
- func (*PhysicalClock) Descriptor() ([]byte, []int)
- func (m *PhysicalClock) Marshal() (dAtA []byte, err error)
- func (m *PhysicalClock) MarshalTo(dAtA []byte) (int, error)
- func (m *PhysicalClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PhysicalClock) ProtoMessage()
- func (m *PhysicalClock) Reset()
- func (m *PhysicalClock) Size() (n int)
- func (m *PhysicalClock) String() string
- func (m *PhysicalClock) Unmarshal(dAtA []byte) error
- func (m *PhysicalClock) XXX_DiscardUnknown()
- func (m *PhysicalClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PhysicalClock) XXX_Merge(src proto.Message)
- func (m *PhysicalClock) XXX_Size() int
- func (m *PhysicalClock) XXX_Unmarshal(b []byte) error
- 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 Server
Constants ¶
This section is empty.
Variables ¶
Functions ¶
Types ¶
type Client ¶
Client is a client for communicating with the storage layer
type EpochClock ¶ added in v0.6.13
type EpochClock struct {
Election *EpochClockElection `protobuf:"bytes,1,opt,name=election,proto3" json:"election,omitempty"`
}
func (*EpochClock) Descriptor ¶ added in v0.6.13
func (*EpochClock) Descriptor() ([]byte, []int)
func (*EpochClock) GetElection ¶ added in v0.6.13
func (m *EpochClock) GetElection() *EpochClockElection
func (*EpochClock) Marshal ¶ added in v0.6.13
func (m *EpochClock) Marshal() (dAtA []byte, err error)
func (*EpochClock) MarshalTo ¶ added in v0.6.13
func (m *EpochClock) MarshalTo(dAtA []byte) (int, error)
func (*EpochClock) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *EpochClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EpochClock) ProtoMessage ¶ added in v0.6.13
func (*EpochClock) ProtoMessage()
func (*EpochClock) Reset ¶ added in v0.6.13
func (m *EpochClock) Reset()
func (*EpochClock) Size ¶ added in v0.6.13
func (m *EpochClock) Size() (n int)
func (*EpochClock) String ¶ added in v0.6.13
func (m *EpochClock) String() string
func (*EpochClock) Unmarshal ¶ added in v0.6.13
func (m *EpochClock) Unmarshal(dAtA []byte) error
func (*EpochClock) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *EpochClock) XXX_DiscardUnknown()
func (*EpochClock) XXX_Marshal ¶ added in v0.6.13
func (m *EpochClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EpochClock) XXX_Merge ¶ added in v0.6.13
func (m *EpochClock) XXX_Merge(src proto.Message)
func (*EpochClock) XXX_Size ¶ added in v0.6.13
func (m *EpochClock) XXX_Size() int
func (*EpochClock) XXX_Unmarshal ¶ added in v0.6.13
func (m *EpochClock) XXX_Unmarshal(b []byte) error
type EpochClockElection ¶ added in v0.6.13
type EpochClockElection struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*EpochClockElection) Descriptor ¶ added in v0.6.13
func (*EpochClockElection) Descriptor() ([]byte, []int)
func (*EpochClockElection) GetName ¶ added in v0.6.13
func (m *EpochClockElection) GetName() string
func (*EpochClockElection) Marshal ¶ added in v0.6.13
func (m *EpochClockElection) Marshal() (dAtA []byte, err error)
func (*EpochClockElection) MarshalTo ¶ added in v0.6.13
func (m *EpochClockElection) MarshalTo(dAtA []byte) (int, error)
func (*EpochClockElection) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *EpochClockElection) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EpochClockElection) ProtoMessage ¶ added in v0.6.13
func (*EpochClockElection) ProtoMessage()
func (*EpochClockElection) Reset ¶ added in v0.6.13
func (m *EpochClockElection) Reset()
func (*EpochClockElection) Size ¶ added in v0.6.13
func (m *EpochClockElection) Size() (n int)
func (*EpochClockElection) String ¶ added in v0.6.13
func (m *EpochClockElection) String() string
func (*EpochClockElection) Unmarshal ¶ added in v0.6.13
func (m *EpochClockElection) Unmarshal(dAtA []byte) error
func (*EpochClockElection) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *EpochClockElection) XXX_DiscardUnknown()
func (*EpochClockElection) XXX_Marshal ¶ added in v0.6.13
func (m *EpochClockElection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EpochClockElection) XXX_Merge ¶ added in v0.6.13
func (m *EpochClockElection) XXX_Merge(src proto.Message)
func (*EpochClockElection) XXX_Size ¶ added in v0.6.13
func (m *EpochClockElection) XXX_Size() int
func (*EpochClockElection) XXX_Unmarshal ¶ added in v0.6.13
func (m *EpochClockElection) XXX_Unmarshal(b []byte) error
type GossipClock ¶ added in v0.6.13
type GossipClock struct { // Types that are valid to be assigned to Clock: // *GossipClock_Logical // *GossipClock_Physical // *GossipClock_Epoch Clock isGossipClock_Clock `protobuf_oneof:"clock"` }
func (*GossipClock) Descriptor ¶ added in v0.6.13
func (*GossipClock) Descriptor() ([]byte, []int)
func (*GossipClock) GetClock ¶ added in v0.6.13
func (m *GossipClock) GetClock() isGossipClock_Clock
func (*GossipClock) GetEpoch ¶ added in v0.6.13
func (m *GossipClock) GetEpoch() *EpochClock
func (*GossipClock) GetLogical ¶ added in v0.6.13
func (m *GossipClock) GetLogical() *LogicalClock
func (*GossipClock) GetPhysical ¶ added in v0.6.13
func (m *GossipClock) GetPhysical() *PhysicalClock
func (*GossipClock) Marshal ¶ added in v0.6.13
func (m *GossipClock) Marshal() (dAtA []byte, err error)
func (*GossipClock) MarshalTo ¶ added in v0.6.13
func (m *GossipClock) MarshalTo(dAtA []byte) (int, error)
func (*GossipClock) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *GossipClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipClock) ProtoMessage ¶ added in v0.6.13
func (*GossipClock) ProtoMessage()
func (*GossipClock) Reset ¶ added in v0.6.13
func (m *GossipClock) Reset()
func (*GossipClock) Size ¶ added in v0.6.13
func (m *GossipClock) Size() (n int)
func (*GossipClock) String ¶ added in v0.6.13
func (m *GossipClock) String() string
func (*GossipClock) Unmarshal ¶ added in v0.6.13
func (m *GossipClock) Unmarshal(dAtA []byte) error
func (*GossipClock) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *GossipClock) XXX_DiscardUnknown()
func (*GossipClock) XXX_Marshal ¶ added in v0.6.13
func (m *GossipClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipClock) XXX_Merge ¶ added in v0.6.13
func (m *GossipClock) XXX_Merge(src proto.Message)
func (*GossipClock) XXX_OneofWrappers ¶ added in v0.6.13
func (*GossipClock) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*GossipClock) XXX_Size ¶ added in v0.6.13
func (m *GossipClock) XXX_Size() int
func (*GossipClock) XXX_Unmarshal ¶ added in v0.6.13
func (m *GossipClock) XXX_Unmarshal(b []byte) error
type GossipClock_Epoch ¶ added in v0.6.13
type GossipClock_Epoch struct {
Epoch *EpochClock `protobuf:"bytes,3,opt,name=epoch,proto3,oneof" json:"epoch,omitempty"`
}
func (*GossipClock_Epoch) MarshalTo ¶ added in v0.6.13
func (m *GossipClock_Epoch) MarshalTo(dAtA []byte) (int, error)
func (*GossipClock_Epoch) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *GossipClock_Epoch) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipClock_Epoch) Size ¶ added in v0.6.13
func (m *GossipClock_Epoch) Size() (n int)
type GossipClock_Logical ¶ added in v0.6.13
type GossipClock_Logical struct {
Logical *LogicalClock `protobuf:"bytes,1,opt,name=logical,proto3,oneof" json:"logical,omitempty"`
}
func (*GossipClock_Logical) MarshalTo ¶ added in v0.6.13
func (m *GossipClock_Logical) MarshalTo(dAtA []byte) (int, error)
func (*GossipClock_Logical) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *GossipClock_Logical) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipClock_Logical) Size ¶ added in v0.6.13
func (m *GossipClock_Logical) Size() (n int)
type GossipClock_Physical ¶ added in v0.6.13
type GossipClock_Physical struct {
Physical *PhysicalClock `protobuf:"bytes,2,opt,name=physical,proto3,oneof" json:"physical,omitempty"`
}
func (*GossipClock_Physical) MarshalTo ¶ added in v0.6.13
func (m *GossipClock_Physical) MarshalTo(dAtA []byte) (int, error)
func (*GossipClock_Physical) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *GossipClock_Physical) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipClock_Physical) Size ¶ added in v0.6.13
func (m *GossipClock_Physical) Size() (n int)
type GossipConfig ¶ added in v0.6.13
type GossipConfig struct { Clock *GossipClock `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"` ReplicationFactor uint32 `protobuf:"varint,2,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"` }
func (*GossipConfig) Descriptor ¶ added in v0.6.13
func (*GossipConfig) Descriptor() ([]byte, []int)
func (*GossipConfig) GetClock ¶ added in v0.6.13
func (m *GossipConfig) GetClock() *GossipClock
func (*GossipConfig) GetReplicationFactor ¶ added in v0.6.13
func (m *GossipConfig) GetReplicationFactor() uint32
func (*GossipConfig) Marshal ¶ added in v0.6.13
func (m *GossipConfig) Marshal() (dAtA []byte, err error)
func (*GossipConfig) MarshalTo ¶ added in v0.6.13
func (m *GossipConfig) MarshalTo(dAtA []byte) (int, error)
func (*GossipConfig) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *GossipConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipConfig) ProtoMessage ¶ added in v0.6.13
func (*GossipConfig) ProtoMessage()
func (*GossipConfig) Reset ¶ added in v0.6.13
func (m *GossipConfig) Reset()
func (*GossipConfig) Size ¶ added in v0.6.13
func (m *GossipConfig) Size() (n int)
func (*GossipConfig) String ¶ added in v0.6.13
func (m *GossipConfig) String() string
func (*GossipConfig) Unmarshal ¶ added in v0.6.13
func (m *GossipConfig) Unmarshal(dAtA []byte) error
func (*GossipConfig) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *GossipConfig) XXX_DiscardUnknown()
func (*GossipConfig) XXX_Marshal ¶ added in v0.6.13
func (m *GossipConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipConfig) XXX_Merge ¶ added in v0.6.13
func (m *GossipConfig) XXX_Merge(src proto.Message)
func (*GossipConfig) XXX_Size ¶ added in v0.6.13
func (m *GossipConfig) XXX_Size() int
func (*GossipConfig) XXX_Unmarshal ¶ added in v0.6.13
func (m *GossipConfig) XXX_Unmarshal(b []byte) error
type LogicalClock ¶ added in v0.6.13
type LogicalClock struct { }
func (*LogicalClock) Descriptor ¶ added in v0.6.13
func (*LogicalClock) Descriptor() ([]byte, []int)
func (*LogicalClock) Marshal ¶ added in v0.6.13
func (m *LogicalClock) Marshal() (dAtA []byte, err error)
func (*LogicalClock) MarshalTo ¶ added in v0.6.13
func (m *LogicalClock) MarshalTo(dAtA []byte) (int, error)
func (*LogicalClock) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *LogicalClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogicalClock) ProtoMessage ¶ added in v0.6.13
func (*LogicalClock) ProtoMessage()
func (*LogicalClock) Reset ¶ added in v0.6.13
func (m *LogicalClock) Reset()
func (*LogicalClock) Size ¶ added in v0.6.13
func (m *LogicalClock) Size() (n int)
func (*LogicalClock) String ¶ added in v0.6.13
func (m *LogicalClock) String() string
func (*LogicalClock) Unmarshal ¶ added in v0.6.13
func (m *LogicalClock) Unmarshal(dAtA []byte) error
func (*LogicalClock) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *LogicalClock) XXX_DiscardUnknown()
func (*LogicalClock) XXX_Marshal ¶ added in v0.6.13
func (m *LogicalClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogicalClock) XXX_Merge ¶ added in v0.6.13
func (m *LogicalClock) XXX_Merge(src proto.Message)
func (*LogicalClock) XXX_Size ¶ added in v0.6.13
func (m *LogicalClock) XXX_Size() int
func (*LogicalClock) XXX_Unmarshal ¶ added in v0.6.13
func (m *LogicalClock) XXX_Unmarshal(b []byte) error
type Partition ¶
type Partition struct { *PartitionClient // contains filtered or unexported fields }
func (*Partition) AddRequestHeaders ¶
func (*Partition) AddResponseHeaders ¶
func (p *Partition) AddResponseHeaders(headers *primitive.ResponseHeaders)
type PartitionClient ¶ added in v0.6.13
type PartitionClient struct { cluster.Partition ID PartitionID // contains filtered or unexported fields }
partitionClient is a proxy partition client
func (*PartitionClient) Close ¶ added in v0.6.13
func (p *PartitionClient) Close() error
Close closes the connections
func (*PartitionClient) Connect ¶ added in v0.6.13
func (p *PartitionClient) Connect() (*grpc.ClientConn, error)
Connect gets the connection to the partition
type PhysicalClock ¶ added in v0.6.13
type PhysicalClock struct { }
func (*PhysicalClock) Descriptor ¶ added in v0.6.13
func (*PhysicalClock) Descriptor() ([]byte, []int)
func (*PhysicalClock) Marshal ¶ added in v0.6.13
func (m *PhysicalClock) Marshal() (dAtA []byte, err error)
func (*PhysicalClock) MarshalTo ¶ added in v0.6.13
func (m *PhysicalClock) MarshalTo(dAtA []byte) (int, error)
func (*PhysicalClock) MarshalToSizedBuffer ¶ added in v0.6.13
func (m *PhysicalClock) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PhysicalClock) ProtoMessage ¶ added in v0.6.13
func (*PhysicalClock) ProtoMessage()
func (*PhysicalClock) Reset ¶ added in v0.6.13
func (m *PhysicalClock) Reset()
func (*PhysicalClock) Size ¶ added in v0.6.13
func (m *PhysicalClock) Size() (n int)
func (*PhysicalClock) String ¶ added in v0.6.13
func (m *PhysicalClock) String() string
func (*PhysicalClock) Unmarshal ¶ added in v0.6.13
func (m *PhysicalClock) Unmarshal(dAtA []byte) error
func (*PhysicalClock) XXX_DiscardUnknown ¶ added in v0.6.13
func (m *PhysicalClock) XXX_DiscardUnknown()
func (*PhysicalClock) XXX_Marshal ¶ added in v0.6.13
func (m *PhysicalClock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PhysicalClock) XXX_Merge ¶ added in v0.6.13
func (m *PhysicalClock) XXX_Merge(src proto.Message)
func (*PhysicalClock) XXX_Size ¶ added in v0.6.13
func (m *PhysicalClock) XXX_Size() int
func (*PhysicalClock) XXX_Unmarshal ¶ added in v0.6.13
func (m *PhysicalClock) XXX_Unmarshal(b []byte) error
type PrimitiveServer ¶
type PrimitiveServer struct { *Server // 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 Server ¶ added in v0.6.13
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶ added in v0.6.13
func NewServer(client *Client, config GossipConfig) *Server
func (*Server) AddResponseHeaders ¶ added in v0.6.13
func (s *Server) AddResponseHeaders(headers *primitive.ResponseHeaders)
func (*Server) Partition ¶ added in v0.6.13
func (s *Server) Partition(partitionID PartitionID) *Partition
func (*Server) PartitionBy ¶ added in v0.6.13
func (*Server) Partitions ¶ added in v0.6.13
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. |
Click to show internal directories.
Click to hide internal directories.