scheduled

Documentation

Index

• Variables
• type Action
  • func ParseAction(s string) (Action, error)
  • func (i Action) IsExpireDonorIdentity() bool
  • func (i Action) MarshalText() ([]byte, error)
  • func (i Action) String() string
  • func (i *Action) UnmarshalText(text []byte) error
• type ActionFunc
• type ActionOptions
• type DonorStore
• type DynamoClient
• type Event
• type Logger
• type MetricsClient
• type NotifyClient
• type Runner
  • func NewRunner(logger Logger, store ScheduledStore, donorStore DonorStore, ...) *Runner
  • func (r *Runner) Errored()
  • func (r *Runner) Ignored()
  • func (r *Runner) Metrics(processingTime time.Duration) cloudwatch.PutMetricDataInput
  • func (r *Runner) Processed()
  • func (r *Runner) Run(ctx context.Context) error
• type ScheduledStore
• type Store
  • func NewStore(dynamoClient DynamoClient) *Store
  • func (s *Store) Pop(ctx context.Context, day time.Time) (*Event, error)
  • func (s *Store) Put(ctx context.Context, row Event) error
• type Waiter

Variables

var ActionValues = ActionOptions{
	ExpireDonorIdentity: ActionExpireDonorIdentity,
}

Types

type Action

type Action uint8

const (
	// ActionExpireDonorIdentity will check that the target donor has not signed
	// their LPA, and if so remove their identity data and notify them of the
	// change.
	ActionExpireDonorIdentity Action = iota + 1
)

func ParseAction

func ParseAction(s string) (Action, error)

func (Action) IsExpireDonorIdentity

func (i Action) IsExpireDonorIdentity() bool

func (Action) MarshalText

func (i Action) MarshalText() ([]byte, error)

func (Action) String

func (i Action) String() string

func (*Action) UnmarshalText

func (i *Action) UnmarshalText(text []byte) error

type ActionFunc

type ActionFunc func(ctx context.Context, row *Event) error

type ActionOptions

type ActionOptions struct {
	ExpireDonorIdentity Action
}

type DonorStore

type DonorStore interface {
	One(ctx context.Context, pk dynamo.LpaKeyType, sk dynamo.SK) (*donordata.Provided, error)
	Put(ctx context.Context, provided *donordata.Provided) error
}

type DynamoClient

type DynamoClient interface {
	Move(ctx context.Context, oldKeys dynamo.Keys, value any) error
	AnyByPK(ctx context.Context, pk dynamo.PK, v interface{}) error
	Put(ctx context.Context, v interface{}) error
}

type Event

type Event struct {
	PK dynamo.ScheduledDayKeyType
	SK dynamo.ScheduledKeyType
	// CreatedAt is when the event was created
	CreatedAt time.Time
	// At is when the action should be done
	At time.Time
	// Action is what to do when run
	Action Action
	// TargetLpaKey is used to specify the target of the action
	TargetLpaKey dynamo.LpaKeyType
	// TargetLpaOwnerKey is used to specify the target of the action
	TargetLpaOwnerKey dynamo.LpaOwnerKeyType
}

A Event specifies an action to take in the future.

type Logger

type Logger interface {
	InfoContext(ctx context.Context, msg string, args ...any)
	ErrorContext(ctx context.Context, msg string, args ...any)
}

type MetricsClient

type MetricsClient interface {
	PutMetrics(ctx context.Context, input *cloudwatch.PutMetricDataInput) error
}

type NotifyClient

type NotifyClient interface {
	SendActorEmail(ctx context.Context, lang localize.Lang, to, lpaUID string, email notify.Email) error
}

type Runner

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

func NewRunner

func NewRunner(logger Logger, store ScheduledStore, donorStore DonorStore, notifyClient NotifyClient, metricsClient MetricsClient, metricsEnabled bool) *Runner

func (*Runner) Errored

func (r *Runner) Errored()

func (*Runner) Ignored

func (r *Runner) Ignored()

func (*Runner) Metrics

func (r *Runner) Metrics(processingTime time.Duration) cloudwatch.PutMetricDataInput

func (*Runner) Processed

func (r *Runner) Processed()

func (*Runner) Run

func (r *Runner) Run(ctx context.Context) error

type ScheduledStore

type ScheduledStore interface {
	Pop(ctx context.Context, at time.Time) (*Event, error)
}

type Store

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

func NewStore

func NewStore(dynamoClient DynamoClient) *Store

func (*Store) Pop

func (s *Store) Pop(ctx context.Context, day time.Time) (*Event, error)

func (*Store) Put

func (s *Store) Put(ctx context.Context, row Event) error

type Waiter

type Waiter interface {
	Reset()
	Wait() error
}