client

Documentation

Index

• Constants
• type Client
  • func New(config *Config) (*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

Constants

const (
	Created int32 = iota
	Starting
	Ready
	Stopping
	Stopped
)

Types

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
	// contains filtered or unexported fields
}

func New

func New(config *Config) (*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