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) ListPath(ctx context.Context, req *pb.ListPathRequest) (*pb.ListPathReply, 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)

Variables

var (
	ErrArchivingFeatureDisabled = fmt.Errorf("archiving feature is disabled")
)

Types

type Service

type Service struct {
	Collections *c.Collections
	Buckets     *bucks.Buckets
	GatewayURL  string
	IPFSClient  iface.CoreAPI
	IPNSManager *ipns.Manager
	DNSManager  *dns.Manager
}

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

func (s *Service) ListPath(ctx context.Context, req *pb.ListPathRequest) (*pb.ListPathReply, 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)