grpc

Documentation

Index

• type TreeServer
  • func NewSharedTreeServer(resolver *source.Resolver[*object.DataSource]) *TreeServer
  • func NewTreeServer(ds *object.DataSource) *TreeServer
  • func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)
  • func (s *TreeServer) CloseSession(ctx context.Context, req *tree.CloseSessionRequest) (resp *tree.CloseSessionResponse, err error)
  • func (s *TreeServer) CreateNode(ctx context.Context, req *tree.CreateNodeRequest) (resp *tree.CreateNodeResponse, err error)
  • func (s *TreeServer) CreateNodeStream(stream tree.NodeReceiverStream_CreateNodeStreamServer) error
  • func (s *TreeServer) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest) (resp *tree.DeleteNodeResponse, err error)
  • func (s *TreeServer) DeleteNodeStream(stream tree.NodeReceiverStream_DeleteNodeStreamServer) error
  • func (s *TreeServer) FlushSession(ctx context.Context, req *tree.FlushSessionRequest) (resp *tree.FlushSessionResponse, err error)
  • func (s *TreeServer) ListNodes(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)
  • func (s *TreeServer) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (resp *service.ModifyLoginResponse, err error)
  • func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest) (resp *tree.OpenSessionResponse, err error)
  • func (s *TreeServer) ReadNode(ctx context.Context, req *tree.ReadNodeRequest) (resp *tree.ReadNodeResponse, err error)
  • func (s *TreeServer) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error
  • func (s *TreeServer) Ready(ctx context.Context, req *server.ReadyCheckRequest) (*server.ReadyCheckResponse, error)
  • func (s *TreeServer) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)
  • func (s *TreeServer) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest) (resp *tree.UpdateNodeResponse, err error)
  • func (s *TreeServer) UpdateNodeStream(stream tree.NodeReceiverStream_UpdateNodeStreamServer) error
  • func (s *TreeServer) UpdateParentsAndNotify(ctx context.Context, dao index.DAO, deltaSize int64, ...) error

Types

type TreeServer

type TreeServer struct {
	*source.Resolver[*object.DataSource]
	grpc_health_v1.HealthServer
	tree.UnimplementedNodeReceiverServer

	tree.UnimplementedNodeProviderServer
	tree.UnimplementedNodeReceiverStreamServer
	tree.UnimplementedNodeProviderStreamerServer
	tree.UnimplementedSessionIndexerServer
	object.UnimplementedResourceCleanerEndpointServer
	sync.UnimplementedSyncEndpointServer
	server.UnimplementedReadyzServer
	// contains filtered or unexported fields
}

TreeServer definition.

func NewSharedTreeServer

func NewSharedTreeServer(resolver *source.Resolver[*object.DataSource]) *TreeServer

func NewTreeServer

func NewTreeServer(ds *object.DataSource) *TreeServer

NewTreeServer factory.

func (*TreeServer) CleanResourcesBeforeDelete

func (s *TreeServer) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)

CleanResourcesBeforeDelete ensure all resources are cleaned before deleting.

func (*TreeServer) CloseSession

func (s *TreeServer) CloseSession(ctx context.Context, req *tree.CloseSessionRequest) (resp *tree.CloseSessionResponse, err error)

CloseSession closes an indexer session.

func (*TreeServer) CreateNode

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

CreateNode implementation for the TreeServer.

func (*TreeServer) CreateNodeStream

func (s *TreeServer) CreateNodeStream(stream tree.NodeReceiverStream_CreateNodeStreamServer) error

CreateNodeStream implementation for the TreeServer.

func (*TreeServer) DeleteNode

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

DeleteNode implementation for the TreeServer.

func (*TreeServer) DeleteNodeStream

func (s *TreeServer) DeleteNodeStream(stream tree.NodeReceiverStream_DeleteNodeStreamServer) error

DeleteNodeStream implements the streaming version of DeleteNode for the TreeServer

func (*TreeServer) FlushSession

func (s *TreeServer) FlushSession(ctx context.Context, req *tree.FlushSessionRequest) (resp *tree.FlushSessionResponse, err error)

FlushSession allows to flsuh what's in the dao cache for the current session to ensure we are up to date moving on to the next phase of the indexation.

func (*TreeServer) ListNodes

func (s *TreeServer) ListNodes(req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesServer) (err error)

ListNodes implementation for the TreeServer.

func (*TreeServer) ModifyLogin

func (s *TreeServer) ModifyLogin(ctx context.Context, req *service.ModifyLoginRequest) (resp *service.ModifyLoginResponse, err error)

func (*TreeServer) OpenSession

func (s *TreeServer) OpenSession(ctx context.Context, req *tree.OpenSessionRequest) (resp *tree.OpenSessionResponse, err error)

OpenSession opens an indexer session.

func (*TreeServer) ReadNode

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

ReadNode implementation for the TreeServer.

func (*TreeServer) ReadNodeStream

func (s *TreeServer) ReadNodeStream(stream tree.NodeProviderStreamer_ReadNodeStreamServer) error

ReadNodeStream implements the streaming version of ReadNode for the TreeServer

func (*TreeServer) Ready

func (s *TreeServer) Ready(ctx context.Context, req *server.ReadyCheckRequest) (*server.ReadyCheckResponse, error)

Ready implements ReadyzServer.Ready by adding a stat on the index root node

func (*TreeServer) TriggerResync

func (s *TreeServer) TriggerResync(ctx context.Context, request *sync.ResyncRequest) (*sync.ResyncResponse, error)

TriggerResync on index performs a Lost+Found request to auto-heal indexation errors, whenever possible

func (*TreeServer) UpdateNode

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

UpdateNode implementation for the TreeServer.

func (*TreeServer) UpdateNodeStream

func (s *TreeServer) UpdateNodeStream(stream tree.NodeReceiverStream_UpdateNodeStreamServer) error

UpdateNodeStream implements the streaming version of UpdateNode for the TreeServer

func (*TreeServer) UpdateParentsAndNotify

func (s *TreeServer) UpdateParentsAndNotify(ctx context.Context, dao index.DAO, deltaSize int64, eventType tree.NodeChangeEvent_EventType, sourceNode tree.ITreeNode, targetNode tree.ITreeNode, sessionUuid string) error

UpdateParentsAndNotify update the parents nodes and notify the tree of the event that occurred.