The highest tagged major version is v2.

user

package

v1.2.6 Latest Latest Go to latest Published: Dec 19, 2020 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 ¶

Variables
func ToProtoStorageJobs(jobs []ffs.StorageJob) ([]*userPb.StorageJob, error)
func ToRPCStorageConfig(config ffs.StorageConfig) *userPb.StorageConfig
type Service
- func New(m *manager.Manager, w wallet.Module, hot ffs.HotStorage) *Service

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrEmptyAuthToken is returned when the provided auth-token is unknown.
	ErrEmptyAuthToken = errors.New("auth token can't be empty")
)

Functions ¶

func ToProtoStorageJobs ¶

func ToProtoStorageJobs(jobs []ffs.StorageJob) ([]*userPb.StorageJob, error)

ToProtoStorageJobs converts a slice of ffs.StorageJobs to proto Jobs.

func ToRPCStorageConfig ¶

func ToRPCStorageConfig(config ffs.StorageConfig) *userPb.StorageConfig

ToRPCStorageConfig converts from a ffs.StorageConfig to a rpc StorageConfig.

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) DefaultStorageConfig ¶

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

DefaultStorageConfig calls ffs.DefaultStorageConfig.

func (*Service) ExecutingStorageJobs ¶

func (s *Service) ExecutingStorageJobs(ctx context.Context, req *userPb.ExecutingStorageJobsRequest) (*userPb.ExecutingStorageJobsResponse, error)

ExecutingStorageJobs returns a list of executing storage jobs.

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) LatestFinalStorageJobs ¶

func (s *Service) LatestFinalStorageJobs(ctx context.Context, req *userPb.LatestFinalStorageJobsRequest) (*userPb.LatestFinalStorageJobsResponse, error)

LatestFinalStorageJobs returns a list of latest final storage jobs.

func (*Service) LatestSuccessfulStorageJobs ¶

func (s *Service) LatestSuccessfulStorageJobs(ctx context.Context, req *userPb.LatestSuccessfulStorageJobsRequest) (*userPb.LatestSuccessfulStorageJobsResponse, error)

LatestSuccessfulStorageJobs returns a list of latest successful storage jobs.

func (*Service) NewAddress ¶

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

NewAddress calls ffs.NewAddr.

func (*Service) QueuedStorageJobs ¶

func (s *Service) QueuedStorageJobs(ctx context.Context, req *userPb.QueuedStorageJobsRequest) (*userPb.QueuedStorageJobsResponse, error)

QueuedStorageJobs returns a list of queued storage jobs.

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 ¶ added in v1.2.2

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