admin

Documentation

Index

• type Service
  • func New(m *manager.Manager, s *scheduler.Scheduler, wm wallet.Module) *Service
  • func (a *Service) Addresses(ctx context.Context, req *adminPb.AddressesRequest) (*adminPb.AddressesResponse, error)
  • func (a *Service) CreateUser(ctx context.Context, req *adminPb.CreateUserRequest) (*adminPb.CreateUserResponse, error)
  • func (a *Service) GCStaged(ctx context.Context, req *adminProto.GCStagedRequest) (*adminProto.GCStagedResponse, error)
  • func (a *Service) ListStorageInfo(ctx context.Context, req *adminPb.ListStorageInfoRequest) (*adminPb.ListStorageInfoResponse, error)
  • func (a *Service) ListStorageJobs(ctx context.Context, req *adminPb.ListStorageJobsRequest) (*adminPb.ListStorageJobsResponse, error)
  • func (a *Service) NewAddress(ctx context.Context, req *adminPb.NewAddressRequest) (*adminPb.NewAddressResponse, error)
  • func (a *Service) PinnedCids(ctx context.Context, req *adminProto.PinnedCidsRequest) (*adminProto.PinnedCidsResponse, error)
  • func (a *Service) SendFil(ctx context.Context, req *adminPb.SendFilRequest) (*adminPb.SendFilResponse, error)
  • func (a *Service) StorageInfo(ctx context.Context, req *adminPb.StorageInfoRequest) (*adminPb.StorageInfoResponse, error)
  • func (a *Service) StorageJobsSummary(ctx context.Context, req *adminPb.StorageJobsSummaryRequest) (*adminPb.StorageJobsSummaryResponse, error)
  • func (a *Service) Users(ctx context.Context, req *adminPb.UsersRequest) (*adminPb.UsersResponse, error)

Types

type Service

type Service struct {
	adminPb.UnimplementedAdminServiceServer
	// contains filtered or unexported fields
}

Service implements the Admin API.

func New

func New(m *manager.Manager, s *scheduler.Scheduler, wm wallet.Module) *Service

New creates a new AdminService.

func (*Service) Addresses

func (a *Service) Addresses(ctx context.Context, req *adminPb.AddressesRequest) (*adminPb.AddressesResponse, error)

Addresses lists all addresses associated with this Powergate.

func (*Service) CreateUser

func (a *Service) CreateUser(ctx context.Context, req *adminPb.CreateUserRequest) (*adminPb.CreateUserResponse, error)

CreateUser creates a new managed instance.

func (*Service) GCStaged

func (a *Service) GCStaged(ctx context.Context, req *adminProto.GCStagedRequest) (*adminProto.GCStagedResponse, error)

GCStaged runs a unpinning garbage collection and returns the unpinned cids.

func (*Service) ListStorageInfo

func (a *Service) ListStorageInfo(ctx context.Context, req *adminPb.ListStorageInfoRequest) (*adminPb.ListStorageInfoResponse, error)

ListStorageInfo returns a list of information about all stored cids, filtered by user ids and cids if provided.

func (*Service) ListStorageJobs

func (a *Service) ListStorageJobs(ctx context.Context, req *adminPb.ListStorageJobsRequest) (*adminPb.ListStorageJobsResponse, error)

ListStorageJobs lists StorageJobs according to the provided request parameters.

func (*Service) NewAddress

func (a *Service) NewAddress(ctx context.Context, req *adminPb.NewAddressRequest) (*adminPb.NewAddressResponse, error)

NewAddress creates a new address.

func (*Service) PinnedCids

func (a *Service) PinnedCids(ctx context.Context, req *adminProto.PinnedCidsRequest) (*adminProto.PinnedCidsResponse, error)

PinnedCids returns all the pinned cids in Hot-Storage.

func (*Service) SendFil

func (a *Service) SendFil(ctx context.Context, req *adminPb.SendFilRequest) (*adminPb.SendFilResponse, error)

SendFil sends FIL from an address associated with this Powergate to any other address.

func (*Service) StorageInfo

func (a *Service) StorageInfo(ctx context.Context, req *adminPb.StorageInfoRequest) (*adminPb.StorageInfoResponse, error)

StorageInfo returns the information about a stored Cid. If no information is available, since the Cid was never stored, it returns an error with codes.NotFound.

func (*Service) StorageJobsSummary

func (a *Service) StorageJobsSummary(ctx context.Context, req *adminPb.StorageJobsSummaryRequest) (*adminPb.StorageJobsSummaryResponse, error)

StorageJobsSummary returns a summary of all storage jobs.

func (*Service) Users

func (a *Service) Users(ctx context.Context, req *adminPb.UsersRequest) (*adminPb.UsersResponse, error)

Users lists all managed instances.