cloud

Documentation

Index

• type BinFrame
  • func UnmarshalBinFrame(frameBytes []byte) (*BinFrame, error)
  • func (c *BinFrame) Marshal() ([]byte, error)
• type BinFrameHeader
• type BinFrameTask
• type Connection
  • func NewConnection() *Connection
  • func (c *Connection) AccountInfo(request nodeinterface.CloudAccountInfoRequest) (resp nodeinterface.CloudAccountInfoResponse, err error)
  • func (c *Connection) AddNode(name string) (resp nodeinterface.CloudAddNodeResponse, err error)
  • func (c *Connection) Call(function string, requestText []byte) (response []byte, err error)
  • func (c *Connection) CloseConnection()
  • func (c *Connection) Connected() bool
  • func (c *Connection) GetSettings(request nodeinterface.CloudGetSettingsRequest) (nodeinterface.CloudGetSettingsResponse, error)
  • func (c *Connection) LoadSession() error
  • func (c *Connection) Login(userName string, password string)
  • func (c *Connection) Logout()
  • func (c *Connection) Nodes() (resp nodeinterface.CloudNodesResponse, err error)
  • func (c *Connection) RemoveNode(nodeId string) (resp nodeinterface.CloudRemoveNodeResponse, err error)
  • func (c *Connection) SaveSession() error
  • func (c *Connection) SendData(data *BinFrame) (frameLen int64)
  • func (c *Connection) SessionId() string
  • func (c *Connection) SetCurrentNodeId(request nodeinterface.CloudSetCurrentNodeIdRequest) (resp nodeinterface.CloudSetCurrentNodeIdResponse, err error)
  • func (c *Connection) SetRequester(requester common_interfaces.Requester)
  • func (c *Connection) SetSettings(request nodeinterface.CloudSetSettingsRequest) (resp nodeinterface.CloudSetSettingsResponse, err error)
  • func (c *Connection) Start()
  • func (c *Connection) Started() bool
  • func (c *Connection) Stat() (res common_interfaces.StatGazerCloud)
  • func (c *Connection) State() (nodeinterface.CloudStateResponse, error)
  • func (c *Connection) Stop()
  • func (c *Connection) UpdateNode(nodeId string, name string) (resp nodeinterface.CloudUpdateNodeResponse, err error)
  • func (c *Connection) UserName() string
• type ProxyTask
• type SessionConfig

Types

type BinFrame

type BinFrame struct {
	Header BinFrameHeader
	Data   []byte
}

func UnmarshalBinFrame

func UnmarshalBinFrame(frameBytes []byte) (*BinFrame, error)

func (*BinFrame) Marshal

func (c *BinFrame) Marshal() ([]byte, error)

type BinFrameHeader

type BinFrameHeader struct {
	Src           string `json:"src"`
	Dest          string `json:"dest"`
	Function      string `json:"function"`
	TransactionId string `json:"transaction_id"`
	SessionId     string `json:"session_id"`
}

type BinFrameTask

type BinFrameTask struct {
	SessionId string
	Client    *Connection
	Frame     *BinFrame
}

type Connection

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

func NewConnection

func NewConnection() *Connection

func (*Connection) AccountInfo

func (c *Connection) AccountInfo(request nodeinterface.CloudAccountInfoRequest) (resp nodeinterface.CloudAccountInfoResponse, err error)

func (*Connection) AddNode

func (c *Connection) AddNode(name string) (resp nodeinterface.CloudAddNodeResponse, err error)

func (*Connection) Call

func (c *Connection) Call(function string, requestText []byte) (response []byte, err error)

func (*Connection) CloseConnection

func (c *Connection) CloseConnection()

func (*Connection) Connected

func (c *Connection) Connected() bool

func (*Connection) GetSettings

func (c *Connection) GetSettings(request nodeinterface.CloudGetSettingsRequest) (nodeinterface.CloudGetSettingsResponse, error)

func (*Connection) LoadSession

func (c *Connection) LoadSession() error

func (*Connection) Login

func (c *Connection) Login(userName string, password string)

func (*Connection) Logout

func (c *Connection) Logout()

func (*Connection) Nodes

func (c *Connection) Nodes() (resp nodeinterface.CloudNodesResponse, err error)

func (*Connection) RemoveNode

func (c *Connection) RemoveNode(nodeId string) (resp nodeinterface.CloudRemoveNodeResponse, err error)

func (*Connection) SaveSession

func (c *Connection) SaveSession() error

func (*Connection) SendData

func (c *Connection) SendData(data *BinFrame) (frameLen int64)

func (*Connection) SessionId

func (c *Connection) SessionId() string

func (*Connection) SetCurrentNodeId

func (c *Connection) SetCurrentNodeId(request nodeinterface.CloudSetCurrentNodeIdRequest) (resp nodeinterface.CloudSetCurrentNodeIdResponse, err error)

func (*Connection) SetRequester

func (c *Connection) SetRequester(requester common_interfaces.Requester)

func (*Connection) SetSettings

func (c *Connection) SetSettings(request nodeinterface.CloudSetSettingsRequest) (resp nodeinterface.CloudSetSettingsResponse, err error)

func (*Connection) Start

func (c *Connection) Start()

func (*Connection) Started

func (c *Connection) Started() bool

func (*Connection) Stat

func (c *Connection) Stat() (res common_interfaces.StatGazerCloud)

func (*Connection) State

func (c *Connection) State() (nodeinterface.CloudStateResponse, error)

func (*Connection) Stop

func (c *Connection) Stop()

func (*Connection) UpdateNode

func (c *Connection) UpdateNode(nodeId string, name string) (resp nodeinterface.CloudUpdateNodeResponse, err error)

func (*Connection) UserName

func (c *Connection) UserName() string

type ProxyTask

type ProxyTask struct {
	TransactionId string
	Function      string
	RequestText   []byte

	ResponseReceived bool
	ErrorReceived    bool
	ResponseText     []byte
}

type SessionConfig

type SessionConfig struct {
	UserName string `json:"user_name"`
	Key      string `json:"key"`
	NodeId   string `json:"node_id"`

	AllowIncomingFunctions []string `json:"allow_incoming_functions"`
}