grpc

package
v3.0.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Nov 26, 2021 License: AGPL-3.0 Imports: 44 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 FlatSnapshot

type FlatSnapshot struct {
	*snapshot.BoltSnapshot
	// contains filtered or unexported fields
}

FlatSnapshot is a composed sync endpoint combining a BoltDB and S3 client.

func (*FlatSnapshot) Close

func (f *FlatSnapshot) Close(delete ...bool) error

func (*FlatSnapshot) GetEndpointInfo

func (f *FlatSnapshot) GetEndpointInfo() model.EndpointInfo

func (*FlatSnapshot) Walk

func (f *FlatSnapshot) Walk(walknFc model.WalkNodesFunc, root string, recursive bool) (err error)

type Handler

type Handler struct {
	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) FlatScanEmpty

func (s *Handler) FlatScanEmpty(ctx context.Context, syncStatus chan model.Status, syncDone chan interface{}) (model.Stater, error)

FlatScanEmpty uses s3 client to feed index from bucket (basic mono-directional sync)

func (*Handler) FlatSyncSnapshot

func (s *Handler) FlatSyncSnapshot(ctx context.Context, mode string, snapName string, syncStatus chan model.Status, syncDone chan interface{}) (model.Stater, error)

FlatSyncSnapshot can read or write a snapshot of the index inside the storage

func (*Handler) GetDataSourceConfig

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

GetDataSourceConfig 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) StartConfigsOnly

func (s *Handler) StartConfigsOnly()

func (*Handler) Stop added in v1.2.4

func (s *Handler) Stop()

func (*Handler) StopConfigsOnly

func (s *Handler) StopConfigsOnly()

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