asyncrecord

Documentation

Index

• type Recorder
  • func New(store *state.Store, runID int64) *Recorder
  • func (r *Recorder) EventSink(ctx context.Context, req executor.Request, requestEvidenceID string, ...) executor.EventSink
  • func (r *Recorder) RecordConfirmationRead(ctx context.Context, req executor.Request, result executor.Result, ...) error
  • func (r *Recorder) RecordRequest(ctx context.Context, req executor.Request) (string, error)
  • func (r *Recorder) RecordResponse(ctx context.Context, req executor.Request, result executor.Result, ...) error
  • func (r *Recorder) RecordStatus(ctx context.Context, req executor.Request, event executor.Event, ...) error

Types

type Recorder

type Recorder struct {
	Store *state.Store
	RunID int64
	// contains filtered or unexported fields
}

func New

func New(store *state.Store, runID int64) *Recorder

func (*Recorder) EventSink

func (r *Recorder) EventSink(ctx context.Context, req executor.Request, requestEvidenceID string, next executor.EventSink) executor.EventSink

func (*Recorder) RecordConfirmationRead

func (r *Recorder) RecordConfirmationRead(ctx context.Context, req executor.Request, result executor.Result, execErr error, requestEvidenceID string) error

func (*Recorder) RecordRequest

func (r *Recorder) RecordRequest(ctx context.Context, req executor.Request) (string, error)

func (*Recorder) RecordResponse

func (r *Recorder) RecordResponse(ctx context.Context, req executor.Request, result executor.Result, execErr error, requestEvidenceID string) error

func (*Recorder) RecordStatus

func (r *Recorder) RecordStatus(ctx context.Context, req executor.Request, event executor.Event, requestEvidenceID string) error