discovery

Documentation

Index

• Constants
• type Action
• type Node
  • func (n *Node) FullID() string
• type NodeState
• type Request
• type Response

Constants

const (
	DefaultPublishPrefix   = "node.publish"
	DefaultDiscoveryPrefix = "node.discovery"

	DefaultLivecycle = 2 * time.Second
	DefaultExpire    = 5 * time.Second
)

Types

type Action

type Action string

const (
	SaveAction   Action = "save"
	UpdateAction Action = "update"
	DeleteAction Action = "delete"
)

type Node

type Node struct {
	ID string
	//
	Component *module.Component //optional

	Module *module.ModuleVersion
	// How node looks like
	Graph *structpb.Struct
	// Realtime stats
	Stats       *structpb.Struct
	WorkspaceID string
	// which server is running the node
	ServerID string

	FlowID *string // optional
}

Node represents a node info

func (*Node) FullID

func (n *Node) FullID() string

FullID return the node id with scheme prefix

type NodeState

type NodeState int32

NodeState define the node state type

type Request

type Request struct {
	Action Action
	Node   Node
}

type Response

type Response struct {
	Success bool
	Reason  string
}