sxutil

package module

Go to main page

Versions in this module

v0

v0.7.0

Jul 4, 2021

Changes in this version

type SXSynerexClient

+ GrpcConn *grpc.ClientConn

v0.6.8

Jul 2, 2021

v0.6.7

May 29, 2021

v0.6.6

May 18, 2021

v0.6.5

Mar 16, 2021

v0.6.4

Mar 16, 2021

v0.6.3

Feb 19, 2021

v0.6.2

Nov 7, 2020

Changes in this version

type SXServiceClient

+ func (clt *SXServiceClient) MbusIndex(id uint64) int

v0.6.1

Oct 2, 2020

Changes in this version

+ const MSG_TIME_OUT

+ const RECONNECT_WAIT

v0.6.0

Sep 30, 2020

Changes in this version

type SXServiceClient

+ MbusIDs []IDType

v0.5.4

Sep 29, 2020

v0.5.3

Sep 28, 2020

v0.5.2

Sep 18, 2020

v0.5.1

Sep 18, 2020

Changes in this version

+ func CombinedSubscribeDemand(client *SXServiceClient, ndcb func(*SXServiceClient, *api.Demand), ...) (*sync.Mutex, *bool)

+ func RegisterDemandHandler(client *SXServiceClient, dh DemandHandler) (*sync.Mutex, *bool)

+ type DemandHandler interface

+ OnConfirmResponse func(*SXServiceClient, IDType, error)

+ OnNotifyDemand func(*SXServiceClient, *api.Demand) *SupplyOpts

+ OnSelectSupply func(*SXServiceClient, *api.Demand) bool

type SXServiceClient

+ func (clt *SXServiceClient) ProposeDemand(dmo *DemandOpts) uint64

+ type SupplyHandler interface

v0.5.0

Sep 12, 2020

Changes in this version

+ func SimpleSubscribeDemand(client *SXServiceClient, dmcb func(*SXServiceClient, *api.Demand)) (*sync.Mutex, *bool)

+ func SimpleSubscribeSupply(client *SXServiceClient, spcb func(*SXServiceClient, *api.Supply)) (*sync.Mutex, *bool)

+ func SubscribeDemand(client *SXServiceClient, dmcb func(*SXServiceClient, *api.Demand), ...)

+ func SubscribeSupply(client *SXServiceClient, spcb func(*SXServiceClient, *api.Supply), ...)

type SXServiceClient

+ SXClient *SXSynerexClient

+ type SXSynerexClient struct

+ Client api.SynerexClient

+ ServerAddress string

v0.4.12

Jul 22, 2020

Changes in this version

type SXServiceClient

+ func (clt *SXServiceClient) CreateMbus(ctx context.Context, opt *api.MbusOpt) (*api.Mbus, error)

+ func (clt *SXServiceClient) GetMbusStatus(ctx context.Context, mb *api.Mbus) (*api.MbusState, error)

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

v0.4.11

Jun 12, 2020

v0.4.10

Apr 22, 2020

v0.4.9

Mar 14, 2020

v0.4.8

Mar 14, 2020

Changes in this version

+ var BuildTime string

+ var GitVer string

+ var Sha1Ver string

v0.4.7

Jan 13, 2020

Changes in this version

+ type NodeServInfo struct

+ func GetDefaultNodeServInfo() *NodeServInfo

+ func NewNodeServInfo() *NodeServInfo

+ func (ni *NodeServInfo) GenerateIntID() uint64

+ func (ni *NodeServInfo) GetNodeName(n int) string

+ func (ni *NodeServInfo) MsgCountUp()

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

+ func (ni *NodeServInfo) RegisterNodeWithCmd(nodesrv string, nm string, channels []uint32, serv *SxServerOpt, ...) (string, error)

+ func (ni *NodeServInfo) SetNodeStatus(status int32, arg string)

+ func (ni *NodeServInfo) UnRegisterNode()

type SXServiceClient

+ NI *NodeServInfo

v0.4.6

Jan 13, 2020

v0.4.5

Jan 13, 2020

v0.4.4

Jan 13, 2020

v0.4.3

Jan 12, 2020

v0.4.2

Jan 12, 2020

Changes in this version

+ func RegisterNodeWithCmd(nodesrv string, nm string, channels []uint32, serv *SxServerOpt, ...) (string, error)

v0.4.1

Jan 12, 2020

v0.3.14

Jan 6, 2020

v0.3.13

Dec 25, 2019

v0.3.12

Dec 16, 2019

Changes in this version

+ const WAIT_TIME

+ func RegisterNodeAndProc(nodesrv string, nm string, channels []uint32, serv *SxServerOpt, fn func()) (string, error)

+ type NodeState struct

+ Locked bool

+ ProposedDemand []api.Demand

+ ProposedSupply []api.Supply

+ func NewNodeState() *NodeState

v0.3.11

Nov 23, 2019

v0.3.10

Oct 30, 2019

Changes in this version

type SxServerOpt

+ GwInfo string

v0.3.9

Oct 28, 2019

Changes in this version

+ func MsgCountUp()

v0.3.7

Sep 25, 2019

v0.3.6

Oct 28, 2019

v0.3.5

Sep 25, 2019

Changes in this version

type SxServerOpt

+ NodeType nodeapi.NodeType

+ ServerInfo string

v0.3.4

Sep 25, 2019

Changes in this version

+ func GrpcConnectServer(serverAddress string) api.SynerexClient

v0.3.3

Sep 25, 2019

Changes in this version

+ type SXServiceClient struct

+ ArgJson string

+ ChannelType uint32

+ Client api.SynerexClient

+ ClientID IDType

+ MbusID IDType

+ 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

v0.3.2

Sep 22, 2019

v0.3.1

Sep 22, 2019

v0.2.2

Sep 22, 2019

v0.2.1

Sep 22, 2019

Changes in this version

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

+ type SxServerOpt struct

+ AreaId string

+ ClusterId int32

+ ServerAddress string

v0.1.3

Sep 22, 2019

v0.1.2

Sep 22, 2019

v0.1.1

Sep 22, 2019

v0.0.2

Sep 21, 2019

Changes in this version

+ func CallDeferFunctions()

+ func HandleSigInt()

+ func RegisterDeferFunction(f func())

type DemandOpts

+ Cdata *api.Content

type SupplyOpts

+ Cdata *api.Content

v0.0.1

Sep 21, 2019

Changes in this version

+ func GenerateIntID() uint64

+ func GetNodeName(n int) string

+ func InitNodeNum(n int)

+ func RegisterNodeName(nodesrv string, nm string, isServ bool) error

+ func SetNodeStatus(status int32, arg string)

+ func UnRegisterNode()

+ type DemandOpts struct

+ ID uint64

+ JSON string

+ Name string

+ Target uint64

+ type IDType uint64

+ type SMServiceClient struct

+ ArgJson string

+ ChannelType uint32

+ Client api.SynerexClient

+ ClientID IDType

+ MbusID IDType

+ func NewSMServiceClient(clt api.SynerexClient, mtype uint32, argJson string) *SMServiceClient

+ func (clt *SMServiceClient) CloseMbus(ctx context.Context) error

+ func (clt *SMServiceClient) Confirm(id IDType) error

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

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

+ func (clt *SMServiceClient) NotifyDemand(dmo *DemandOpts) uint64

+ func (clt *SMServiceClient) NotifySupply(smo *SupplyOpts) uint64

+ func (clt *SMServiceClient) ProposeSupply(spo *SupplyOpts) uint64

+ func (clt *SMServiceClient) SelectDemand(dm *api.Demand) error

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

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

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

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

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

+ type SupplyOpts struct

+ ID uint64

+ JSON string

+ Name string

+ Target uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL