definitions

Documentation

Index

• type DefinitionBatchState
• type DefinitionHandler
  • func NewDefinitionHandler(ctx context.Context, di database.Plugin, bi blockchain.Plugin, ...) (DefinitionHandler, error)
• type DefinitionMessageAction
  • func (dma DefinitionMessageAction) String() string
• type HandlerResult

Types

type DefinitionBatchState

type DefinitionBatchState interface {
	// PreFinalize may perform a blocking action (possibly to an external connector) that should execute outside database RunAsGroup
	AddPreFinalize(func(ctx context.Context) error)

	// Finalize may perform final, non-idempotent database operations (such as inserting Events)
	AddFinalize(func(ctx context.Context) error)

	// GetPendingConfirm returns a map of messages are that pending confirmation after already being processed in this batch
	GetPendingConfirm() map[fftypes.UUID]*core.Message

	// Notify of a DID claim locking in, so a rewind gets queued for it to go back and process any dependent child identities/messages
	DIDClaimConfirmed(did string)
}

DefinitionBatchState tracks the state between definition handlers that run in-line on the pin processing route in the aggregator as part of a batch of pins. They might have complex API calls, and interdependencies, that need to be managed via this state. The actions to be taken at the end of a definition batch. See further notes on "batchState" in the event aggregator

type DefinitionHandler

type DefinitionHandler interface {
	HandleDefinitionBroadcast(ctx context.Context, state DefinitionBatchState, msg *core.Message, data core.DataArray, tx *fftypes.UUID) (HandlerResult, error)
}

func NewDefinitionHandler

func NewDefinitionHandler(ctx context.Context, di database.Plugin, bi blockchain.Plugin, dx dataexchange.Plugin, dm data.Manager, im identity.Manager, am assets.Manager, cm contracts.Manager) (DefinitionHandler, error)

type DefinitionMessageAction

type DefinitionMessageAction int

DefinitionMessageAction is the action to be taken on an individual definition message

const (
	// ActionReject the message was successfully processed, but was malformed/invalid and should be marked as rejected
	ActionReject DefinitionMessageAction = iota

	// ActionConfirm the message was valid and should be confirmed
	ActionConfirm

	// ActionRetry a recoverable error was encountered - batch should be halted and then re-processed from the start
	ActionRetry

	// ActionWait the message is still awaiting further pieces for aggregation and should be held in pending state
	ActionWait
)

func (DefinitionMessageAction) String

func (dma DefinitionMessageAction) String() string

type HandlerResult

type HandlerResult struct {
	Action           DefinitionMessageAction
	CustomCorrelator *fftypes.UUID
}