client

package module
v0.0.0-...-e2be02a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2021 License: GPL-3.0 Imports: 17 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	ExecOK              = "OK"
	ExecFailed          = "FAIL"
	ContentTypeProtobuf = "application/x-protobuf"
	ContentTypeJson     = "application/json"
)

Variables

View Source 
var Log = m3util.NewLogger("client", m3util.INFO)

Functions

This section is empty.

Types

type ClientConnection 

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

func (*ClientConnection) CheckServerUp 

func (cl *ClientConnection) CheckServerUp() bool

func (*ClientConnection) ExecReq 

func (cl *ClientConnection) ExecReq(method string, uri string, reqMsg proto.Message, respMsg proto.Message, useQueryParams bool) (string, error)

type ClientPathNodeMap 

type ClientPathNodeMap interface {
	Size() int
	GetPathNodeById(id m3point.Int64Id) *PathNodeCl
	GetPathNode(p m3point.Point) *PathNodeCl
	AddPathNode(pathNode *PathNodeCl) (*PathNodeCl, bool)
	Clear()
	RangePerId(visit func(id m3point.Int64Id, pn *PathNodeCl) bool, rc *m3point.RangeContext)
	RangePerPoint(visit func(point m3point.Point, pn *PathNodeCl) bool, rc *m3point.RangeContext)
}

func MakeHashPathNodeMap 

func MakeHashPathNodeMap(initSize int) ClientPathNodeMap

type ClientPathPackData 

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

func GetClientPathPackData 

func GetClientPathPackData(env m3util.QsmEnvironment) *ClientPathPackData

func (*ClientPathPackData) GetEnvId 

func (pathData *ClientPathPackData) GetEnvId() m3util.QsmEnvID

func (*ClientPathPackData) GetPathCtx 

func (pathData *ClientPathPackData) GetPathCtx(id m3path.PathContextId) m3path.PathContext

func (*ClientPathPackData) GetPathCtxFromAttributes 

func (pathData *ClientPathPackData) GetPathCtxFromAttributes(growthType m3point.GrowthType, growthIndex int, offset int) (m3path.PathContext, error)

type ClientPointHashPathNodeMap 

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

func (*ClientPointHashPathNodeMap) AddPathNode 

func (hnm *ClientPointHashPathNodeMap) AddPathNode(pathNode *PathNodeCl) (*PathNodeCl, bool)

func (*ClientPointHashPathNodeMap) Clear 

func (hnm *ClientPointHashPathNodeMap) Clear()

func (*ClientPointHashPathNodeMap) GetPathNode 

func (hnm *ClientPointHashPathNodeMap) GetPathNode(p m3point.Point) *PathNodeCl

func (*ClientPointHashPathNodeMap) GetPathNodeById 

func (hnm *ClientPointHashPathNodeMap) GetPathNodeById(id m3point.Int64Id) *PathNodeCl

func (*ClientPointHashPathNodeMap) RangePerId 

func (hnm *ClientPointHashPathNodeMap) RangePerId(visit func(id m3point.Int64Id, pn *PathNodeCl) bool, rc *m3point.RangeContext)

func (*ClientPointHashPathNodeMap) RangePerPoint 

func (hnm *ClientPointHashPathNodeMap) RangePerPoint(visit func(point m3point.Point, pn *PathNodeCl) bool, rc *m3point.RangeContext)

func (*ClientPointHashPathNodeMap) Size 

func (hnm *ClientPointHashPathNodeMap) Size() int

type ClientPointPackData 

type ClientPointPackData struct {
	m3point.BasePointPackData

	ValidNextTrio       [12][2]m3point.TrioIndex
	AllMod4Permutations [12][4]m3point.TrioIndex
	AllMod8Permutations [12][8]m3point.TrioIndex
	// contains filtered or unexported fields
}

func GetClientPointPackData 

func GetClientPointPackData(env m3util.QsmEnvironment) *ClientPointPackData

func (*ClientPointPackData) GetAllMod4Permutations 

func (ppd *ClientPointPackData) GetAllMod4Permutations() [12][4]m3point.TrioIndex

func (*ClientPointPackData) GetAllMod8Permutations 

func (ppd *ClientPointPackData) GetAllMod8Permutations() [12][8]m3point.TrioIndex

func (*ClientPointPackData) GetValidNextTrio 

func (ppd *ClientPointPackData) GetValidNextTrio() [12][2]m3point.TrioIndex

type ClientSpacePackData 

type ClientSpacePackData struct {
	Env *QsmApiEnvironment
	// contains filtered or unexported fields
}

func GetClientSpacePackData 

func GetClientSpacePackData(env m3util.QsmEnvironment) *ClientSpacePackData

func (*ClientSpacePackData) CreateSpace 

func (spaceData *ClientSpacePackData) CreateSpace(name string, activePathNodeThreshold m3space.DistAndTime, maxTriosPerPoint int, maxPathNodesPerPoint int) (m3space.SpaceIfc, error)

func (*ClientSpacePackData) DeleteSpace 

func (spaceData *ClientSpacePackData) DeleteSpace(id int, name string) (int, error)

func (*ClientSpacePackData) GetAllSpaces 

func (spaceData *ClientSpacePackData) GetAllSpaces() []m3space.SpaceIfc

func (*ClientSpacePackData) GetEnvId 

func (spaceData *ClientSpacePackData) GetEnvId() m3util.QsmEnvID

func (*ClientSpacePackData) GetSpace 

func (spaceData *ClientSpacePackData) GetSpace(id int) m3space.SpaceIfc

func (*ClientSpacePackData) LoadAllSpaces 

func (spaceData *ClientSpacePackData) LoadAllSpaces() error

type EventCl 

type EventCl struct {
	CreationTime m3space.DistAndTime

	CenterNode *EventNodeCl

	// The biggest creation time of event node db
	MaxNodeTime m3space.DistAndTime
	// contains filtered or unexported fields
}

func (*EventCl) GetActiveNodesAt 

func (evt *EventCl) GetActiveNodesAt(currentTime m3space.DistAndTime) ([]m3space.NodeEventIfc, error)

func (*EventCl) GetCenterNode 

func (evt *EventCl) GetCenterNode() m3space.NodeEventIfc

func (*EventCl) GetColor 

func (evt *EventCl) GetColor() m3space.EventColor

func (*EventCl) GetCreationTime 

func (evt *EventCl) GetCreationTime() m3space.DistAndTime

func (*EventCl) GetId 

func (evt *EventCl) GetId() m3space.EventId

func (*EventCl) GetPathContext 

func (evt *EventCl) GetPathContext() m3path.PathContext

func (*EventCl) GetSpace 

func (evt *EventCl) GetSpace() m3space.SpaceIfc

func (*EventCl) String 

func (evt *EventCl) String() string

type EventNodeCl 

type EventNodeCl struct {
	Event *EventCl
	// contains filtered or unexported fields
}

func (*EventNodeCl) GetColor 

func (en *EventNodeCl) GetColor() m3space.EventColor

func (*EventNodeCl) GetConnectionState 

func (en *EventNodeCl) GetConnectionState(connIdx int) m3path.ConnectionState

func (*EventNodeCl) GetCreationTime 

func (en *EventNodeCl) GetCreationTime() m3space.DistAndTime

func (*EventNodeCl) GetD 

func (en *EventNodeCl) GetD() m3space.DistAndTime

func (*EventNodeCl) GetEventId 

func (en *EventNodeCl) GetEventId() m3space.EventId

func (*EventNodeCl) GetId 

func (en *EventNodeCl) GetId() m3space.NodeEventId

func (*EventNodeCl) GetPathNode 

func (en *EventNodeCl) GetPathNode() (m3path.PathNode, error)

func (*EventNodeCl) GetPathNodeId 

func (en *EventNodeCl) GetPathNodeId() m3path.PathNodeId

func (*EventNodeCl) GetPoint 

func (en *EventNodeCl) GetPoint() (*m3point.Point, error)

func (*EventNodeCl) GetPointId 

func (en *EventNodeCl) GetPointId() m3path.PointId

func (*EventNodeCl) GetTrioDetails 

func (en *EventNodeCl) GetTrioDetails(pointData m3point.PointPackDataIfc) *m3point.TrioDetails

func (*EventNodeCl) GetTrioIndex 

func (en *EventNodeCl) GetTrioIndex() m3point.TrioIndex

func (*EventNodeCl) HasOpenConnections 

func (en *EventNodeCl) HasOpenConnections() bool

func (*EventNodeCl) IsDeadEnd 

func (en *EventNodeCl) IsDeadEnd(connIdx int) bool

func (*EventNodeCl) IsFrom 

func (en *EventNodeCl) IsFrom(connIdx int) bool

func (*EventNodeCl) IsNext 

func (en *EventNodeCl) IsNext(connIdx int) bool

func (*EventNodeCl) String 

func (en *EventNodeCl) String() string

type PathContextCl 

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

func MakePatchContextClient 

func MakePatchContextClient(pathData *ClientPathPackData, pMsg *m3api.PathContextMsg) *PathContextCl

func (*PathContextCl) CountAllPathNodes 

func (pathCtx *PathContextCl) CountAllPathNodes() int

func (*PathContextCl) DumpInfo 

func (pathCtx *PathContextCl) DumpInfo() string

func (*PathContextCl) GetGrowthCtx 

func (pathCtx *PathContextCl) GetGrowthCtx() m3point.GrowthContext

func (*PathContextCl) GetGrowthIndex 

func (pathCtx *PathContextCl) GetGrowthIndex() int

func (*PathContextCl) GetGrowthOffset 

func (pathCtx *PathContextCl) GetGrowthOffset() int

func (*PathContextCl) GetGrowthType 

func (pathCtx *PathContextCl) GetGrowthType() m3point.GrowthType

func (*PathContextCl) GetId 

func (pathCtx *PathContextCl) GetId() m3path.PathContextId

func (*PathContextCl) GetMaxDist 

func (pathCtx *PathContextCl) GetMaxDist() int

func (*PathContextCl) GetNumberOfNodesAt 

func (pathCtx *PathContextCl) GetNumberOfNodesAt(dist int) int

func (*PathContextCl) GetNumberOfNodesBetween 

func (pathCtx *PathContextCl) GetNumberOfNodesBetween(fromDist int, toDist int) int

func (*PathContextCl) GetPathNodeMap 

func (pathCtx *PathContextCl) GetPathNodeMap() ClientPathNodeMap

func (*PathContextCl) GetPathNodesAt 

func (pathCtx *PathContextCl) GetPathNodesAt(dist int) ([]m3path.PathNode, error)

func (*PathContextCl) GetPathNodesBetween 

func (pathCtx *PathContextCl) GetPathNodesBetween(fromDist, toDist int) ([]m3path.PathNode, error)

func (*PathContextCl) GetRootPathNode 

func (pathCtx *PathContextCl) GetRootPathNode() m3path.PathNode

func (*PathContextCl) RequestNewMaxDist 

func (pathCtx *PathContextCl) RequestNewMaxDist(requestDist int) error

func (*PathContextCl) String 

func (pathCtx *PathContextCl) String() string

type PathNodeCl 

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

func (*PathNodeCl) D 

func (pn *PathNodeCl) D() int

func (*PathNodeCl) GetId 

func (pn *PathNodeCl) GetId() m3path.PathNodeId

func (*PathNodeCl) GetPathContext 

func (pn *PathNodeCl) GetPathContext() m3path.PathContext

func (*PathNodeCl) GetTrioDetails 

func (pn *PathNodeCl) GetTrioDetails(pointData m3point.PointPackDataIfc) *m3point.TrioDetails

func (*PathNodeCl) GetTrioIndex 

func (pn *PathNodeCl) GetTrioIndex() m3point.TrioIndex

func (*PathNodeCl) HasOpenConnections 

func (pn *PathNodeCl) HasOpenConnections() bool

func (*PathNodeCl) IsDeadEnd 

func (pn *PathNodeCl) IsDeadEnd(connIdx int) bool

func (*PathNodeCl) IsFrom 

func (pn *PathNodeCl) IsFrom(connIdx int) bool

func (*PathNodeCl) IsNext 

func (pn *PathNodeCl) IsNext(connIdx int) bool

func (*PathNodeCl) IsRoot 

func (pn *PathNodeCl) IsRoot() bool

func (*PathNodeCl) P 

func (pn *PathNodeCl) P() m3point.Point

func (*PathNodeCl) String 

func (pn *PathNodeCl) String() string

type QsmApiEnvironment 

type QsmApiEnvironment struct {
	m3util.BaseQsmEnvironment
	// contains filtered or unexported fields
}

func GetInitializedApiEnv 

func GetInitializedApiEnv(envId m3util.QsmEnvID) *QsmApiEnvironment

func GetOrCreateInitializedApiEnv 

func GetOrCreateInitializedApiEnv(envId m3util.QsmEnvID, callDrop, callInit bool) *QsmApiEnvironment

func (*QsmApiEnvironment) Close 

func (env *QsmApiEnvironment) Close()

type SpaceCl 

type SpaceCl struct {
	SpaceData *ClientSpacePackData
	// contains filtered or unexported fields
}

func (*SpaceCl) CreateEvent 

func (space *SpaceCl) CreateEvent(growthType m3point.GrowthType, growthIndex int, growthOffset int,
	creationTime m3space.DistAndTime, center m3point.Point, color m3space.EventColor) (m3space.EventIfc, error)

func (*SpaceCl) GetActiveEventsAt 

func (space *SpaceCl) GetActiveEventsAt(atTime m3space.DistAndTime) []m3space.EventIfc

func (*SpaceCl) GetActiveThreshold 

func (space *SpaceCl) GetActiveThreshold() m3space.DistAndTime

func (*SpaceCl) GetEvent 

func (space *SpaceCl) GetEvent(id m3space.EventId) m3space.EventIfc

func (*SpaceCl) GetId 

func (space *SpaceCl) GetId() int

func (*SpaceCl) GetMaxCoord 

func (space *SpaceCl) GetMaxCoord() m3point.CInt

func (*SpaceCl) GetMaxNodesPerPoint 

func (space *SpaceCl) GetMaxNodesPerPoint() int

func (*SpaceCl) GetMaxTime 

func (space *SpaceCl) GetMaxTime() m3space.DistAndTime

func (*SpaceCl) GetMaxTriosPerPoint 

func (space *SpaceCl) GetMaxTriosPerPoint() int

func (*SpaceCl) GetName 

func (space *SpaceCl) GetName() string

func (*SpaceCl) GetSpaceTimeAt 

func (space *SpaceCl) GetSpaceTimeAt(atTime m3space.DistAndTime) m3space.SpaceTimeIfc

func (*SpaceCl) SetMaxCoord 

func (space *SpaceCl) SetMaxCoord(c m3point.CInt)

func (*SpaceCl) SetMaxTime 

func (space *SpaceCl) SetMaxTime(t m3space.DistAndTime)

func (*SpaceCl) String 

func (space *SpaceCl) String() string

func (*SpaceCl) UpdateMax 

func (space *SpaceCl) UpdateMax()

type SpaceTimeCl 

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

func (*SpaceTimeCl) GetActiveEvents 

func (st *SpaceTimeCl) GetActiveEvents() []m3space.EventIfc

func (*SpaceTimeCl) GetCurrentTime 

func (st *SpaceTimeCl) GetCurrentTime() m3space.DistAndTime

func (*SpaceTimeCl) GetDisplayState 

func (st *SpaceTimeCl) GetDisplayState() string
func (st *SpaceTimeCl) GetNbActiveLinks() int

func (*SpaceTimeCl) GetNbActiveNodes 

func (st *SpaceTimeCl) GetNbActiveNodes() int

func (*SpaceTimeCl) GetSpace 

func (st *SpaceTimeCl) GetSpace() m3space.SpaceIfc

func (*SpaceTimeCl) Next 

func (st *SpaceTimeCl) Next() m3space.SpaceTimeIfc

func (*SpaceTimeCl) String 

func (st *SpaceTimeCl) String() string
func (st *SpaceTimeCl) VisitLinks(visitor m3space.SpaceTimeLinkVisitor)

func (*SpaceTimeCl) VisitNodes 

func (st *SpaceTimeCl) VisitNodes(visitor m3space.SpaceTimeNodeVisitor)

type SpaceTimeNodeCl 

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

func (*SpaceTimeNodeCl) GetColorMask 

func (stn *SpaceTimeNodeCl) GetColorMask() uint8

func (*SpaceTimeNodeCl) GetEventIds 

func (stn *SpaceTimeNodeCl) GetEventIds() []m3space.EventId

func (*SpaceTimeNodeCl) GetLastAccessed 

func (stn *SpaceTimeNodeCl) GetLastAccessed() m3space.DistAndTime

func (*SpaceTimeNodeCl) GetPoint 

func (stn *SpaceTimeNodeCl) GetPoint() (*m3point.Point, error)

func (*SpaceTimeNodeCl) GetPointId 

func (stn *SpaceTimeNodeCl) GetPointId() m3path.PointId

func (*SpaceTimeNodeCl) GetSpaceTime 

func (stn *SpaceTimeNodeCl) GetSpaceTime() m3space.SpaceTimeIfc

func (*SpaceTimeNodeCl) GetStateString 

func (stn *SpaceTimeNodeCl) GetStateString() string

func (*SpaceTimeNodeCl) HasRoot 

func (stn *SpaceTimeNodeCl) HasRoot() bool

func (*SpaceTimeNodeCl) HowManyColors 

func (stn *SpaceTimeNodeCl) HowManyColors() uint8

func (*SpaceTimeNodeCl) IsEmpty 

func (stn *SpaceTimeNodeCl) IsEmpty() bool

func (*SpaceTimeNodeCl) VisitConnections 

func (stn *SpaceTimeNodeCl) VisitConnections(visitConn func(evtNode *SpaceTimeNodeEventCl, connIdx int, connId m3point.ConnectionId))

type SpaceTimeNodeEventCl 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.