Documentation
¶
Overview ¶
Package grpc is a pydio service running synchronization between objects and index.
Index ¶
- func WithStorage(source string) service.ServiceOption
- type Handler
- 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) 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) Stop()
- func (s *Handler) TriggerResync(c context.Context, req *protosync.ResyncRequest, ...) error
- func (s *Handler) UpdateNode(ctx context.Context, req *tree.UpdateNodeRequest, ...) error
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.5
func (*Handler) BroadcastCloseSession ¶ added in v1.5.0
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 ¶
func (s *Handler) ListNodes(ctx context.Context, req *tree.ListNodesRequest, resp tree.NodeProvider_ListNodesStream) error
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
Source Files
¶
- handler-node.go
- handler.go
- plugins.go
Click to show internal directories.
Click to hide internal directories.