sxutil

README

synerex_sxutil

Documentation

Index

• func CallDeferFunctions()
• func GenerateIntID() uint64
• func GetNodeName(n int) string
• func GrpcConnectServer(serverAddress string) api.SynerexClient
• func HandleSigInt()
• func InitNodeNum(n int)
• func MsgCountUp()
• func RegisterDeferFunction(f func())
• func RegisterNode(nodesrv string, nm string, channels []uint32, serv *SxServerOpt) (string, error)
• func SetNodeStatus(status int32, arg string)
• func UnRegisterNode()
• type DemandOpts
• type IDType
• type SXServiceClient
  • func NewSXServiceClient(clt api.SynerexClient, mtype uint32, argJson string) *SXServiceClient
  • func (clt *SXServiceClient) CloseMbus(ctx context.Context) error
  • func (clt *SXServiceClient) Confirm(id IDType) error
  • func (clt *SXServiceClient) IsDemandTarget(dm *api.Demand, idlist []uint64) bool
  • func (clt *SXServiceClient) IsSupplyTarget(sp *api.Supply, idlist []uint64) bool
  • func (clt *SXServiceClient) NotifyDemand(dmo *DemandOpts) (uint64, error)
  • func (clt *SXServiceClient) NotifySupply(smo *SupplyOpts) (uint64, error)
  • func (clt *SXServiceClient) ProposeSupply(spo *SupplyOpts) uint64
  • func (clt *SXServiceClient) SelectDemand(dm *api.Demand) error
  • func (clt *SXServiceClient) SelectSupply(sp *api.Supply) (uint64, error)
  • func (clt *SXServiceClient) SendMsg(ctx context.Context, msg *api.MbusMsg) error
  • func (clt *SXServiceClient) SubscribeDemand(ctx context.Context, dmcb func(*SXServiceClient, *api.Demand)) error
  • func (clt *SXServiceClient) SubscribeMbus(ctx context.Context, mbcb func(*SXServiceClient, *api.MbusMsg)) error
  • func (clt *SXServiceClient) SubscribeSupply(ctx context.Context, spcb func(*SXServiceClient, *api.Supply)) error
• type SupplyOpts
• type SxServerOpt

Functions

func CallDeferFunctions

func CallDeferFunctions()

func GenerateIntID

func GenerateIntID() uint64

GenerateIntID for generate uniquie ID

func GetNodeName

func GetNodeName(n int) string

func GrpcConnectServer

func GrpcConnectServer(serverAddress string) api.SynerexClient

Utility Function for Conneting gRPC server

func HandleSigInt

func HandleSigInt()

func InitNodeNum

func InitNodeNum(n int)

InitNodeNum for initialize NodeNum again

func MsgCountUp

func MsgCountUp()

func RegisterDeferFunction

func RegisterDeferFunction(f func())

register closing functions.

func RegisterNode

func RegisterNode(nodesrv string, nm string, channels []uint32, serv *SxServerOpt) (string, error)

RegisterNode is a function to register Node with node server address

func SetNodeStatus

func SetNodeStatus(status int32, arg string)

func UnRegisterNode

func UnRegisterNode()

UnRegisterNode de-registrate node id

Types

type DemandOpts

type DemandOpts struct {
	ID     uint64
	Target uint64
	Name   string
	JSON   string
	Cdata  *api.Content
}

DemandOpts is sender options for Demand

type IDType

type IDType uint64

IDType for all ID in Synerex

type SXServiceClient

type SXServiceClient struct {
	ClientID    IDType
	ChannelType uint32
	Client      api.SynerexClient
	ArgJson     string
	MbusID      IDType
}

SXServiceClient Wrappter Structure for market client

func NewSXServiceClient

func NewSXServiceClient(clt api.SynerexClient, mtype uint32, argJson string) *SXServiceClient

NewSXServiceClient Creates wrapper structre SXServiceClient from SynerexClient

func (*SXServiceClient) CloseMbus

func (clt *SXServiceClient) CloseMbus(ctx context.Context) error

func (*SXServiceClient) Confirm

func (clt *SXServiceClient) Confirm(id IDType) error

Confirm sends confirm message to sender

func (*SXServiceClient) IsDemandTarget

func (clt *SXServiceClient) IsDemandTarget(dm *api.Demand, idlist []uint64) bool

IsDemandTarget is a helper function to check target

func (*SXServiceClient) IsSupplyTarget

func (clt *SXServiceClient) IsSupplyTarget(sp *api.Supply, idlist []uint64) bool

IsSupplyTarget is a helper function to check target

func (*SXServiceClient) NotifyDemand

func (clt *SXServiceClient) NotifyDemand(dmo *DemandOpts) (uint64, error)

NotifyDemand sends Typed Demand to Server

func (*SXServiceClient) NotifySupply

func (clt *SXServiceClient) NotifySupply(smo *SupplyOpts) (uint64, error)

NotifySupply sends Typed Supply to Server

func (*SXServiceClient) ProposeSupply

func (clt *SXServiceClient) ProposeSupply(spo *SupplyOpts) uint64

ProposeSupply send proposal Supply message to server

func (*SXServiceClient) SelectDemand

func (clt *SXServiceClient) SelectDemand(dm *api.Demand) error

SelectDemand send select message to server

func (*SXServiceClient) SelectSupply

func (clt *SXServiceClient) SelectSupply(sp *api.Supply) (uint64, error)

SelectSupply send select message to server

func (*SXServiceClient) SendMsg

func (clt *SXServiceClient) SendMsg(ctx context.Context, msg *api.MbusMsg) error

func (*SXServiceClient) SubscribeDemand

func (clt *SXServiceClient) SubscribeDemand(ctx context.Context, dmcb func(*SXServiceClient, *api.Demand)) error

SubscribeDemand Wrapper function for SXServiceClient

func (*SXServiceClient) SubscribeMbus

func (clt *SXServiceClient) SubscribeMbus(ctx context.Context, mbcb func(*SXServiceClient, *api.MbusMsg)) error

SubscribeMbus Wrapper function for SXServiceClient

func (*SXServiceClient) SubscribeSupply

func (clt *SXServiceClient) SubscribeSupply(ctx context.Context, spcb func(*SXServiceClient, *api.Supply)) error

SubscribeSupply Wrapper function for SXServiceClient

type SupplyOpts

type SupplyOpts struct {
	ID     uint64
	Target uint64
	Name   string
	JSON   string
	Cdata  *api.Content
}

SupplyOpts is sender options for Supply

type SxServerOpt

type SxServerOpt struct {
	NodeType   nodeapi.NodeType
	ServerInfo string
	ClusterId  int32
	AreaId     string
	GwInfo     string
}