grpc

package
v2.1.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 1, 2020 License: AGPL-3.0 Imports: 38 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

func WithStorage

func WithStorage(source string) service.ServiceOption

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