metadata

Jan 10, 2022

Changes in this version

+ const PluginName

+ var ErrNoSuchObject = errors.New("no such object")

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ type GRPCClient struct

+ func (c *GRPCClient) GetFolders(storageID string, limit int, from string) ([]string, error)

+ func (c *GRPCClient) GetModificationTime(storageID, objectPath string) (int64, error)

+ func (c *GRPCClient) GetModificationTimes(storageID, objectPath string) (map[string]int64, error)

+ func (c *GRPCClient) RemoveMetadata(storageID, objectPath string) error

+ func (c *GRPCClient) SetModificationTime(storageID, objectPath string, mTime int64) error

+ type GRPCServer struct

+ Impl Metadater

+ func (s *GRPCServer) GetFolders(ctx context.Context, req *proto.GetFoldersRequest) (*proto.GetFoldersResponse, error)

+ func (s *GRPCServer) GetModificationTime(ctx context.Context, req *proto.GetModificationTimeRequest) (*proto.GetModificationTimeResponse, error)

+ func (s *GRPCServer) GetModificationTimes(ctx context.Context, req *proto.GetModificationTimesRequest) (*proto.GetModificationTimesResponse, error)

+ func (s *GRPCServer) RemoveMetadata(ctx context.Context, req *proto.RemoveMetadataRequest) (*emptypb.Empty, error)

+ func (s *GRPCServer) SetModificationTime(ctx context.Context, req *proto.SetModificationTimeRequest) (*emptypb.Empty, error)

+ type Metadater interface

+ GetFolders func(storageID string, limit int, from string) ([]string, error)

+ GetModificationTime func(storageID, objectPath string) (int64, error)

+ GetModificationTimes func(storageID, objectPath string) (map[string]int64, error)

+ RemoveMetadata func(storageID, objectPath string) error

+ SetModificationTime func(storageID, objectPath string, mTime int64) error

+ type Plugin struct

+ Impl Metadater

+ func (p *Plugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

+ func (p *Plugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error