grpc

Documentation

Overview

Package grpc provides a GRPC service for aggregating all indexes from all datasources

Index

• type DataSource
• type EventSubscriber
  • func (s *EventSubscriber) Handle(ctx context.Context, msg *tree.NodeChangeEvent) error
• type TreeServer
  • 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

Types

type DataSource

type DataSource struct {
	Name string
	// contains filtered or unexported fields
}

type EventSubscriber

type EventSubscriber struct {
	TreeServer  *TreeServer
	EventClient client.Client
}

func (*EventSubscriber) Handle

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

Handle incoming INDEX events and resend them as TREE events

type TreeServer

type TreeServer struct {
	DataSources map[string]DataSource

	ConfigsMutex *sync.Mutex
	// contains filtered or unexported fields
}

func (*TreeServer) CreateNode

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

CreateNode implementation for the TreeServer

func (*TreeServer) DeleteNode

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

DeleteNode implementation for the TreeServer

func (*TreeServer) ListNodes

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

func (*TreeServer) ListNodesWithLimit

func (s *TreeServer) ListNodesWithLimit(ctx context.Context, req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesStream, cursorIndex *int64, numberSent *int64) error

ListNodesWithLimit implementation for the TreeServer

func (*TreeServer) ReadNode

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

ReadNode implementation for the TreeServer

func (*TreeServer) UpdateNode

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

UpdateNode implementation for the TreeServer