batchsessionhandler

Documentation

Index

• func JoinBatchSession(ctx context.Context, eventsCh <-chan clientlib.BatchEventChannel, ...) (string, string, time.Duration, []string, *tree.TxTree, error)
• type Args
• type Handler
  • func NewDefaultHandler(args Args) (Handler, error)
• type HandlerOption
  • func WithCancel(cancelCh <-chan struct{}) HandlerOption
  • func WithReplay(ch chan<- any) HandlerOption
  • func WithSkipVtxoTreeSigning() HandlerOption

Functions

func JoinBatchSession

func JoinBatchSession(
	ctx context.Context, eventsCh <-chan clientlib.BatchEventChannel,
	eventsHandler Handler, opts ...HandlerOption,
) (string, string, time.Duration, []string, *tree.TxTree, error)

Types

type Args

type Args struct {
	Client       clientlib.Client
	ServerParams clientlib.ServerParams
	SignTx       clientlib.SignFn

	IntentId       string
	Vtxos          []clientlib.Vtxo
	BoardingUtxos  []clientlib.Utxo
	Receivers      []clientlib.Receiver
	SignerSessions []tree.SignerSession
	// contains filtered or unexported fields
}

type Handler

type Handler interface {
	OnBatchStarted(
		ctx context.Context, event clientlib.BatchStartedEvent,
	) (bool, time.Duration, error)
	OnBatchFinalized(ctx context.Context, event clientlib.BatchFinalizedEvent) error
	OnBatchFailed(ctx context.Context, event clientlib.BatchFailedEvent) error
	OnTreeTxEvent(ctx context.Context, event clientlib.TreeTxEvent) error
	OnTreeSignatureEvent(ctx context.Context, event clientlib.TreeSignatureEvent) error
	OnTreeSigningStarted(
		ctx context.Context, event clientlib.TreeSigningStartedEvent, vtxoTree *tree.TxTree,
	) (bool, error)
	OnTreeNoncesAggregated(
		ctx context.Context,
		event clientlib.TreeNoncesAggregatedEvent,
	) (signed bool, err error)
	OnTreeNonces(ctx context.Context, event clientlib.TreeNoncesEvent) (signed bool, err error)
	OnBatchFinalization(
		ctx context.Context,
		event clientlib.BatchFinalizationEvent, vtxoTree, connectorTree *tree.TxTree,
	) ([]string, error)
	OnStreamStarted(
		ctx context.Context, event clientlib.StreamStartedEvent,
	) error
}

func NewDefaultHandler

func NewDefaultHandler(args Args) (Handler, error)

type HandlerOption

type HandlerOption func(*options)

func WithCancel

func WithCancel(cancelCh <-chan struct{}) HandlerOption

func WithReplay

func WithReplay(ch chan<- any) HandlerOption

func WithSkipVtxoTreeSigning

func WithSkipVtxoTreeSigning() HandlerOption