grpc

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 7, 2018 License: AGPL-3.0 Imports: 16 Imported by: 9

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

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 (*TreeServer) ListNodesWithLimit

func (s *TreeServer) ListNodesWithLimit(ctx context.Context, req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesStream, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL