rpc

Documentation

Index

• type Args
  • func (a *Args) GetObject(t interface{}) error
• type ArgsGroup
• type CustomerRoute
• type Reply
• type ReplyGroup
• type Session
  • func NewSession(nodeId string) *Session
  • func NewSessionFromRpc(nodeId string, sessionId int64, userId int64) *Session
  • func (s *Session) Clone() *Session
  • func (s *Session) Get(key string) string
  • func (s *Session) GetCache(key string) string
  • func (s *Session) GetNodeId() string
  • func (s *Session) GetSessionId() int64
  • func (s *Session) GetUserId() int64
  • func (s *Session) Remove(key string)
  • func (s *Session) RemoveCache(key string)
  • func (s *Session) Set(key, value string)
  • func (s *Session) SetCache(key, value string)
  • func (s *Session) SetUserId(userId int64)
  • func (s *Session) SyncSettings(settings map[string]interface{})

Types

type Args

type Args struct {
	*Session
	MsgId  int
	MsgReq interface{}
}

func (*Args) GetObject

func (a *Args) GetObject(t interface{}) error

type ArgsGroup

type ArgsGroup struct {
	Route   string
	Payload []byte
}

Group message request

type CustomerRoute

type CustomerRoute func(session *Session, servicePath, serviceName string) (string, error)

Route msg to the specified node

type Reply

type Reply struct {
	Code    int
	ErrMsg  string
	MsgResp interface{}
}

type ReplyGroup

type ReplyGroup struct {
}

Group message response

type Session

type Session struct {
	NodeId    string
	SessionId int64

	UserId int64

	Settings map[string]string
	// contains filtered or unexported fields
}

func NewSession

func NewSession(nodeId string) *Session

func NewSessionFromRpc

func NewSessionFromRpc(nodeId string, sessionId int64, userId int64) *Session

func (*Session) Clone

func (s *Session) Clone() *Session

func (*Session) Get

func (s *Session) Get(key string) string

func (*Session) GetCache

func (s *Session) GetCache(key string) string

func (*Session) GetNodeId

func (s *Session) GetNodeId() string

func (*Session) GetSessionId

func (s *Session) GetSessionId() int64

func (*Session) GetUserId

func (s *Session) GetUserId() int64

func (*Session) Remove

func (s *Session) Remove(key string)

func (*Session) RemoveCache

func (s *Session) RemoveCache(key string)

func (*Session) Set

func (s *Session) Set(key, value string)

func (*Session) SetCache

func (s *Session) SetCache(key, value string)

func (*Session) SetUserId

func (s *Session) SetUserId(userId int64)

func (*Session) SyncSettings

func (s *Session) SyncSettings(settings map[string]interface{})