client

Documentation

Index

• Constants
• type CRDTOperationTargetFn
• type Client
  • func New(config *Config, schemaCh chan serialization.SchemaMsg) (*Client, error)
  • func (c *Client) AddAfterShutdownHandler(handler func(ctx context.Context))
  • func (c *Client) AddBeforeShutdownHandler(handler func(ctx context.Context))
  • func (c *Client) Name() string
  • func (c *Client) Shutdown(ctx context.Context) error
  • func (c *Client) Start(ctx context.Context) error
  • func (c *Client) State() int32
• type Config
  • func NewConfig() *Config
  • func (c *Config) Validate() error
• type Invoker
  • func NewInvoker(factory *cluster.ConnectionInvocationFactory, svc *invocation.Service, ...) *Invoker
  • func (iv *Invoker) CB() *cb.CircuitBreaker
  • func (iv *Invoker) Factory() *cluster.ConnectionInvocationFactory
  • func (iv *Invoker) InvokeOnConnection(ctx context.Context, req *proto.ClientMessage, conn *cluster.Connection) (*proto.ClientMessage, error)
  • func (iv *Invoker) InvokeOnConnectionWithHandler(ctx context.Context, req *proto.ClientMessage, conn *cluster.Connection, ...) (*proto.ClientMessage, error)
  • func (iv *Invoker) InvokeOnMemberCRDT(ctx context.Context, ...) (*proto.ClientMessage, error)
  • func (iv *Invoker) InvokeOnPartition(ctx context.Context, request *proto.ClientMessage, partitionID int32) (*proto.ClientMessage, error)
  • func (iv *Invoker) InvokeOnPartitionAsync(ctx context.Context, request *proto.ClientMessage, partitionID int32, ...) (invocation.Invocation, error)
  • func (iv *Invoker) InvokeOnRandomTarget(ctx context.Context, request *proto.ClientMessage, ...) (*proto.ClientMessage, error)
  • func (iv *Invoker) InvokeUrgentOnRandomTarget(ctx context.Context, request *proto.ClientMessage, ...) (*proto.ClientMessage, error)
  • func (iv *Invoker) SendInvocation(ctx context.Context, inv invocation.Invocation) error
  • func (iv *Invoker) TryInvoke(ctx context.Context, f cb.TryHandler) (*proto.ClientMessage, error)

Constants

const (
	Created int32 = iota
	Starting
	Ready
	Stopping
	Stopped
)

Types

type CRDTOperationTargetFn

type CRDTOperationTargetFn func(excluded map[types.UUID]struct{}) (*pubcluster.MemberInfo, []proto.Pair)

type Client

type Client struct {
	InvocationHandler    invocation.Handler
	Logger               ilogger.LogAdaptor
	ConnectionManager    *icluster.ConnectionManager
	ViewListenerService  *icluster.ViewListenerService
	InvocationService    *invocation.Service
	InvocationFactory    *icluster.ConnectionInvocationFactory
	SerializationService *serialization.Service
	EventDispatcher      *event.DispatchService
	StatsService         *stats.Service

	PartitionService *icluster.PartitionService
	ClusterService   *icluster.Service
	Invoker          *Invoker
	// contains filtered or unexported fields
}

func New

func New(config *Config, schemaCh chan serialization.SchemaMsg) (*Client, error)

func (*Client) AddAfterShutdownHandler

func (c *Client) AddAfterShutdownHandler(handler func(ctx context.Context))

func (*Client) AddBeforeShutdownHandler

func (c *Client) AddBeforeShutdownHandler(handler func(ctx context.Context))

func (*Client) Name

func (c *Client) Name() string

Name returns client's name. Use config.Name to set the client name. If not set manually, an automatically generated name is used.

func (*Client) Shutdown

func (c *Client) Shutdown(ctx context.Context) error

Shutdown disconnects the client from the cluster and frees resources allocated by the client.

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) State

func (c *Client) State() int32

type Config

type Config struct {
	Name          string
	Cluster       *cluster.Config
	Failover      *cluster.FailoverConfig
	Serialization *pubserialization.Config
	Logger        *logger.Config
	Labels        []string
	StatsEnabled  bool
	StatsPeriod   time.Duration
}

func NewConfig

func NewConfig() *Config

func (*Config) Validate

func (c *Config) Validate() error

type Invoker

type Invoker struct {
	// contains filtered or unexported fields
}

func NewInvoker

func NewInvoker(factory *cluster.ConnectionInvocationFactory, svc *invocation.Service, lg *logger.LogAdaptor) *Invoker

func (*Invoker) CB

func (iv *Invoker) CB() *cb.CircuitBreaker

func (*Invoker) Factory

func (iv *Invoker) Factory() *cluster.ConnectionInvocationFactory

func (*Invoker) InvokeOnConnection

func (iv *Invoker) InvokeOnConnection(ctx context.Context, req *proto.ClientMessage, conn *cluster.Connection) (*proto.ClientMessage, error)

func (*Invoker) InvokeOnConnectionWithHandler

func (iv *Invoker) InvokeOnConnectionWithHandler(ctx context.Context, req *proto.ClientMessage, conn *cluster.Connection, handler proto.ClientMessageHandler) (*proto.ClientMessage, error)

func (*Invoker) InvokeOnMemberCRDT

func (iv *Invoker) InvokeOnMemberCRDT(ctx context.Context, makeReq func(target types.UUID, clocks []proto.Pair) *proto.ClientMessage, crdtFn CRDTOperationTargetFn) (*proto.ClientMessage, error)

func (*Invoker) InvokeOnPartition

func (iv *Invoker) InvokeOnPartition(ctx context.Context, request *proto.ClientMessage, partitionID int32) (*proto.ClientMessage, error)

func (*Invoker) InvokeOnPartitionAsync

func (iv *Invoker) InvokeOnPartitionAsync(ctx context.Context, request *proto.ClientMessage, partitionID int32, now time.Time) (invocation.Invocation, error)

func (*Invoker) InvokeOnRandomTarget

func (iv *Invoker) InvokeOnRandomTarget(ctx context.Context, request *proto.ClientMessage, handler proto.ClientMessageHandler) (*proto.ClientMessage, error)

func (*Invoker) InvokeUrgentOnRandomTarget

func (iv *Invoker) InvokeUrgentOnRandomTarget(ctx context.Context, request *proto.ClientMessage, handler proto.ClientMessageHandler) (*proto.ClientMessage, error)

func (*Invoker) SendInvocation

func (iv *Invoker) SendInvocation(ctx context.Context, inv invocation.Invocation) error

func (*Invoker) TryInvoke

func (iv *Invoker) TryInvoke(ctx context.Context, f cb.TryHandler) (*proto.ClientMessage, error)