user

package

v2.6.2 Latest Latest Go to latest Published: Jul 2, 2021 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/textileio/powergate

Links

Open Source Insights

Documentation ¶

Index ¶

type Service
- func New(m *manager.Manager, w wallet.Module, hot ffs.HotStorage) *Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Service ¶

type Service struct {
	userPb.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

Service implements the Powergate API.

func New ¶

func New(m *manager.Manager, w wallet.Module, hot ffs.HotStorage) *Service

New creates a new powergate Service.

func (*Service) Addresses ¶

func (s *Service) Addresses(ctx context.Context, req *userPb.AddressesRequest) (*userPb.AddressesResponse, error)

Addresses calls ffs.Addrs.

func (*Service) ApplyStorageConfig ¶

func (s *Service) ApplyStorageConfig(ctx context.Context, req *userPb.ApplyStorageConfigRequest) (*userPb.ApplyStorageConfigResponse, error)

ApplyStorageConfig applies the provided cid storage config.

func (*Service) Balance ¶

func (s *Service) Balance(ctx context.Context, req *userPb.BalanceRequest) (*userPb.BalanceResponse, error)

Balance returns the balance for an address.

func (*Service) BuildInfo ¶

func (s *Service) BuildInfo(ctx context.Context, req *userPb.BuildInfoRequest) (*userPb.BuildInfoResponse, error)

BuildInfo returns information about the powergate build.

func (*Service) CancelStorageJob ¶

func (s *Service) CancelStorageJob(ctx context.Context, req *userPb.CancelStorageJobRequest) (*userPb.CancelStorageJobResponse, error)

CancelStorageJob calls API.CancelJob.

func (*Service) CidInfo ¶

func (s *Service) CidInfo(ctx context.Context, req *userPb.CidInfoRequest) (*userPb.CidInfoResponse, error)

CidInfo returns information about cids managed by the FFS instance.

func (*Service) CidSummary ¶

func (s *Service) CidSummary(ctx context.Context, req *userPb.CidSummaryRequest) (*userPb.CidSummaryResponse, error)

CidSummary gives a summary of the storage and jobs state of the specified cid.

func (*Service) DefaultStorageConfig ¶

func (s *Service) DefaultStorageConfig(ctx context.Context, req *userPb.DefaultStorageConfigRequest) (*userPb.DefaultStorageConfigResponse, error)

DefaultStorageConfig calls ffs.DefaultStorageConfig.

func (*Service) Get ¶

func (s *Service) Get(req *userPb.GetRequest, srv userPb.UserService_GetServer) error

Get gets the data for a stored Cid.

func (*Service) ListStorageInfo ¶

func (s *Service) ListStorageInfo(ctx context.Context, req *userPb.ListStorageInfoRequest) (*userPb.ListStorageInfoResponse, error)

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

func (*Service) ListStorageJobs ¶

func (s *Service) ListStorageJobs(ctx context.Context, req *userPb.ListStorageJobsRequest) (*userPb.ListStorageJobsResponse, error)

ListStorageJobs lists StorageJobs according to the provided request parameters.

func (*Service) NewAddress ¶

func (s *Service) NewAddress(ctx context.Context, req *userPb.NewAddressRequest) (*userPb.NewAddressResponse, error)

NewAddress calls ffs.NewAddr.

func (*Service) Remove ¶

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

Remove calls ffs.Remove.

func (*Service) ReplaceData ¶

func (s *Service) ReplaceData(ctx context.Context, req *userPb.ReplaceDataRequest) (*userPb.ReplaceDataResponse, error)

ReplaceData calls ffs.Replace.

func (*Service) RetrievalDealRecords ¶

func (s *Service) RetrievalDealRecords(ctx context.Context, req *userPb.RetrievalDealRecordsRequest) (*userPb.RetrievalDealRecordsResponse, error)

RetrievalDealRecords calls ffs.ListRetrievalDealRecords.

func (*Service) SendFil ¶

func (s *Service) SendFil(ctx context.Context, req *userPb.SendFilRequest) (*userPb.SendFilResponse, error)

SendFil sends fil from a managed address to any other address.

func (*Service) SetDefaultStorageConfig ¶

func (s *Service) SetDefaultStorageConfig(ctx context.Context, req *userPb.SetDefaultStorageConfigRequest) (*userPb.SetDefaultStorageConfigResponse, error)

SetDefaultStorageConfig sets a new config to be used by default.

func (*Service) SignMessage ¶

func (s *Service) SignMessage(ctx context.Context, req *userPb.SignMessageRequest) (*userPb.SignMessageResponse, error)

SignMessage calls ffs.SignMessage.

func (*Service) Stage ¶

func (s *Service) Stage(srv userPb.UserService_StageServer) error

Stage allows to stage-pin a stream of data in Hot-Storage in preparation for pushing a storage configuration.

func (*Service) StageCid ¶

func (s *Service) StageCid(ctx context.Context, req *userPb.StageCidRequest) (*userPb.StageCidResponse, error)

StageCid allows to stage-pin a cid in Hot-Storage in preparation for pushing a storage configuration.

func (*Service) StorageConfigForJob ¶

func (s *Service) StorageConfigForJob(ctx context.Context, req *userPb.StorageConfigForJobRequest) (*userPb.StorageConfigForJobResponse, error)

StorageConfigForJob returns the StorageConfig associated with the job id.

func (*Service) StorageDealRecords ¶

func (s *Service) StorageDealRecords(ctx context.Context, req *userPb.StorageDealRecordsRequest) (*userPb.StorageDealRecordsResponse, error)

StorageDealRecords calls ffs.ListStorageDealRecords.

func (*Service) StorageInfo ¶

func (s *Service) StorageInfo(ctx context.Context, req *userPb.StorageInfoRequest) (*userPb.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) StorageJob ¶

func (s *Service) StorageJob(ctx context.Context, req *userPb.StorageJobRequest) (*userPb.StorageJobResponse, error)

StorageJob calls API.GetStorageJob.

func (*Service) StorageJobsSummary ¶

func (s *Service) StorageJobsSummary(ctx context.Context, req *userPb.StorageJobsSummaryRequest) (*userPb.StorageJobsSummaryResponse, error)

StorageJobsSummary returns a summary of all storage jobs.

func (*Service) UserIdentifier ¶

func (s *Service) UserIdentifier(ctx context.Context, req *userPb.UserIdentifierRequest) (*userPb.UserIdentifierResponse, error)

UserIdentifier returns the API instance id.

func (*Service) VerifyMessage ¶

func (s *Service) VerifyMessage(ctx context.Context, req *userPb.VerifyMessageRequest) (*userPb.VerifyMessageResponse, error)

VerifyMessage calls ffs.VerifyMessage.

func (*Service) WatchLogs ¶

func (s *Service) WatchLogs(req *userPb.WatchLogsRequest, srv userPb.UserService_WatchLogsServer) error

WatchLogs returns a stream of human-readable messages related to executions of a Cid. The listener is automatically unsubscribed when the client closes the stream.

func (*Service) WatchStorageJobs ¶

func (s *Service) WatchStorageJobs(req *userPb.WatchStorageJobsRequest, srv userPb.UserService_WatchStorageJobsServer) error

WatchStorageJobs calls API.WatchJobs.

Source Files ¶

View all Source files

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