cluster

Documentation

Index

• func DeleteClusterUsers(userId string, ti *time.Time) []byte
• func Live()
• func SendALLUser(clusterClient *client.ClusterClient)
• func SendClusterUsers(userIds []string) []byte
• func Start()
• type ClusterConnUser
  • func NewClusterConnUser(co *conn.ClusterConn, st string) *ClusterConnUser
• type ClusterServer
  • func NewClusterServer() *ClusterServer
  • func (this *ClusterServer) Accept() (*conn.ClusterConn, error)
  • func (this *ClusterServer) Bind(lport int) error

Functions

func DeleteClusterUsers

func DeleteClusterUsers(userId string, ti *time.Time) []byte

func Live

func Live()

func SendALLUser

func SendALLUser(clusterClient *client.ClusterClient)

func SendClusterUsers

func SendClusterUsers(userIds []string) []byte

func Start

func Start()

Types

type ClusterConnUser

type ClusterConnUser struct {
	*conn.ClusterConn
	// contains filtered or unexported fields
}

func NewClusterConnUser

func NewClusterConnUser(co *conn.ClusterConn, st string) *ClusterConnUser

type ClusterServer

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

func NewClusterServer

func NewClusterServer() *ClusterServer

func (*ClusterServer) Accept

func (this *ClusterServer) Accept() (*conn.ClusterConn, error)

func (*ClusterServer) Bind

func (this *ClusterServer) Bind(lport int) error