client

Documentation

Index

• Constants
• Variables
• func GetValidBootNodeIP() (string, error)
• func StatusCheck(ip string) error
• type ChainClient
  • func NewChainClient(base string) *ChainClient
  • func (cc *ChainClient) GetAccountMeta(userAddr string) (*account.Account, error)
  • func (cc *ChainClient) GetBlockByIdx(nonce *big.Int) (*block.Block, error)
  • func (cc *ChainClient) GetFriendsOf(userAddr string) (*account.FriendRelation, error)
  • func (cc *ChainClient) GetGroupMeta(gid string) (*account.ChatGroup, error)
  • func (cc *ChainClient) GetGroupsOf(userAddr string) (*account.GroupRelation, error)
  • func (cc *ChainClient) GetLatestBlock() (*block.Block, error)
  • func (cc *ChainClient) GetOneFriendOf(userAddr, friend string) (*account.Contact, error)
  • func (cc *ChainClient) RawChainTransaction(path string, raw, sig []byte) (string, error)
  • func (cc *ChainClient) SetBasUrl(newIP string)
• type CliCallBack
• type WSClient
  • func NewWSClient(nodeIP string, cb CliCallBack) (*WSClient, error)
  • func (cc *WSClient) IsOnline() bool
  • func (cc *WSClient) OffLine()
  • func (cc *WSClient) Online(onlineData []byte) error
  • func (cc *WSClient) PullUnreadMsg(startSeq int64, selfID string) error
  • func (cc *WSClient) ResetUrl(newIP string)
  • func (cc *WSClient) Write(to string, msg []byte) error

Constants

const (
	HttpTimeOut = time.Second * 15
)

Variables

var (
	ErrInvalidProtoData = fmt.Errorf("invalid proto data")
	ErrNotFound         = fmt.Errorf("not found")
)

var (
	ErrUnknownMsg    = fmt.Errorf("unknown websocket message")
	ErrNoMsgCallback = fmt.Errorf("no message reciver")
	ErrNoValidNode   = fmt.Errorf("no valid service node")
)

Functions

func GetValidBootNodeIP

func GetValidBootNodeIP() (string, error)

func StatusCheck

func StatusCheck(ip string) error

Types

type ChainClient

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

func NewChainClient

func NewChainClient(base string) *ChainClient

func (*ChainClient) GetAccountMeta

func (cc *ChainClient) GetAccountMeta(userAddr string) (*account.Account, error)

func (*ChainClient) GetBlockByIdx

func (cc *ChainClient) GetBlockByIdx(nonce *big.Int) (*block.Block, error)

func (*ChainClient) GetFriendsOf

func (cc *ChainClient) GetFriendsOf(userAddr string) (*account.FriendRelation, error)

func (*ChainClient) GetGroupMeta

func (cc *ChainClient) GetGroupMeta(gid string) (*account.ChatGroup, error)

func (*ChainClient) GetGroupsOf

func (cc *ChainClient) GetGroupsOf(userAddr string) (*account.GroupRelation, error)

func (*ChainClient) GetLatestBlock

func (cc *ChainClient) GetLatestBlock() (*block.Block, error)

func (*ChainClient) GetOneFriendOf

func (cc *ChainClient) GetOneFriendOf(userAddr, friend string) (*account.Contact, error)

func (*ChainClient) RawChainTransaction

func (cc *ChainClient) RawChainTransaction(path string, raw, sig []byte) (string, error)

func (*ChainClient) SetBasUrl

func (cc *ChainClient) SetBasUrl(newIP string)

type CliCallBack

type CliCallBack interface {
	ImmediateMessage(msg *pbs.WSCryptoMsg) error
	WebSocketClosed()
	OnlineSuccess()
	NoRightTips(tips *pbs.WSNoRightTips)
}

type WSClient

type WSClient struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewWSClient

func NewWSClient(nodeIP string, cb CliCallBack) (*WSClient, error)

func (*WSClient) IsOnline

func (cc *WSClient) IsOnline() bool

func (*WSClient) OffLine

func (cc *WSClient) OffLine()

func (*WSClient) Online

func (cc *WSClient) Online(onlineData []byte) error

func (*WSClient) PullUnreadMsg

func (cc *WSClient) PullUnreadMsg(startSeq int64, selfID string) error

func (*WSClient) ResetUrl

func (cc *WSClient) ResetUrl(newIP string)

func (*WSClient) Write

func (cc *WSClient) Write(to string, msg []byte) error