statemachine

package

Go to main page

Versions in this module

v0

v0.0.3

Oct 16, 2024

v0.0.2

Oct 10, 2024

Changes in this version

type TransferRequest

+ func (tr *TransferRequest) SetProviderPID(id uuid.UUID)

type TransferRequestNegotiationTerminated

+ func (tr *TransferRequestNegotiationTerminated) Recv(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ func (tr *TransferRequestNegotiationTerminated) Send(ctx context.Context) (func(), error)

v0.0.1

Aug 30, 2024

Changes in this version

+ var ContractStates = contractstatesContainer

+ var ErrFatal = errors.New("fatal error")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrTransient = errors.New("transient error")

+ var TransferRequestStates = transferrequeststatesContainer

+ func ExhaustiveContractStates(f func(ContractState))

+ func ExhaustiveTransferRequestStates(f func(TransferRequestState))

+ type Archiver interface

+ DelAgreement func(ctx context.Context, agreementID uuid.UUID) error

+ GetAgreement func(ctx context.Context, agreementID uuid.UUID) (*odrl.Agreement, error)

+ GetConsumerContract func(ctx context.Context, consumerPID uuid.UUID) (*Contract, error)

+ GetConsumerTransfer func(ctx context.Context, consumerPID uuid.UUID) (*TransferRequest, error)

+ GetProviderContract func(ctx context.Context, providerPID uuid.UUID) (*Contract, error)

+ GetProviderTransfer func(ctx context.Context, providerPID uuid.UUID) (*TransferRequest, error)

+ PutAgreement func(ctx context.Context, agreement *odrl.Agreement) error

+ PutConsumerContract func(ctx context.Context, contract *Contract) error

+ PutConsumerTransfer func(ctx context.Context, contract *TransferRequest) error

+ PutProviderContract func(ctx context.Context, contract *Contract) error

+ PutProviderTransfer func(ctx context.Context, contract *TransferRequest) error

+ type Contract struct

+ func (cn *Contract) Copy() *Contract

+ func (cn *Contract) GetAgreement() odrl.Agreement

+ func (cn *Contract) GetCallback() *url.URL

+ func (cn *Contract) GetConsumerPID() uuid.UUID

+ func (cn *Contract) GetContract() *Contract

+ func (cn *Contract) GetContractNegotiation() shared.ContractNegotiation

+ func (cn *Contract) GetOffer() odrl.Offer

+ func (cn *Contract) GetProviderPID() uuid.UUID

+ func (cn *Contract) GetRole() DataspaceRole

+ func (cn *Contract) GetSelf() *url.URL

+ func (cn *Contract) GetState() ContractState

+ func (cn *Contract) SetCallback(u string) error

+ func (cn *Contract) SetConsumerPID(u uuid.UUID)

+ func (cn *Contract) SetProviderPID(u uuid.UUID)

+ func (cn *Contract) SetState(state ContractState) error

+ type ContractNegotiationAccepted struct

+ func (cd *ContractNegotiationAccepted) GetArchiver() Archiver

+ func (cd *ContractNegotiationAccepted) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationAccepted) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationAccepted) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationAccepted) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationAgreed struct

+ func (cd *ContractNegotiationAgreed) GetArchiver() Archiver

+ func (cd *ContractNegotiationAgreed) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationAgreed) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationAgreed) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationAgreed) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationFinalized struct

+ func (cd *ContractNegotiationFinalized) GetArchiver() Archiver

+ func (cd *ContractNegotiationFinalized) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationFinalized) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationFinalized) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationFinalized) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationInitial struct

+ func (cd *ContractNegotiationInitial) GetArchiver() Archiver

+ func (cd *ContractNegotiationInitial) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationInitial) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationInitial) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationInitial) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationOffered struct

+ func (cd *ContractNegotiationOffered) GetArchiver() Archiver

+ func (cd *ContractNegotiationOffered) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationOffered) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationOffered) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationOffered) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationRequested struct

+ func (cd *ContractNegotiationRequested) GetArchiver() Archiver

+ func (cd *ContractNegotiationRequested) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationRequested) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationRequested) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationRequested) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationState interface

+ GetArchiver func() Archiver

+ GetProvider func() providerv1.ProviderServiceClient

+ GetReconciler func() *Reconciler

+ Recv func(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ Send func(ctx context.Context) (func(), error)

+ func GetContractNegotiation(ctx context.Context, store Archiver, c *Contract, ...) (context.Context, ContractNegotiationState)

+ func NewContract(ctx context.Context, store Archiver, provider providerv1.ProviderServiceClient, ...) (context.Context, ContractNegotiationState, error)

+ type ContractNegotiationTerminated struct

+ func (cd *ContractNegotiationTerminated) GetArchiver() Archiver

+ func (cd *ContractNegotiationTerminated) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationTerminated) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationTerminated) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationTerminated) Send(ctx context.Context) (func(), error)

+ type ContractNegotiationVerified struct

+ func (cd *ContractNegotiationVerified) GetArchiver() Archiver

+ func (cd *ContractNegotiationVerified) GetProvider() providerv1.ProviderServiceClient

+ func (cd *ContractNegotiationVerified) GetReconciler() *Reconciler

+ func (cn *ContractNegotiationVerified) Recv(ctx context.Context, message any) (context.Context, ContractNegotiationState, error)

+ func (cn *ContractNegotiationVerified) Send(ctx context.Context) (func(), error)

+ type ContractState struct

+ func ParseContractState(a any) (ContractState, error)

+ func (i ContractState) String() string

+ func (p *ContractState) Scan(value any) error

+ func (p *ContractState) UnmarshalJSON(b []byte) error

+ func (p ContractState) IsValid() bool

+ func (p ContractState) MarshalJSON() ([]byte, error)

+ func (p ContractState) Value() (driver.Value, error)

+ type Contracter interface

+ GetCallback func() *url.URL

+ GetConsumerPID func() uuid.UUID

+ GetContract func() *Contract

+ GetContractNegotiation func() shared.ContractNegotiation

+ GetOffer func() odrl.Offer

+ GetProviderPID func() uuid.UUID

+ GetSelf func() *url.URL

+ GetState func() ContractState

+ SetCallback func(u string) error

+ SetState func(state ContractState) error

+ type DataspaceRole int8

+ const DataspaceConsumer

+ const DataspaceProvider

+ type MemoryArchiver struct

+ func NewMemoryArchiver() *MemoryArchiver

+ func (ma *MemoryArchiver) DelAgreement(ctx context.Context, agreementID uuid.UUID) error

+ func (ma *MemoryArchiver) GetAgreement(ctx context.Context, agreementID uuid.UUID) (*odrl.Agreement, error)

+ func (ma *MemoryArchiver) GetConsumerContract(ctx context.Context, pid uuid.UUID) (*Contract, error)

+ func (ma *MemoryArchiver) GetConsumerTransfer(ctx context.Context, pid uuid.UUID) (*TransferRequest, error)

+ func (ma *MemoryArchiver) GetProviderContract(ctx context.Context, pid uuid.UUID) (*Contract, error)

+ func (ma *MemoryArchiver) GetProviderTransfer(ctx context.Context, pid uuid.UUID) (*TransferRequest, error)

+ func (ma *MemoryArchiver) PutAgreement(ctx context.Context, agreement *odrl.Agreement) error

+ func (ma *MemoryArchiver) PutConsumerContract(ctx context.Context, contract *Contract) error

+ func (ma *MemoryArchiver) PutConsumerTransfer(ctx context.Context, transfer *TransferRequest) error

+ func (ma *MemoryArchiver) PutProviderContract(ctx context.Context, contract *Contract) error

+ func (ma *MemoryArchiver) PutProviderTransfer(ctx context.Context, transfer *TransferRequest) error

+ type Reconciler struct

+ func NewReconciler(ctx context.Context, r shared.Requester, a Archiver) *Reconciler

+ func (r *Reconciler) Add(entry ReconciliationEntry)

+ func (r *Reconciler) Run()

+ type ReconciliationEntry struct

+ Attempts int

+ Body []byte

+ Context context.Context

+ EntityID uuid.UUID

+ Method string

+ NextAttempt time.Time

+ Role DataspaceRole

+ TargetState string

+ Type ReconciliationType

+ URL *url.URL

+ type ReconciliationType uint

+ const ReconciliationContract

+ const ReconciliationTransferRequest

+ const ReconciliationUndefined

+ type TransferDirection uint8

+ const DirectionPull

+ const DirectionPush

+ const DirectionUnknown

+ type TransferRequest struct

+ func (tr *TransferRequest) GetAgreementID() uuid.UUID

+ func (tr *TransferRequest) GetCallback() *url.URL

+ func (tr *TransferRequest) GetConsumerPID() uuid.UUID

+ func (tr *TransferRequest) GetFormat() string

+ func (tr *TransferRequest) GetProviderPID() uuid.UUID

+ func (tr *TransferRequest) GetPublishInfo() *providerv1.PublishInfo

+ func (tr *TransferRequest) GetRole() DataspaceRole

+ func (tr *TransferRequest) GetSelf() *url.URL

+ func (tr *TransferRequest) GetState() TransferRequestState

+ func (tr *TransferRequest) GetTarget() string

+ func (tr *TransferRequest) GetTransferDirection() TransferDirection

+ func (tr *TransferRequest) GetTransferProcess() shared.TransferProcess

+ func (tr *TransferRequest) GetTransferRequest() *TransferRequest

+ func (tr *TransferRequest) SetState(state TransferRequestState) error

+ type TransferRequestNegotiationCompleted struct

+ func (cd *TransferRequestNegotiationCompleted) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationCompleted) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationCompleted) GetReconciler() *Reconciler

+ func (tr *TransferRequestNegotiationCompleted) Recv(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ func (tr *TransferRequestNegotiationCompleted) Send(ctx context.Context) (func(), error)

+ type TransferRequestNegotiationInitial struct

+ func (cd *TransferRequestNegotiationInitial) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationInitial) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationInitial) GetReconciler() *Reconciler

+ func (tr *TransferRequestNegotiationInitial) Recv(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ func (tr *TransferRequestNegotiationInitial) Send(ctx context.Context) (func(), error)

+ type TransferRequestNegotiationRequested struct

+ func (cd *TransferRequestNegotiationRequested) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationRequested) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationRequested) GetReconciler() *Reconciler

+ func (tr *TransferRequestNegotiationRequested) Recv(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ func (tr *TransferRequestNegotiationRequested) Send(ctx context.Context) (func(), error)

+ type TransferRequestNegotiationStarted struct

+ func (cd *TransferRequestNegotiationStarted) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationStarted) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationStarted) GetReconciler() *Reconciler

+ func (tr *TransferRequestNegotiationStarted) Recv(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ func (tr *TransferRequestNegotiationStarted) Send(ctx context.Context) (func(), error)

+ type TransferRequestNegotiationState interface

+ GetArchiver func() Archiver

+ GetProvider func() providerv1.ProviderServiceClient

+ GetReconciler func() *Reconciler

+ Recv func(ctx context.Context, message any) (TransferRequestNegotiationState, error)

+ Send func(ctx context.Context) (func(), error)

+ func GetTransferRequestNegotiation(a Archiver, tr *TransferRequest, p providerv1.ProviderServiceClient, ...) TransferRequestNegotiationState

+ func NewTransferRequest(ctx context.Context, store Archiver, provider providerv1.ProviderServiceClient, ...) (TransferRequestNegotiationState, error)

+ type TransferRequestNegotiationSuspended struct

+ func (cd *TransferRequestNegotiationSuspended) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationSuspended) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationSuspended) GetReconciler() *Reconciler

+ type TransferRequestNegotiationTerminated struct

+ func (cd *TransferRequestNegotiationTerminated) GetArchiver() Archiver

+ func (cd *TransferRequestNegotiationTerminated) GetProvider() providerv1.ProviderServiceClient

+ func (cd *TransferRequestNegotiationTerminated) GetReconciler() *Reconciler

+ type TransferRequestState struct

+ func ParseTransferRequestState(a any) (TransferRequestState, error)

+ func (i TransferRequestState) String() string

+ func (p *TransferRequestState) Scan(value any) error

+ func (p *TransferRequestState) UnmarshalJSON(b []byte) error

+ func (p TransferRequestState) IsValid() bool

+ func (p TransferRequestState) MarshalJSON() ([]byte, error)

+ func (p TransferRequestState) Value() (driver.Value, error)

+ type TransferRequester interface

+ GetAgreementID func() uuid.UUID

+ GetCallback func() *url.URL

+ GetConsumerPID func() uuid.UUID

+ GetFormat func() string

+ GetProviderPID func() uuid.UUID

+ GetPublishInfo func() *providerv1.PublishInfo

+ GetRole func() DataspaceRole

+ GetSelf func() *url.URL

+ GetState func() TransferRequestState

+ GetTarget func() string

+ GetTransferDirection func() TransferDirection

+ GetTransferProcess func() shared.TransferProcess

+ GetTransferRequest func() *TransferRequest

+ SetState func(state TransferRequestState) error

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