grpc

Documentation

Overview

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

Index

• func WithStorage(source string) service.ServiceOption
• type FlatSnapshot
  • func (f *FlatSnapshot) Close(delete ...bool) error
  • func (f *FlatSnapshot) GetEndpointInfo() model.EndpointInfo
  • func (f *FlatSnapshot) Walk(walknFc model.WalkNodesFunc, root string, recursive bool) (err error)
• 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) FlatScanEmpty(ctx context.Context, syncStatus chan model.Status, syncDone chan interface{}) (model.Stater, error)
  • func (s *Handler) FlatSyncSnapshot(ctx context.Context, mode string, snapName string, ...) (model.Stater, 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) StartConfigsOnly()
  • func (s *Handler) Stop()
  • func (s *Handler) StopConfigsOnly()
  • 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 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

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

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

func (s *Handler) StartConfigsOnly()

func (*Handler) Stop

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