grpc

May 7, 2019

Changes in this version

+ type StreamConverter struct

+ func (sc *StreamConverter) Close() error

+ func (sc *StreamConverter) RecvMsg(i interface{}) error

+ func (sc *StreamConverter) Send(response *tree.ListNodesResponse) error

+ func (sc *StreamConverter) SendMsg(i interface{}) error

type TreeServer

+ func (s *TreeServer) Search(ctx context.Context, request *tree.SearchRequest, ...) error

Apr 24, 2018

Changes in this version

+ type DataSource struct

+ Name string

+ type EventSubscriber struct

+ EventClient client.Client

+ TreeServer *TreeServer

+ func (s *EventSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error

+ type TreeServer struct

+ ConfigsMutex *sync.Mutex

+ DataSources map[string]DataSource

+ func (s *TreeServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, ...) error

+ func (s *TreeServer) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest, ...) error

+ func (s *TreeServer) ListNodes(ctx context.Context, req *tree.ListNodesRequest, ...) error

+ func (s *TreeServer) ListNodesWithLimit(ctx context.Context, req *tree.ListNodesRequest, ...) error

+ func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) error

+ func (s *TreeServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, ...) error