gossip

Documentation

Index

• func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)
• type Client
  • func NewClient(cluster cluster.Cluster, scheme time.Scheme) *Client
  • func (c *Client) AddResponseHeaders(headers *primitive.ResponseHeaders)
  • func (c *Client) Close() error
  • func (c *Client) Partition(partitionID PartitionID) *Partition
  • func (c *Client) PartitionBy(partitionKey []byte) *Partition
  • func (c *Client) Partitions() []*Partition
• type Partition
  • func NewPartition(c cluster.Cluster, p cluster.Partition, clock time.Clock) *Partition
  • func (p *Partition) AddRequestHeaders(ctx context.Context, headers *primitive.RequestHeaders) context.Context
  • func (p *Partition) AddResponseHeaders(headers *primitive.ResponseHeaders)
  • func (p *Partition) Close() error
  • func (p *Partition) Connect() (*grpc.ClientConn, error)
• 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
  • func NewProtocol(cluster cluster.Cluster, env env.DriverEnv, scheme time.Scheme) *Protocol
  • func (n *Protocol) Configure(config protocolapi.ProtocolConfig) error
  • func (n *Protocol) Name() string
  • func (n *Protocol) Primitives() *primitive.PrimitiveTypeRegistry
  • func (n *Protocol) Start() error
  • func (n *Protocol) Stop() error

Functions

func RegisterPrimitiveServer

func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)

Types

type Client

type Client struct {
	Cluster cluster.Cluster
	// contains filtered or unexported fields
}

Client is a client for communicating with the storage layer

func NewClient

func NewClient(cluster cluster.Cluster, scheme time.Scheme) *Client

NewClient creates a new proxy client

func (*Client) AddResponseHeaders

func (c *Client) AddResponseHeaders(headers *primitive.ResponseHeaders)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Partition

func (c *Client) Partition(partitionID PartitionID) *Partition

func (*Client) PartitionBy

func (c *Client) PartitionBy(partitionKey []byte) *Partition

func (*Client) Partitions

func (c *Client) Partitions() []*Partition

type Partition

type Partition struct {
	cluster.Partition

	ID PartitionID
	// contains filtered or unexported fields
}

Partition is a proxy partition

func NewPartition

func NewPartition(c cluster.Cluster, p cluster.Partition, clock time.Clock) *Partition

NewPartition creates a new proxy partition

func (*Partition) AddRequestHeaders

func (p *Partition) AddRequestHeaders(ctx context.Context, headers *primitive.RequestHeaders) context.Context

func (*Partition) AddResponseHeaders

func (p *Partition) AddResponseHeaders(headers *primitive.ResponseHeaders)

func (*Partition) Close

func (p *Partition) Close() error

close closes the connections

func (*Partition) Connect

func (p *Partition) Connect() (*grpc.ClientConn, error)

Connect gets the connection to the partition

type PartitionID

type PartitionID int

PartitionID is a partition identifier

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

func NewProtocol(cluster cluster.Cluster, env env.DriverEnv, scheme time.Scheme) *Protocol

NewProtocol creates a new state machine protocol

func (*Protocol) Configure

func (n *Protocol) Configure(config protocolapi.ProtocolConfig) error

Configure configures the protocol

func (*Protocol) Name

func (n *Protocol) Name() string

Name returns the protocol name

func (*Protocol) Primitives

func (n *Protocol) Primitives() *primitive.PrimitiveTypeRegistry

Primitives returns the protocol primitives

func (*Protocol) Start

func (n *Protocol) Start() error

Start starts the node

func (*Protocol) Stop

func (n *Protocol) Stop() error

Stop stops the node