grpc

package
v2.0.0-rc3+incompatible Latest Latest
Warning

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

Go to latest
Published: Nov 5, 2019 License: AGPL-3.0 Imports: 37 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handler

type Handler struct {
	IndexClient tree.NodeProviderClient
	S3client    model.PathSyncTarget

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

Handler structure

func NewHandler added in v1.2.4

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

func (*Handler) BroadcastCloseSession added in v1.5.0

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

ListNodes Forward to index

func (*Handler) NotifyError added in v1.5.0

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 added in v1.2.4

func (s *Handler) Start()

func (*Handler) Stop added in v1.2.4

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

Jump to

Keyboard shortcuts

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