bucketsd

Documentation

Index

• Variables
• type Service
  • func (s *Service) Archive(ctx context.Context, req *pb.ArchiveRequest) (*pb.ArchiveResponse, error)
  • func (s *Service) ArchiveInfo(ctx context.Context, req *pb.ArchiveInfoRequest) (*pb.ArchiveInfoResponse, error)
  • func (s *Service) ArchiveStatus(ctx context.Context, req *pb.ArchiveStatusRequest) (*pb.ArchiveStatusResponse, error)
  • func (s *Service) ArchiveWatch(req *pb.ArchiveWatchRequest, server pb.APIService_ArchiveWatchServer) error
  • func (s *Service) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)
  • func (s *Service) DefaultArchiveConfig(ctx context.Context, req *pb.DefaultArchiveConfigRequest) (*pb.DefaultArchiveConfigResponse, error)
  • func (s *Service) Links(ctx context.Context, req *pb.LinksRequest) (*pb.LinksResponse, error)
  • func (s *Service) List(ctx context.Context, _ *pb.ListRequest) (*pb.ListResponse, error)
  • func (s *Service) ListIpfsPath(ctx context.Context, req *pb.ListIpfsPathRequest) (*pb.ListIpfsPathResponse, error)
  • func (s *Service) ListPath(ctx context.Context, req *pb.ListPathRequest) (*pb.ListPathResponse, error)
  • func (s *Service) PullIpfsPath(req *pb.PullIpfsPathRequest, server pb.APIService_PullIpfsPathServer) error
  • func (s *Service) PullPath(req *pb.PullPathRequest, server pb.APIService_PullPathServer) error
  • func (s *Service) PullPathAccessRoles(ctx context.Context, req *pb.PullPathAccessRolesRequest) (*pb.PullPathAccessRolesResponse, error)
  • func (s *Service) PushPath(server pb.APIService_PushPathServer) (err error)
  • func (s *Service) PushPathAccessRoles(ctx context.Context, req *pb.PushPathAccessRolesRequest) (res *pb.PushPathAccessRolesResponse, err error)
  • func (s *Service) Remove(ctx context.Context, req *pb.RemoveRequest) (*pb.RemoveResponse, error)
  • func (s *Service) RemovePath(ctx context.Context, req *pb.RemovePathRequest) (res *pb.RemovePathResponse, err error)
  • func (s *Service) Root(ctx context.Context, req *pb.RootRequest) (*pb.RootResponse, error)
  • func (s *Service) SetDefaultArchiveConfig(ctx context.Context, req *pb.SetDefaultArchiveConfigRequest) (*pb.SetDefaultArchiveConfigResponse, error)
  • func (s *Service) SetPath(ctx context.Context, req *pb.SetPathRequest) (res *pb.SetPathResponse, err error)

Variables

var (

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

	// ErrMaxBucketSizeExceeded indicates the requested operation exceeds the max bucket size.
	ErrMaxBucketSizeExceeded = errors.New("max bucket size exceeded")

	// ErrStorageQuotaExhausted indicates the requested operation exceeds the storage allowance.
	ErrStorageQuotaExhausted = errors.New("storage quota exhausted")
)

Types

type Service

type Service struct {
	Collections         *mdb.Collections
	Buckets             *tdb.Buckets
	GatewayURL          string
	GatewayBucketsHost  string
	IPFSClient          iface.CoreAPI
	IPNSManager         *ipns.Manager
	PowergateClient     *pow.Client
	PowergateAdminToken string
	ArchiveTracker      *archive.Tracker
	Semaphores          *nutil.SemaphorePool
	MaxBucketSize       int64
}

Service is a gRPC service for buckets.

func (*Service) Archive

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

func (*Service) ArchiveInfo

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

func (*Service) ArchiveStatus

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

func (*Service) ArchiveWatch

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

func (*Service) Create

func (s *Service) Create(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)

func (*Service) DefaultArchiveConfig

func (s *Service) DefaultArchiveConfig(
	ctx context.Context,
	req *pb.DefaultArchiveConfigRequest,
) (*pb.DefaultArchiveConfigResponse, error)

func (*Service) Links

func (s *Service) Links(ctx context.Context, req *pb.LinksRequest) (*pb.LinksResponse, error)

func (*Service) List

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

func (*Service) ListIpfsPath

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

func (*Service) ListPath

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

func (*Service) PullIpfsPath

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

func (*Service) PullPath

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

func (*Service) PullPathAccessRoles

func (s *Service) PullPathAccessRoles(
	ctx context.Context,
	req *pb.PullPathAccessRolesRequest,
) (*pb.PullPathAccessRolesResponse, error)

func (*Service) PushPath

func (s *Service) PushPath(server pb.APIService_PushPathServer) (err error)

func (*Service) PushPathAccessRoles

func (s *Service) PushPathAccessRoles(
	ctx context.Context,
	req *pb.PushPathAccessRolesRequest,
) (res *pb.PushPathAccessRolesResponse, err error)

func (*Service) Remove

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

func (*Service) RemovePath

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

func (*Service) Root

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

func (*Service) SetDefaultArchiveConfig

func (s *Service) SetDefaultArchiveConfig(
	ctx context.Context,
	req *pb.SetDefaultArchiveConfigRequest,
) (*pb.SetDefaultArchiveConfigResponse, error)

func (*Service) SetPath

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