Versions in this module Expand all Collapse all v1 v1.5.0 Jan 11, 2021 Changes in this version + const RenterSessionAdditionalInfoKey + const RenterSessionInMemKey + const RenterSessionKey + const RenterSessionOfflineMetaKey + const RenterSessionOfflineSigningKey + const RenterSessionPrefix + const RenterSessionStatusKey + const RssCompleteStatus + const RssErrorStatus + const RssGuardFileMetaSignedStatus + const RssGuardQuestionsSignedStatus + const RssGuardStatus + const RssInitStatus + const RssPayPayinRequestSignedStatus + const RssPayStatus + const RssSubmitBalanceReqSignedStatus + const RssSubmitLedgerChannelCommitSignedStatus + const RssSubmitStatus + const RssToCompleteEvent + const RssToErrorEvent + const RssToGuardEvent + const RssToGuardFileMetaSignedEvent + const RssToGuardQuestionsSignedEvent + const RssToPayEvent + const RssToPayPayinRequestSignedEvent + const RssToSubmitBalanceReqSignedEvent + const RssToSubmitEvent + const RssToSubmitLedgerChannelCommitSignedEvent + const RssToWaitUploadEvent + const RssToWaitUploadReqSignedEvent + const RssWaitUploadReqSignedStatus + const RssWaitUploadStatus + func Batch(d ds.Datastore, keys []string, vals []proto.Message) error + func DeleteShardsContracts(d datastore.Datastore, peerId string, role string) error + func Get(d ds.Datastore, key string, m proto.Message) error + func GetShardId(ssId string, shardHash string, index int) (contractId string) + func List(d ds.Datastore, prefix string, substrInKey ...string) ([][]byte, error) + func ListKeys(d ds.Datastore, prefix string, substrInKey ...string) ([]string, error) + func ListShardsContracts(d datastore.Datastore, peerId string, role string) ([]*shardpb.SignedContracts, error) + func Remove(d ds.Datastore, key string) error + func Save(d ds.Datastore, key string, val proto.Message) error + func SaveShardsContracts(ds datastore.Datastore, scs []*shardpb.SignedContracts, ...) ([]*shardpb.SignedContracts, []string, error) + type HostShard struct + func GetHostShard(ctxParams *uh.ContextParams, contractId string) (*HostShard, error) + func (hs *HostShard) Complete() error + func (hs *HostShard) Contract(signedEscrowContract []byte, signedGuardContract *guardpb.Contract) error + type RenterSession struct + Cancel context.CancelFunc + Ctx context.Context + CtxParams *uh.ContextParams + Hash string + PeerId string + ShardHashes []string + SsId string + func GetRenterSession(ctxParams *uh.ContextParams, ssId string, hash string, shardHashes []string) (*RenterSession, error) + func (rs *RenterSession) GetAdditionalInfo() (*renterpb.RenterSessionAdditionalInfo, error) + func (rs *RenterSession) GetCompleteShardsNum() (int, int, error) + func (rs *RenterSession) OfflineMeta() (*renterpb.OfflineMeta, error) + func (rs *RenterSession) OfflineSigning() (*renterpb.OfflineSigning, error) + func (rs *RenterSession) SaveOfflineMeta(meta *renterpb.OfflineMeta) error + func (rs *RenterSession) SaveOfflineSigning(signingData *renterpb.OfflineSigning) error + func (rs *RenterSession) Status() (*renterpb.RenterSessionStatus, error) + func (rs *RenterSession) To(event string, args ...interface{}) error + func (rs *RenterSession) UpdateAdditionalInfo(info string) error + type RenterSessionsCursor struct + func GetRenterSessionsCursor(ctxParam *uh.ContextParams) (*RenterSessionsCursor, error) + func (r *RenterSessionsCursor) NextSession(status string) (*RenterSession, error) + type RenterShard struct + func GetRenterShard(ctxParams *uh.ContextParams, ssId string, hash string, index int) (*RenterShard, error) + func (rs *RenterShard) Contract(signedEscrowContract []byte, signedGuardContract *guardpb.Contract) error + func (rs *RenterShard) Contracts() (*shardpb.SignedContracts, error) + func (rs *RenterShard) GetAdditionalInfo() (*shardpb.AdditionalInfo, error) + func (rs *RenterShard) Status() (*shardpb.Status, error) + func (rs *RenterShard) UpdateAdditionalInfo(info string) error
Go to main page