grpc

package
v1.2.2 Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2018 License: AGPL-3.0 Imports: 29 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     synccommon.PathSyncTarget
	SyncTask     *task.Sync
	SyncConfig   *object.DataSource
	ObjectConfig *object.MinioConfig
}

Handler structure

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) ReadNode

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

ReadNode Forwards to Index

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