Documentation ¶
Index ¶
- Variables
- func NodeData(nodeId string) *resource.Node
- func NodeState(nodeId string) *resource.State
- type DatahubServer
- func (t *DatahubServer) GetResource(key resource.Key) (*resource.Resource, error)
- func (t *DatahubServer) Handle(function string, payload []byte) ([]byte, error)
- func (t *DatahubServer) Init() error
- func (t *DatahubServer) ListResource(key resource.Key) ([]*resource.Resource, error)
- func (t *DatahubServer) Save(kind *resource.Kind, data []byte) error
- func (t *DatahubServer) Serve() error
- func (t *DatahubServer) Start() error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ResourceDirs = map[*resource.Kind]string{ resource.KindProduct: "etc/products/", resource.KindProtocol: "etc/protocols/", resource.KindWidget: "etc/widgets/", } )
Functions ¶
Types ¶
type DatahubServer ¶
func NewDatahubServer ¶
func NewDatahubServer(config conf.DatahubConfig) *DatahubServer
func (*DatahubServer) GetResource ¶
func (*DatahubServer) Handle ¶
func (t *DatahubServer) Handle(function string, payload []byte) ([]byte, error)
func (*DatahubServer) Init ¶
func (t *DatahubServer) Init() error
func (*DatahubServer) ListResource ¶
func (*DatahubServer) Serve ¶
func (t *DatahubServer) Serve() error
LOOP: keep handling incoming resource events
func (*DatahubServer) Start ¶
func (t *DatahubServer) Start() error
Click to show internal directories.
Click to hide internal directories.