client

package

Go to main page

Versions in this module

v1

v1.2.6

Dec 19, 2020

v1.2.5

Dec 17, 2020

v1.2.4

Dec 8, 2020

v1.2.3

Dec 3, 2020

v1.2.2

Dec 2, 2020

v1.2.1

Nov 13, 2020

v1.2.0

Nov 13, 2020

v1.1.2

Nov 12, 2020

v1.1.1

Nov 12, 2020

v1.1.0

Nov 11, 2020

Changes in this version

type Client

+ func (c *Client) UserID(ctx context.Context) (*userPb.UserIdentifierResponse, error)

v1.0.0

Nov 4, 2020

Changes in this version

+ const AdminKey

+ type ApplyOption func(r *proto.ApplyStorageConfigRequest)

type Client

+ Admin *admin.Admin

+ Data *Data

+ StorageConfig *StorageConfig

+ StorageJobs *StorageJobs

+ func (c *Client) StorageProfileID(ctx context.Context) (*proto.StorageProfileIdentifierResponse, error)

+ type Data struct

+ func (d *Data) CidInfo(ctx context.Context, cids ...string) (*proto.CidInfoResponse, error)

+ func (d *Data) Get(ctx context.Context, cid string) (io.Reader, error)

+ func (d *Data) GetFolder(ctx context.Context, ipfsRevProxyAddr, cid, outputDir string) error

+ func (d *Data) ReplaceData(ctx context.Context, cid1, cid2 string) (*proto.ReplaceDataResponse, error)

+ func (d *Data) Stage(ctx context.Context, data io.Reader) (*proto.StageResponse, error)

+ func (d *Data) StageFolder(ctx context.Context, ipfsRevProxyAddr string, folderPath string) (string, error)

+ func (d *Data) WatchLogs(ctx context.Context, ch chan<- WatchLogsEvent, cid string, ...) error

+ type DealRecordsOption func(*proto.DealRecordsConfig)

type Deals

+ func (d *Deals) RetrievalDealRecords(ctx context.Context, opts ...DealRecordsOption) (*proto.RetrievalDealRecordsResponse, error)

+ func (d *Deals) StorageDealRecords(ctx context.Context, opts ...DealRecordsOption) (*proto.StorageDealRecordsResponse, error)

+ type StorageConfig struct

+ func (s *StorageConfig) Apply(ctx context.Context, cid string, opts ...ApplyOption) (*proto.ApplyStorageConfigResponse, error)

+ func (s *StorageConfig) Default(ctx context.Context) (*proto.DefaultStorageConfigResponse, error)

+ func (s *StorageConfig) Remove(ctx context.Context, cid string) (*proto.RemoveResponse, error)

+ func (s *StorageConfig) SetDefault(ctx context.Context, config *proto.StorageConfig) (*proto.SetDefaultStorageConfigResponse, error)

+ type StorageJobs struct

+ func (j *StorageJobs) Cancel(ctx context.Context, jobID string) (*proto.CancelStorageJobResponse, error)

+ func (j *StorageJobs) Executing(ctx context.Context, cids ...string) (*proto.ExecutingStorageJobsResponse, error)

+ func (j *StorageJobs) LatestFinal(ctx context.Context, cids ...string) (*proto.LatestFinalStorageJobsResponse, error)

+ func (j *StorageJobs) LatestSuccessful(ctx context.Context, cids ...string) (*proto.LatestSuccessfulStorageJobsResponse, error)

+ func (j *StorageJobs) Queued(ctx context.Context, cids ...string) (*proto.QueuedStorageJobsResponse, error)

+ func (j *StorageJobs) StorageConfigForJob(ctx context.Context, jobID string) (*proto.StorageConfigForJobResponse, error)

+ func (j *StorageJobs) StorageJob(ctx context.Context, jobID string) (*proto.StorageJobResponse, error)

+ func (j *StorageJobs) Summary(ctx context.Context, cids ...string) (*proto.StorageJobsSummaryResponse, error)

+ func (j *StorageJobs) Watch(ctx context.Context, ch chan<- WatchStorageJobsEvent, jobIDs ...string) error

type Wallet

+ func (w *Wallet) Addresses(ctx context.Context) (*proto.AddressesResponse, error)

+ func (w *Wallet) SignMessage(ctx context.Context, address string, message []byte) (*proto.SignMessageResponse, error)

+ func (w *Wallet) VerifyMessage(ctx context.Context, address string, message, signature []byte) (*proto.VerifyMessageResponse, error)

+ type WatchLogsEvent struct

+ Err error

+ Res *proto.WatchLogsResponse

type WatchLogsOption

+ func WithJobIDFilter(jobID string) WatchLogsOption

+ type WatchStorageJobsEvent struct

+ Err error

+ Res *proto.WatchStorageJobsResponse

v0

v0.9.4

Oct 28, 2020

v0.9.3

Oct 28, 2020

v0.9.2

Oct 20, 2020

v0.9.1

Oct 15, 2020

v0.9.0

Oct 15, 2020

v0.8.0

Oct 14, 2020

v0.7.2

Oct 12, 2020

v0.7.1

Oct 6, 2020

v0.7.0

Oct 2, 2020

Changes in this version

type FFS

+ func (f *FFS) ShowAll(ctx context.Context) (*rpc.ShowAllResponse, error)

v0.6.10

Oct 2, 2020

v0.6.9

Sep 30, 2020

Changes in this version

type FFS

+ func (f *FFS) SignMessage(ctx context.Context, addr string, message []byte) ([]byte, error)

+ func (f *FFS) VerifyMessage(ctx context.Context, addr string, message, signature []byte) (bool, error)

v0.6.8

Sep 28, 2020

v0.6.7

Sep 26, 2020

v0.6.6

Sep 26, 2020

v0.6.5

Sep 26, 2020

v0.6.4

Sep 26, 2020

v0.6.3

Sep 26, 2020

v0.6.2

Sep 23, 2020

v0.6.1

Sep 22, 2020

v0.6.0

Sep 21, 2020

Changes in this version

type FFS

+ func (f *FFS) GetStorageJob(ctx context.Context, jid ffs.JobID) (ffs.StorageJob, error)

v0.6.0-rc8

Sep 21, 2020

v0.6.0-rc7

Sep 18, 2020

v0.6.0-rc5

Sep 17, 2020

v0.6.0-rc4

Sep 17, 2020

v0.6.0-rc3

Sep 16, 2020

v0.6.0-rc2

Sep 15, 2020

v0.6.0-rc1

Sep 15, 2020

v0.5.0-rc4

Sep 12, 2020

v0.5.0-rc3

Sep 11, 2020

v0.5.0-rc2

Sep 3, 2020

v0.5.0-rc1

Aug 29, 2020

v0.4.1

Aug 12, 2020

v0.4.0

Aug 11, 2020

Changes in this version

type Client

+ func (c *Client) BuildInfo(ctx context.Context) (*buildinfoRpc.BuildInfoResponse, error)

+ func (c *Client) Host() string

type FFS

+ func (f *FFS) GetFolder(ctx context.Context, ipfsRevProxyAddr string, c cid.Cid, outputDir string) error

+ func (f *FFS) StageFolder(ctx context.Context, ipfsRevProxyAddr string, folderPath string) (cid.Cid, error)

v0.3.1-pre.3

Aug 7, 2020

v0.3.1-pre.2

Aug 5, 2020

v0.3.1-pre.1

Aug 5, 2020

v0.3.1-pre.0

Aug 5, 2020

v0.3.0

Jul 31, 2020

Changes in this version

+ func CreateClientConn(target string, optsOverrides ...grpc.DialOption) (*grpc.ClientConn, error)

type TokenAuth

+ Secure bool

v0.2.1

Jul 22, 2020

v0.2.0

Jul 21, 2020

Changes in this version

type FFS

+ func (f *FFS) DefaultStorageConfig(ctx context.Context) (ffs.StorageConfig, error)

+ func (f *FFS) GetStorageConfig(ctx context.Context, c cid.Cid) (*rpc.GetStorageConfigResponse, error)

+ func (f *FFS) PushStorageConfig(ctx context.Context, c cid.Cid, opts ...PushStorageConfigOption) (ffs.JobID, error)

+ func (f *FFS) SetDefaultStorageConfig(ctx context.Context, config ffs.StorageConfig) error

+ func (f *FFS) Stage(ctx context.Context, data io.Reader) (*cid.Cid, error)

+ type PushStorageConfigOption func(r *rpc.PushStorageConfigRequest)

+ func WithStorageConfig(c ffs.StorageConfig) PushStorageConfigOption

v0.2.0-pre.1

Jul 21, 2020

v0.2.0-pre.0

Jul 20, 2020

v0.1.2-pre.2

Jul 17, 2020

v0.1.2-pre.1

Jul 17, 2020

v0.1.2-pre.0

Jul 16, 2020

v0.1.1

Jul 15, 2020

Changes in this version

type Wallet

+ func (w *Wallet) Balance(ctx context.Context, address string) (uint64, error)

+ func (w *Wallet) NewAddress(ctx context.Context, typ string) (string, error)

+ func (w *Wallet) SendFil(ctx context.Context, from, to string, amount int64) error

v0.1.1-pre.2

Jul 13, 2020

v0.1.1-pre.1

Jul 13, 2020

v0.1.1-pre.0

Jul 13, 2020

v0.1.0

Jul 8, 2020

Changes in this version

+ const AuthKey

+ type Asks struct

+ func (a *Asks) Get(ctx context.Context) (*ask.Index, error)

+ func (a *Asks) Query(ctx context.Context, query ask.Query) ([]ask.StorageAsk, error)

+ type Client struct

+ Asks *Asks

+ Deals *Deals

+ FFS *FFS

+ Faults *Faults

+ Health *Health

+ Miners *Miners

+ Net *Net

+ Reputation *Reputation

+ Wallet *Wallet

+ func NewClient(ma multiaddr.Multiaddr, opts ...grpc.DialOption) (*Client, error)

+ func (c *Client) Close() error

+ type Deals struct

+ func (d *Deals) ListRetrievalDealRecords(ctx context.Context, opts ...ListDealRecordsOption) ([]deals.RetrievalDealRecord, error)

+ func (d *Deals) ListStorageDealRecords(ctx context.Context, opts ...ListDealRecordsOption) ([]deals.StorageDealRecord, error)

+ func (d *Deals) Retrieve(ctx context.Context, waddr string, cid cid.Cid) (io.Reader, error)

+ func (d *Deals) Store(ctx context.Context, addr string, data io.Reader, ...) ([]cid.Cid, []deals.StorageDealConfig, error)

+ func (d *Deals) Watch(ctx context.Context, proposals []cid.Cid) (<-chan WatchEvent, error)

+ type FFS struct

+ func (f *FFS) AddToHot(ctx context.Context, data io.Reader) (*cid.Cid, error)

+ func (f *FFS) Addrs(ctx context.Context) ([]api.AddrInfo, error)

+ func (f *FFS) CancelJob(ctx context.Context, jid ffs.JobID) error

+ func (f *FFS) Close(ctx context.Context) error

+ func (f *FFS) Create(ctx context.Context) (string, string, error)

+ func (f *FFS) CreatePayChannel(ctx context.Context, from string, to string, amount uint64) (ffs.PaychInfo, cid.Cid, error)

+ func (f *FFS) DefaultConfig(ctx context.Context) (ffs.DefaultConfig, error)

+ func (f *FFS) Get(ctx context.Context, c cid.Cid) (io.Reader, error)

+ func (f *FFS) GetCidConfig(ctx context.Context, c cid.Cid) (*rpc.GetCidConfigResponse, error)

+ func (f *FFS) GetDefaultCidConfig(ctx context.Context, c cid.Cid) (ffs.CidConfig, error)

+ func (f *FFS) ID(ctx context.Context) (ffs.APIID, error)

+ func (f *FFS) Info(ctx context.Context) (api.InstanceInfo, error)

+ func (f *FFS) ListAPI(ctx context.Context) ([]ffs.APIID, error)

+ func (f *FFS) ListPayChannels(ctx context.Context) ([]ffs.PaychInfo, error)

+ func (f *FFS) ListRetrievalDealRecords(ctx context.Context, opts ...ListDealRecordsOption) ([]deals.RetrievalDealRecord, error)

+ func (f *FFS) ListStorageDealRecords(ctx context.Context, opts ...ListDealRecordsOption) ([]deals.StorageDealRecord, error)

+ func (f *FFS) NewAddr(ctx context.Context, name string, options ...NewAddressOption) (string, error)

+ func (f *FFS) PushConfig(ctx context.Context, c cid.Cid, opts ...PushConfigOption) (ffs.JobID, error)

+ func (f *FFS) RedeemPayChannel(ctx context.Context, addr string) error

+ func (f *FFS) Remove(ctx context.Context, c cid.Cid) error

+ func (f *FFS) Replace(ctx context.Context, c1 cid.Cid, c2 cid.Cid) (ffs.JobID, error)

+ func (f *FFS) SendFil(ctx context.Context, from string, to string, amount int64) error

+ func (f *FFS) SetDefaultConfig(ctx context.Context, config ffs.DefaultConfig) error

+ func (f *FFS) Show(ctx context.Context, c cid.Cid) (*rpc.ShowResponse, error)

+ func (f *FFS) WatchJobs(ctx context.Context, ch chan<- JobEvent, jids ...ffs.JobID) error

+ func (f *FFS) WatchLogs(ctx context.Context, ch chan<- LogEvent, c cid.Cid, opts ...WatchLogsOption) error

+ type Faults struct

+ func (s *Faults) Get(ctx context.Context) (*faults.IndexSnapshot, error)

+ type Health struct

+ func (health *Health) Check(ctx context.Context) (h.Status, []string, error)

+ type JobEvent struct

+ Err error

+ Job ffs.Job

+ type ListDealRecordsOption func(*rpc.ListDealRecordsConfig)

+ func WithAscending(ascending bool) ListDealRecordsOption

+ func WithDataCids(cids ...string) ListDealRecordsOption

+ func WithFromAddrs(addrs ...string) ListDealRecordsOption

+ func WithIncludeFinal(includeFinal bool) ListDealRecordsOption

+ func WithIncludePending(includePending bool) ListDealRecordsOption

+ type LogEvent struct

+ Err error

+ LogEntry ffs.LogEntry

+ type Miners struct

+ func (a *Miners) Get(ctx context.Context) (*miner.IndexSnapshot, error)

+ type Net struct

+ func (net *Net) ConnectPeer(ctx context.Context, addrInfo peer.AddrInfo) error

+ func (net *Net) Connectedness(ctx context.Context, peerID peer.ID) (n.Connectedness, error)

+ func (net *Net) DisconnectPeer(ctx context.Context, peerID peer.ID) error

+ func (net *Net) FindPeer(ctx context.Context, peerID peer.ID) (n.PeerInfo, error)

+ func (net *Net) ListenAddr(ctx context.Context) (peer.AddrInfo, error)

+ func (net *Net) Peers(ctx context.Context) ([]n.PeerInfo, error)

+ type NewAddressOption func(r *rpc.NewAddrRequest)

+ func WithAddressType(addressType string) NewAddressOption

+ func WithMakeDefault(makeDefault bool) NewAddressOption

+ type PushConfigOption func(r *rpc.PushConfigRequest)

+ func WithCidConfig(c ffs.CidConfig) PushConfigOption

+ func WithOverride(override bool) PushConfigOption

+ type Reputation struct

+ func (r *Reputation) AddSource(ctx context.Context, id string, maddr ma.Multiaddr) error

+ func (r *Reputation) GetTopMiners(ctx context.Context, limit int) ([]reputation.MinerScore, error)

+ type TokenAuth struct

+ func (t TokenAuth) GetRequestMetadata(ctx context.Context, _ ...string) (map[string]string, error)

+ func (t TokenAuth) RequireTransportSecurity() bool

+ type Wallet struct

+ func (w *Wallet) List(ctx context.Context) ([]string, error)

+ func (w *Wallet) NewWallet(ctx context.Context, typ string) (string, error)

+ func (w *Wallet) WalletBalance(ctx context.Context, address string) (uint64, error)

+ type WatchEvent struct

+ Deal deals.StorageDealInfo

+ Err error

+ type WatchLogsOption func(r *rpc.WatchLogsRequest)

+ func WithHistory(enabled bool) WatchLogsOption

+ func WithJidFilter(jid ffs.JobID) WatchLogsOption

v0.0.1-beta.13

Jul 2, 2020

v0.0.1-beta.12

Jul 2, 2020

v0.0.1-beta.11

Jul 2, 2020

v0.0.1-beta.10

Jun 22, 2020

v0.0.1-beta.9

Jun 20, 2020

v0.0.1-beta.8

Jun 5, 2020

v0.0.1-beta.7

Jun 5, 2020

v0.0.1-beta.6

May 29, 2020

v0.0.1-beta.5

May 29, 2020

v0.0.1-beta.4

May 29, 2020

v0.0.1-beta.3

May 28, 2020

v0.0.1-beta.1

May 18, 2020

v0.0.1-beta.0

May 18, 2020

Other modules containing this package

github.com/textileio/powergate/v2

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