rpc

Documentation

Index

• Constants
• Variables
• func InitComet(conn *zk.Conn, fpath string, retry, ping time.Duration)
• func InitMessage(conn *zk.Conn, fpath string, retry, ping time.Duration)
• type CometMigrateArgs
• type CometNewArgs
• type CometNodeEvent
• type CometNodeInfo
  • func GetComet(key string) *CometNodeInfo
• type CometPushPrivateArgs
• type CometPushPublicArgs
• type Message
  • func (m *Message) Bytes() ([]byte, error)
  • func (m *Message) OldBytes() ([]byte, error)
• type MessageGetPrivateArgs
• type MessageGetResp
• type MessageNodeEvent
• type MessageSavePrivateArgs
• type MessageSavePublishArgs
• type OldMessage
• type RandLB
  • func NewRandLB(clients map[string]*rpc.Client, addrs []string, service string, ...) (*RandLB, error)
  • func (r *RandLB) Destroy()
  • func (r *RandLB) Get() *rpc.Client
  • func (r *RandLB) Stop()

Constants

const (
	// group id
	PrivateGroupId = 0
	PublicGroupId  = 1
	// message rpc service
	MessageService            = "MessageRPC"
	MessageServiceGetPrivate  = "MessageRPC.GetPrivate"
	MessageServiceSavePrivate = "MessageRPC.SavePrivate"
	MessageServiceDelPrivate  = "MessageRPC.DelPrivate"
)

const (
	// common
	// ok
	OK = 0
	// param error
	ParamErr = 65534
	// internal error
	InternalErr = 65535
)

const (
	CometServicePushPrivate = "CometRPC.PushPrivate"
)

Variables

var (
	ErrRandLBLength = errors.New("clients and addrs length not match")
	ErrRandLBAddr   = errors.New("clients map no addr key")
)

var (
	ErrCometRPC = errors.New("comet rpc call failed")
)

var (
	ErrParam = errors.New("parameter error")
)

Functions

func InitComet

func InitComet(conn *zk.Conn, fpath string, retry, ping time.Duration)

InitComet init a rand lb rpc for comet module.

func InitMessage

func InitMessage(conn *zk.Conn, fpath string, retry, ping time.Duration)

InitMessage init a rand lb rpc for message module.

Types

type CometMigrateArgs

type CometMigrateArgs struct {
	Nodes []string // current comet nodes
	Vnode int      // ketama virtual node number
}

Channel Migrate Args

type CometNewArgs

type CometNewArgs struct {
	Expire int64  // message expire second
	Token  string // auth token
	Key    string // subscriber key
}

Channel New Args

type CometNodeEvent

type CometNodeEvent struct {
	// node name(node1, node2...)
	Key string
	// node info
	Value *CometNodeInfo
	// event type
	Event int
}

type CometNodeInfo

type CometNodeInfo struct {
	// The addr for subscribe, format like:map[Protocol]Addr
	Addr map[int][]string
	// The connection for Comet RPC
	CometRPC *RandLB
}

func GetComet

func GetComet(key string) *CometNodeInfo

GetComet get the node infomation under the node.

type CometPushPrivateArgs

type CometPushPrivateArgs struct {
	Key    string          // subscriber key
	Msg    json.RawMessage // message content
	Expire uint            // message expire second
}

Channel Push Private Message Args

type CometPushPublicArgs

type CometPushPublicArgs struct {
	MsgID int64  // message id
	Msg   string // message content
}

Channel Push Public Message Args

type Message

type Message struct {
	Msg     json.RawMessage `json:"msg"` // message content
	MsgId   int64           `json:"mid"` // message id
	GroupId uint            `json:"gid"` // group id
}

The Message struct

func (*Message) Bytes

func (m *Message) Bytes() ([]byte, error)

Bytes get a message reply bytes.

func (*Message) OldBytes

func (m *Message) OldBytes() ([]byte, error)

OldBytes get a message reply bytes(Compatible), TODO remove it.

type MessageGetPrivateArgs

type MessageGetPrivateArgs struct {
	MsgId int64  // message id
	Key   string // subscriber key
}

Message Get Args

type MessageGetResp

type MessageGetResp struct {
	Msgs []*Message // messages
}

Message Get Response

type MessageNodeEvent

type MessageNodeEvent struct {
	// addr:port
	Key string
	// event type
	Event int
}

type MessageSavePrivateArgs

type MessageSavePrivateArgs struct {
	Key    string          // subscriber key
	Msg    json.RawMessage // message content
	MsgId  int64           // message id
	Expire uint            // message expire second
}

Message SavePrivate Args

type MessageSavePublishArgs

type MessageSavePublishArgs struct {
	MsgID  int64  // message id
	Msg    string // message content
	Expire int64  // message expire second
}

Message SavePublish Args

type OldMessage

type OldMessage struct {
	Msg     string `json:"msg"` // Message
	MsgId   int64  `json:"mid"` // Message id
	GroupId uint   `json:"gid"` // Group id
}

The Old Message struct (Compatible), TODO remove it.

type RandLB

type RandLB struct {
	Clients map[string]*rpc.Client
	// contains filtered or unexported fields
}

random load balancing object

var (
	MessageRPC *RandLB
)

func NewRandLB

func NewRandLB(clients map[string]*rpc.Client, addrs []string, service string, retry, ping time.Duration, check bool) (*RandLB, error)

NewRandLB new a random load balancing object.

func (*RandLB) Destroy

func (r *RandLB) Destroy()

Destroy release the rpc.Client resource.

func (*RandLB) Get

func (r *RandLB) Get() *rpc.Client

Get get a rpc client randomly.

func (*RandLB) Stop

func (r *RandLB) Stop()

Stop stop the retry connect goroutine and ping goroutines.