buckets

package
v1.0.14 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2020 License: MIT Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (

	// ErrArchivingFeatureDisabled indicates an archive was requested with archiving disabled.
	ErrArchivingFeatureDisabled = errors.New("archiving feature is disabled")

	// ErrBucketExceedsMaxSize indicates the bucket exceeds the max allowed size.
	ErrBucketExceedsMaxSize = errors.New("bucket size exceeds quota")

	// ErrBucketsTotalSizeExceedsMaxSize indicates the sum of bucket sizes of the account
	// exceeds the maximum allowed size.
	ErrBucketsTotalSizeExceedsMaxSize = errors.New("total size of buckets exceeds quota")

	// ErrTooManyBucketsInThread indicates that there is the maximum number of buckets in a thread.
	ErrTooManyBucketsInThread = errors.New("number of buckets in thread exceeds quota")
)

Functions

This section is empty.

Types

type Service

type Service struct {
	Collections               *mdb.Collections
	Buckets                   *tdb.Buckets
	BucketsMaxSize            int64
	BucketsTotalMaxSize       int64
	BucketsMaxNumberPerThread int
	GatewayURL                string
	IPFSClient                iface.CoreAPI
	IPNSManager               *ipns.Manager
	DNSManager                *dns.Manager
	PGClient                  *powc.Client
	ArchiveTracker            *archive.Tracker
}

Service is a gRPC service for buckets.

func (*Service) Archive added in v1.0.4

func (s *Service) Archive(ctx context.Context, req *pb.ArchiveRequest) (*pb.ArchiveReply, error)

func (*Service) ArchiveInfo added in v1.0.4

func (s *Service) ArchiveInfo(ctx context.Context, req *pb.ArchiveInfoRequest) (*pb.ArchiveInfoReply, error)

func (*Service) ArchiveStatus added in v1.0.4

func (s *Service) ArchiveStatus(ctx context.Context, req *pb.ArchiveStatusRequest) (*pb.ArchiveStatusReply, error)

func (*Service) ArchiveWatch added in v1.0.4

func (s *Service) ArchiveWatch(req *pb.ArchiveWatchRequest, server pb.API_ArchiveWatchServer) error

func (*Service) Init

func (s *Service) Init(ctx context.Context, req *pb.InitRequest) (*pb.InitReply, error)
func (s *Service) Links(ctx context.Context, req *pb.LinksRequest) (*pb.LinksReply, error)

func (*Service) List

func (s *Service) List(ctx context.Context, _ *pb.ListRequest) (*pb.ListReply, error)

func (*Service) ListIpfsPath added in v1.0.8

func (s *Service) ListIpfsPath(ctx context.Context, req *pb.ListIpfsPathRequest) (*pb.ListIpfsPathReply, error)

func (*Service) ListPath

func (s *Service) ListPath(ctx context.Context, req *pb.ListPathRequest) (*pb.ListPathReply, error)

func (*Service) PullIpfsPath added in v1.0.8

func (s *Service) PullIpfsPath(req *pb.PullIpfsPathRequest, server pb.API_PullIpfsPathServer) error

func (*Service) PullPath

func (s *Service) PullPath(req *pb.PullPathRequest, server pb.API_PullPathServer) error

func (*Service) PushPath

func (s *Service) PushPath(server pb.API_PushPathServer) error

func (*Service) Remove

func (s *Service) Remove(ctx context.Context, req *pb.RemoveRequest) (*pb.RemoveReply, error)

func (*Service) RemovePath

func (s *Service) RemovePath(ctx context.Context, req *pb.RemovePathRequest) (*pb.RemovePathReply, error)

func (*Service) Root added in v1.0.7

func (s *Service) Root(ctx context.Context, req *pb.RootRequest) (*pb.RootReply, error)

func (*Service) SetPath added in v1.0.8

func (s *Service) SetPath(ctx context.Context, req *pb.SetPathRequest) (*pb.SetPathReply, error)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL