objects

Documentation

Overview

Package objects is in charge of exposing the content of the datasource with the S3 protocol.

Index

• Variables
• func CreateMinioConfigFile(serviceId string, accessKey string, secretKey string) (configDir string, err error)
• func DeleteMinioConfigDir(serviceId string) error
• type TreeHandler
  • func NewTreeHandler(conf common.ConfigValues) *TreeHandler
  • func (t *TreeHandler) CreateNode(ctx context.Context, request *tree.CreateNodeRequest, ...) error
  • func (t *TreeHandler) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest, ...) error
  • func (t *TreeHandler) FileInfoToNode(nodePath string, fileInfo os.FileInfo) *tree.Node
  • func (t *TreeHandler) ListNodes(ctx context.Context, request *tree.ListNodesRequest, ...) error
  • func (t *TreeHandler) ReadNode(ctx context.Context, request *tree.ReadNodeRequest, ...) error
  • func (t *TreeHandler) SymlinkInfo(path string, info os.FileInfo) (bool, tree.NodeType, string)
  • func (t *TreeHandler) UpdateNode(ctx context.Context, request *tree.UpdateNodeRequest, ...) error

Variables

var (
	Name        = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_OBJECTS
	ChildPrefix = common.SERVICE_GRPC_NAMESPACE_ + common.SERVICE_DATA_OBJECTS_
)

Functions

func CreateMinioConfigFile

func CreateMinioConfigFile(serviceId string, accessKey string, secretKey string) (configDir string, err error)

func DeleteMinioConfigDir

func DeleteMinioConfigDir(serviceId string) error

Types

type TreeHandler

type TreeHandler struct {
	FS afero.Fs
	// contains filtered or unexported fields
}

func NewTreeHandler

func NewTreeHandler(conf common.ConfigValues) *TreeHandler

func (*TreeHandler) CreateNode

func (t *TreeHandler) CreateNode(ctx context.Context, request *tree.CreateNodeRequest, response *tree.CreateNodeResponse) error

func (*TreeHandler) DeleteNode

func (t *TreeHandler) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest, response *tree.DeleteNodeResponse) error

func (*TreeHandler) FileInfoToNode

func (t *TreeHandler) FileInfoToNode(nodePath string, fileInfo os.FileInfo) *tree.Node

func (*TreeHandler) ListNodes

func (t *TreeHandler) ListNodes(ctx context.Context, request *tree.ListNodesRequest, stream tree.NodeProvider_ListNodesStream) error

func (*TreeHandler) ReadNode

func (t *TreeHandler) ReadNode(ctx context.Context, request *tree.ReadNodeRequest, response *tree.ReadNodeResponse) error

func (*TreeHandler) SymlinkInfo

func (t *TreeHandler) SymlinkInfo(path string, info os.FileInfo) (bool, tree.NodeType, string)

func (*TreeHandler) UpdateNode

func (t *TreeHandler) UpdateNode(ctx context.Context, request *tree.UpdateNodeRequest, response *tree.UpdateNodeResponse) error