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 configx.Values) *TreeHandler
  • func (t *TreeHandler) CreateNode(ctx context.Context, request *tree.CreateNodeRequest) (*tree.CreateNodeResponse, error)
  • func (t *TreeHandler) DeleteNode(ctx context.Context, request *tree.DeleteNodeRequest) (*tree.DeleteNodeResponse, error)
  • func (t *TreeHandler) FileInfoToNode(nodePath string, fileInfo os.FileInfo) *tree.Node
  • func (t *TreeHandler) ListNodes(request *tree.ListNodesRequest, stream tree.NodeProvider_ListNodesServer) error
  • func (t *TreeHandler) Name() string
  • func (t *TreeHandler) ReadNode(ctx context.Context, request *tree.ReadNodeRequest) (*tree.ReadNodeResponse, error)
  • func (t *TreeHandler) SymlinkInfo(path string, info os.FileInfo) (bool, tree.NodeType, string)
  • func (t *TreeHandler) UpdateNode(ctx context.Context, request *tree.UpdateNodeRequest) (*tree.UpdateNodeResponse, error)

Variables

var (
	Name        = common.ServiceGrpcNamespace_ + common.ServiceDataObjects
	BrowserName = common.ServiceGrpcNamespace_ + common.ServiceDataObjectsPeer
	ChildPrefix = common.ServiceGrpcNamespace_ + common.ServiceDataObjects_
)

Functions

func CreateMinioConfigFile

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

CreateMinioConfigFile generates a legacy config file

func DeleteMinioConfigDir

func DeleteMinioConfigDir(serviceId string) error

Types

type TreeHandler

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

func NewTreeHandler

func NewTreeHandler(conf configx.Values) *TreeHandler

func (*TreeHandler) CreateNode

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

func (*TreeHandler) DeleteNode

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

func (*TreeHandler) FileInfoToNode

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

func (*TreeHandler) ListNodes

func (t *TreeHandler) ListNodes(request *tree.ListNodesRequest, stream tree.NodeProvider_ListNodesServer) error

func (*TreeHandler) Name

func (t *TreeHandler) Name() string

func (*TreeHandler) ReadNode

func (t *TreeHandler) ReadNode(ctx context.Context, request *tree.ReadNodeRequest) (*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) (*tree.UpdateNodeResponse, error)