client

Documentation

Index

• Constants
• type ClusterClient
  • func NewClusterClient(host string, port int) *ClusterClient
  • func NewClusterClient2(addr string) *ClusterClient
  • func (this *ClusterClient) Live(address []string) (int, error)
  • func (this *ClusterClient) Start(handler HandlerFunc, messageHandler MessageHandlerFunc, ...)
  • func (this *ClusterClient) Write(msg []byte) (int, error)
• type HandlerFunc
• type MessageHandlerFunc
• type SendUserHandlerFunc

Constants

const (
	START = 0
	RUN   = 1
	END   = -1
)

Types

type ClusterClient

type ClusterClient struct {
	Raddress string

	Status int
	// contains filtered or unexported fields
}

func NewClusterClient

func NewClusterClient(host string, port int) *ClusterClient

func NewClusterClient2

func NewClusterClient2(addr string) *ClusterClient

func (*ClusterClient) Live

func (this *ClusterClient) Live(address []string) (int, error)

func (*ClusterClient) Start

func (this *ClusterClient) Start(handler HandlerFunc, messageHandler MessageHandlerFunc, sendUserHandlerFunc SendUserHandlerFunc)

func (*ClusterClient) Write

func (this *ClusterClient) Write(msg []byte) (int, error)

type HandlerFunc

type HandlerFunc func(*ClusterClient, int)

type MessageHandlerFunc

type MessageHandlerFunc func(*ClusterClient, *message.Message, string) error

type SendUserHandlerFunc

type SendUserHandlerFunc func(*ClusterClient, string, int)