grpc

Documentation

Overview

Package grpc is a pydio service running synchronization between objects and index.

Index

• func WithStorage(source string) service.ServiceOption
• type Handler
  • func NewHandler(ctx context.Context, datasource string) (*Handler, error)
  • func (s *Handler) BroadcastCloseSession(sessionUuid string)
  • func (s *Handler) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest, ...) error
  • func (s *Handler) CreateNode(ctx context.Context, req *tree.CreateNodeRequest, ...) error
  • func (s *Handler) DeleteNode(ctx context.Context, req *tree.DeleteNodeRequest, ...) error
  • func (s *Handler) GetDataSourceConfig(ctx context.Context, request *object.GetDataSourceConfigRequest, ...) error
  • func (s *Handler) ListNodes(ctx context.Context, req *tree.ListNodesRequest, ...) error
  • func (s *Handler) NotifyError(errorPath string)
  • func (s *Handler) ReadNode(ctx context.Context, req *tree.ReadNodeRequest, resp *tree.ReadNodeResponse) error
  • func (s *Handler) Start()
  • func (s *Handler) Stop()
  • func (s *Handler) TriggerResync(c context.Context, req *protosync.ResyncRequest, ...) error
  • func (s *Handler) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, ...) error

Functions

func WithStorage

func WithStorage(source string) service.ServiceOption

Types

type Handler

type Handler struct {
	IndexClient      tree.NodeProviderClient
	IndexCleanClient protosync.SyncEndpointClient
	S3client         model.PathSyncTarget

	SyncConfig   *object.DataSource
	ObjectConfig *object.MinioConfig
	// contains filtered or unexported fields
}

Handler structure

func NewHandler

func NewHandler(ctx context.Context, datasource string) (*Handler, error)

func (*Handler) BroadcastCloseSession

func (s *Handler) BroadcastCloseSession(sessionUuid string)

BroadcastCloseSession forwards session id to underlying sync task

func (*Handler) CleanResourcesBeforeDelete

func (s *Handler) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest, response *object.CleanResourcesResponse) error

CleanResourcesBeforeDelete gracefully stops the sync task and remove the associated resync job

func (*Handler) CreateNode

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

CreateNode Forwards to Index

func (*Handler) DeleteNode

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

DeleteNode Forwards to S3

func (*Handler) GetDataSourceConfig

func (s *Handler) GetDataSourceConfig(ctx context.Context, request *object.GetDataSourceConfigRequest, response *object.GetDataSourceConfigResponse) error

Implements the S3Endpoint Interface by using the real object configs + the local datasource configs for bucket and base folder

func (*Handler) ListNodes

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

ListNodes Forward to index

func (*Handler) NotifyError

func (s *Handler) NotifyError(errorPath string)

func (*Handler) ReadNode

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

ReadNode Forwards to Index

func (*Handler) Start

func (s *Handler) Start()

func (*Handler) Stop

func (s *Handler) Stop()

func (*Handler) TriggerResync

func (s *Handler) TriggerResync(c context.Context, req *protosync.ResyncRequest, resp *protosync.ResyncResponse) error

TriggerResync sets 2 servers in sync

func (*Handler) UpdateNode

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

UpdateNode Forwards to S3