buckets

Documentation

Index

• Variables
• type Service
  • func (s *Service) Archive(ctx context.Context, req *pb.ArchiveRequest) (*pb.ArchiveReply, error)
  • func (s *Service) ArchiveInfo(ctx context.Context, req *pb.ArchiveInfoRequest) (*pb.ArchiveInfoReply, error)
  • func (s *Service) ArchiveStatus(ctx context.Context, req *pb.ArchiveStatusRequest) (*pb.ArchiveStatusReply, error)
  • func (s *Service) ArchiveWatch(req *pb.ArchiveWatchRequest, server pb.API_ArchiveWatchServer) error
  • 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 (s *Service) List(ctx context.Context, _ *pb.ListRequest) (*pb.ListReply, error)
  • func (s *Service) ListIpfsPath(ctx context.Context, req *pb.ListIpfsPathRequest) (*pb.ListIpfsPathReply, error)
  • func (s *Service) ListPath(ctx context.Context, req *pb.ListPathRequest) (*pb.ListPathReply, error)
  • func (s *Service) PullIpfsPath(req *pb.PullIpfsPathRequest, server pb.API_PullIpfsPathServer) error
  • func (s *Service) PullPath(req *pb.PullPathRequest, server pb.API_PullPathServer) error
  • func (s *Service) PushPath(server pb.API_PushPathServer) error
  • func (s *Service) Remove(ctx context.Context, req *pb.RemoveRequest) (*pb.RemoveReply, error)
  • func (s *Service) RemovePath(ctx context.Context, req *pb.RemovePathRequest) (*pb.RemovePathReply, error)
  • func (s *Service) Root(ctx context.Context, req *pb.RootRequest) (*pb.RootReply, error)
  • func (s *Service) SetPath(ctx context.Context, req *pb.SetPathRequest) (*pb.SetPathReply, error)

Variables

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")
)

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

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

func (*Service) ArchiveInfo

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

func (*Service) ArchiveStatus

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

func (*Service) ArchiveWatch

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 (*Service) Links

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

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

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

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

func (*Service) SetPath

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