Documentation ¶
Index ¶
- Constants
- func BytesToString(b []byte) string
- func CreateComponentSubject(workspaceID, componentName string) string
- func GetCallbackSubject() (string, error)
- func GetComponentApi(c m.Component) (*module.Component, error)
- func GetComponentLookupSubject(workspaceID string) string
- func GetEnvironmentName() string
- func GetFlowLookupSubject(workspaceID string) string
- func GetInstanceControlSubject(workspaceID, flowID string, ID string, port string) string
- func GetInstanceInputSubject(workspaceID, flowID string, ID string, port string) string
- func GetModuleApi(i m.Info) (*module.ModuleVersion, error)
- func GetNodeStatsLookupSubject(flowID string) string
- func GetNodesLookupSubject(flowID string) string
- func GetPortFullName(nodeID string, portName string) string
- func GetServerLookupSubject(workspaceID string) string
- func NodeToMap(n *module.Node, data map[string]interface{}) map[string]interface{}
Constants ¶
View Source
const DefaultEnvironment = "local"
View Source
const StreamName = "tiny"
Variables ¶
This section is empty.
Functions ¶
func BytesToString ¶
func CreateComponentSubject ¶
func GetCallbackSubject ¶ added in v0.0.4
func GetComponentApi ¶
func GetComponentLookupSubject ¶ added in v0.0.4
func GetEnvironmentName ¶
func GetEnvironmentName() string
func GetFlowLookupSubject ¶ added in v0.0.4
func GetInstanceControlSubject ¶ added in v0.0.7
func GetInstanceInputSubject ¶
func GetModuleApi ¶
func GetNodeStatsLookupSubject ¶ added in v0.0.5
func GetNodesLookupSubject ¶ added in v0.0.4
func GetPortFullName ¶
func GetServerLookupSubject ¶ added in v0.0.4
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.