escrow

package

Go to main page

Versions in this module

v1

v1.1.2

Aug 14, 2019

Changes in this version

+ type FreeCallCheckResponse struct

+ FreeCallsAllowed int

+ OrgID string

+ ServiceID string

+ TotalCallsMade int

+ Username string

v1.1.1

Aug 8, 2019

Changes in this version

+ const FreeCallPaymentType

+ const FreeCallPrefixSignature

+ func FreeCallPaymentHandler(processor *blockchain.Processor) handler.PaymentHandler

+ type BlockChainDisabledProviderControlService struct

+ func (service *BlockChainDisabledProviderControlService) GetListInProgress(ctx context.Context, request *GetPaymentsListRequest) (reply *PaymentsListReply, err error)

+ func (service *BlockChainDisabledProviderControlService) GetListUnclaimed(ctx context.Context, request *GetPaymentsListRequest) (paymentReply *PaymentsListReply, err error)

+ func (service *BlockChainDisabledProviderControlService) StartClaim(ctx context.Context, startClaim *StartClaimRequest) (paymentReply *PaymentReply, err error)

+ type BlockChainDisabledStateService struct

+ func (service *BlockChainDisabledStateService) GetChannelState(context context.Context, request *ChannelStateRequest) (reply *ChannelStateReply, err error)

+ type FreeCallPayment struct

+ CurrentBlockNumber *big.Int

+ OrganizationId string

+ ServiceId string

+ Signature []byte

+ UserId string

+ type FreeCallPaymentValidator struct

+ func NewFreeCallPaymentValidator(funcCurrentBlock func() (currentBlock *big.Int, err error), ...) *FreeCallPaymentValidator

+ func (validator *FreeCallPaymentValidator) Validate(payment *FreeCallPayment) (err error)

v1.1.0

Aug 2, 2019

Changes in this version

+ const PrefixInSignature

v1.0.0

Jun 12, 2019

Changes in this version

+ func PaymentID(channelID *big.Int, channelNonce *big.Int) string

type PaymentChannelStateService

+ func (service *PaymentChannelStateService) StorageNonceMatchesWithBlockchainNonce(storageChannel *PaymentChannelData) (equal bool, err error)

type PaymentStorage

+ func (storage *PaymentStorage) Get(paymentID string) (payment *Payment, ok bool, err error)

v0

v0.1.10

Apr 3, 2019

v0.1.9

Mar 21, 2019

v0.1.8

Mar 5, 2019

v0.1.7

Feb 23, 2019

v0.1.6

Jan 31, 2019

v0.1.5

Jan 22, 2019

Changes in this version

type PaymentChannelService

+ PaymentChannelFromBlockChain func(key *PaymentChannelKey) (channel *PaymentChannelData, ok bool, err error)

type PrefixedAtomicStorage

+ func NewLockerStorage(storage AtomicStorage) *PrefixedAtomicStorage

+ type ProviderControlService struct

+ func NewProviderControlService(channelService PaymentChannelService, metaData *blockchain.ServiceMetadata) *ProviderControlService

+ func (service *ProviderControlService) GetListInProgress(ctx context.Context, request *GetPaymentsListRequest) (reply *PaymentsListReply, err error)

+ func (service *ProviderControlService) GetListUnclaimed(ctx context.Context, request *GetPaymentsListRequest) (paymentReply *PaymentsListReply, err error)

+ func (service *ProviderControlService) StartClaim(ctx context.Context, startClaim *StartClaimRequest) (paymentReply *PaymentReply, err error)

v0.1.4

Dec 18, 2018

v0.1.3

Dec 4, 2018

Changes in this version

type PaymentChannelData

+ Signer common.Address

type PaymentErrorCode

+ const IncorrectNonce

v0.1.2

Nov 22, 2018

Changes in this version

+ const EscrowPaymentType

+ const PaymentChannelAmountHeader

+ const PaymentChannelIDHeader

+ const PaymentChannelNonceHeader

+ const PaymentChannelSignatureHeader

+ func NewMemStorage() (storage *memoryStorage)

+ func NewPaymentHandler(service PaymentChannelService, processor *blockchain.Processor, ...) handler.PaymentHandler

+ type AtomicStorage interface

+ CompareAndSwap func(key string, prevValue string, newValue string) (ok bool, err error)

+ Delete func(key string) (err error)

+ Get func(key string) (value string, ok bool, err error)

+ GetByKeyPrefix func(prefix string) (values []string, err error)

+ Put func(key string, value string) (err error)

+ PutIfAbsent func(key string, value string) (ok bool, err error)

+ type BlockchainChannelReader struct

+ func NewBlockchainChannelReader(processor *blockchain.Processor, cfg *viper.Viper) *BlockchainChannelReader

+ func (reader *BlockchainChannelReader) GetChannelStateFromBlockchain(key *PaymentChannelKey) (channel *PaymentChannelData, ok bool, err error)

+ type ChannelPaymentValidator struct

+ func NewChannelPaymentValidator(processor *blockchain.Processor, cfg *viper.Viper) *ChannelPaymentValidator

+ func (validator *ChannelPaymentValidator) Validate(payment *Payment, channel *PaymentChannelData) (err error)

+ type ChannelUpdate func(channel *PaymentChannelData)

+ var CloseChannel ChannelUpdate = func(channel *PaymentChannelData) { ... }

+ var IncrementChannelNonce ChannelUpdate = func(channel *PaymentChannelData) { ... }

+ type Claim interface

+ Finish func() error

+ Payment func() *Payment

+ type IncomeData struct

+ GrpcContext *handler.GrpcStreamContext

+ Income *big.Int

+ type IncomeValidator interface

+ Validate func(*IncomeData) (err *status.Status)

+ func NewIncomeValidator() (validator IncomeValidator)

+ type Lock interface

+ Unlock func() (err error)

+ type Locker interface

+ Lock func(name string) (lock Lock, ok bool, err error)

+ func NewEtcdLocker(storage AtomicStorage) Locker

+ type Payment struct

+ Amount *big.Int

+ ChannelID *big.Int

+ ChannelNonce *big.Int

+ MpeContractAddress common.Address

+ Signature []byte

+ func (p *Payment) ID() string

+ func (p *Payment) String() string

+ type PaymentChannelData struct

+ AuthorizedAmount *big.Int

+ ChannelID *big.Int

+ Expiration *big.Int

+ FullAmount *big.Int

+ GroupID [32]byte

+ Nonce *big.Int

+ Recipient common.Address

+ Sender common.Address

+ Signature []byte

+ State PaymentChannelState

+ func MergeStorageAndBlockchainChannelState(storage, blockchain *PaymentChannelData) (merged *PaymentChannelData)

+ func (data *PaymentChannelData) String() string

+ type PaymentChannelKey struct

+ ID *big.Int

+ func (key *PaymentChannelKey) String() string

+ type PaymentChannelService interface

+ ListChannels func() (channels []*PaymentChannelData, err error)

+ ListClaims func() (claim []Claim, err error)

+ PaymentChannel func(key *PaymentChannelKey) (channel *PaymentChannelData, ok bool, err error)

+ StartClaim func(key *PaymentChannelKey, update ChannelUpdate) (claim Claim, err error)

+ StartPaymentTransaction func(payment *Payment) (transaction PaymentTransaction, err error)

+ func NewPaymentChannelService(storage *PaymentChannelStorage, paymentStorage *PaymentStorage, ...) PaymentChannelService

+ type PaymentChannelState int

+ const Closed

+ const Open

+ func (state PaymentChannelState) String() string

+ type PaymentChannelStateService struct

+ func NewPaymentChannelStateService(channelService PaymentChannelService) *PaymentChannelStateService

+ func (service *PaymentChannelStateService) GetChannelState(context context.Context, request *ChannelStateRequest) (reply *ChannelStateReply, err error)

+ type PaymentChannelStorage struct

+ func NewPaymentChannelStorage(atomicStorage AtomicStorage) *PaymentChannelStorage

+ func (storage *PaymentChannelStorage) CompareAndSwap(key *PaymentChannelKey, prevState *PaymentChannelData, ...) (ok bool, err error)

+ func (storage *PaymentChannelStorage) Get(key *PaymentChannelKey) (state *PaymentChannelData, ok bool, err error)

+ func (storage *PaymentChannelStorage) GetAll() (states []*PaymentChannelData, err error)

+ func (storage *PaymentChannelStorage) Put(key *PaymentChannelKey, state *PaymentChannelData) (err error)

+ func (storage *PaymentChannelStorage) PutIfAbsent(key *PaymentChannelKey, state *PaymentChannelData) (ok bool, err error)

+ type PaymentError struct

+ Code PaymentErrorCode

+ Message string

+ func NewPaymentError(code PaymentErrorCode, format string, msg ...interface{}) *PaymentError

+ func (err *PaymentError) Error() string

+ type PaymentErrorCode int

+ const FailedPrecondition

+ const Internal

+ const Unauthenticated

+ type PaymentStorage struct

+ func NewPaymentStorage(atomicStorage AtomicStorage) *PaymentStorage

+ func (storage *PaymentStorage) Delete(payment *Payment) (err error)

+ func (storage *PaymentStorage) GetAll() (states []*Payment, err error)

+ func (storage *PaymentStorage) Put(payment *Payment) (err error)

+ type PaymentTransaction interface

+ Channel func() *PaymentChannelData

+ Commit func() error

+ Rollback func() error

+ type PrefixedAtomicStorage struct

+ func (storage *PrefixedAtomicStorage) CompareAndSwap(key string, prevValue string, newValue string) (ok bool, err error)

+ func (storage *PrefixedAtomicStorage) Delete(key string) (err error)

+ func (storage *PrefixedAtomicStorage) Get(key string) (value string, ok bool, err error)

+ func (storage *PrefixedAtomicStorage) GetByKeyPrefix(prefix string) (values []string, err error)

+ func (storage *PrefixedAtomicStorage) Put(key string, value string) (err error)

+ func (storage *PrefixedAtomicStorage) PutIfAbsent(key string, value string) (ok bool, err error)

+ type TypedAtomicStorage interface

+ CompareAndSwap func(key interface{}, prevValue interface{}, newValue interface{}) (ok bool, err error)

+ Delete func(key interface{}) (err error)

+ Get func(key interface{}) (value interface{}, ok bool, err error)

+ GetAll func() (array interface{}, err error)

+ Put func(key interface{}, value interface{}) (err error)

+ PutIfAbsent func(key interface{}, value interface{}) (ok bool, err error)

+ type TypedAtomicStorageImpl struct

+ func (storage *TypedAtomicStorageImpl) CompareAndSwap(key interface{}, prevValue interface{}, newValue interface{}) (ok bool, err error)

+ func (storage *TypedAtomicStorageImpl) Delete(key interface{}) (err error)

+ func (storage *TypedAtomicStorageImpl) Get(key interface{}) (value interface{}, ok bool, err error)

+ func (storage *TypedAtomicStorageImpl) GetAll() (array interface{}, err error)

+ func (storage *TypedAtomicStorageImpl) Put(key interface{}, value interface{}) (err error)

+ func (storage *TypedAtomicStorageImpl) PutIfAbsent(key interface{}, value interface{}) (ok bool, err error)

Incompatible versions in this module

v4.0.0+incompatible

Aug 10, 2020

v3.1.8+incompatible

Jun 1, 2020

v3.1.7+incompatible

Apr 18, 2020

v3.1.6+incompatible

Apr 8, 2020

v3.1.5+incompatible

Apr 1, 2020

v3.1.4+incompatible

Mar 31, 2020

v3.1.3+incompatible

Mar 24, 2020

v3.1.2+incompatible

Mar 11, 2020

v3.1.1+incompatible

Mar 9, 2020

v3.1.0+incompatible

Mar 5, 2020

v3.0.0+incompatible

Feb 18, 2020

v2.0.2+incompatible

Aug 22, 2019

v2.0.1+incompatible

Aug 19, 2019

v2.0.0+incompatible

Aug 19, 2019

Other modules containing this package

github.com/singnet/snet-daemon/v5

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