poster

type Broadcaster interface {
	Broadcast(context.Context, ...sdk.Msg) (*sdk.TxResponse, error)
}

type Decision struct {
	Post   bool
	Reason DecisionReason
}

type DecisionInput struct {
	SnapshotHash       []byte
	Record             *verificationv1.ProviderSnapshotRecord
	Now                time.Time
	PostBeforeDeadline time.Duration
}

type DecisionReason string

type PreparedSnapshotHash struct {
	Snapshot *aepinventory.Snapshot
	Payload  inventoryv1.SnapshotPayload
	Msg      *verificationv1.MsgPostSnapshotHash
}

type QueryClient interface {
	ProviderSnapshot(context.Context, string) (*verificationv1.ProviderSnapshotRecord, error)
	Params(context.Context) (verificationv1.Params, error)
}

type RunOnceResult struct {
	Prepared *PreparedSnapshotHash
	Params   verificationv1.Params
	Record   *verificationv1.ProviderSnapshotRecord
	Decision Decision
	State    State
	Response *sdk.TxResponse
}

type Runner struct {
	// contains filtered or unexported fields
}

type RunnerConfig struct {
	Snapshotter        Snapshotter
	Query              QueryClient
	Broadcaster        Broadcaster
	State              StateStore
	Log                log.Logger
	Interval           time.Duration
	IntervalJitter     time.Duration
	RetryDelay         time.Duration
	RetryJitter        time.Duration
	MaxRetries         uint
	PostBeforeDeadline time.Duration
	Now                func() time.Time
}

type Snapshotter interface {
	Build(context.Context, aepinventory.SnapshotRequest) (*aepinventory.Snapshot, error)
}

type State struct {
	Version            uint32                         `json:"version"`
	HashDomain         string                         `json:"hash_domain"`
	Provider           string                         `json:"provider"`
	SnapshotHash       []byte                         `json:"snapshot_hash,omitempty"`
	SnapshotTimestamp  time.Time                      `json:"snapshot_timestamp,omitempty"`
	ResourceSummary    verificationv1.ResourceSummary `json:"resource_summary"`
	ComplianceDeadline time.Time                      `json:"compliance_deadline,omitempty"`
	Suspended          bool                           `json:"suspended"`
	LastDecision       string                         `json:"last_decision,omitempty"`
	LastTxHash         string                         `json:"last_tx_hash,omitempty"`
	LastAttemptAt      time.Time                      `json:"last_attempt_at,omitempty"`
	LastSuccessAt      time.Time                      `json:"last_success_at,omitempty"`
	LastError          string                         `json:"last_error,omitempty"`
}

type StateStore interface {
	Set(context.Context, State) error
	Get(context.Context) (State, error)
}