controller

Documentation

Index

• type Handler
  • func New(db *ent.Client, lg *zap.Logger) *Handler
  • func (h Handler) NewError(ctx context.Context, err error) *oas.ErrorStatusCode
  • func (h Handler) Poll(ctx context.Context, params oas.PollParams) (oas.Job, error)
  • func (h Handler) Progress(ctx context.Context, req *oas.Progress, params oas.ProgressParams) (*oas.Status, error)
  • func (h Handler) Run(ctx context.Context) error
  • func (h Handler) Status(ctx context.Context) (*oas.Status, error)
• type State
  • func Ensure(tx *ent.Tx) *State
  • func (s *State) Rollback()

Types

type Handler

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

func New

func New(db *ent.Client, lg *zap.Logger) *Handler

func (Handler) NewError

func (h Handler) NewError(ctx context.Context, err error) *oas.ErrorStatusCode

func (Handler) Poll

func (h Handler) Poll(ctx context.Context, params oas.PollParams) (oas.Job, error)

func (Handler) Progress

func (h Handler) Progress(ctx context.Context, req *oas.Progress, params oas.ProgressParams) (*oas.Status, error)

func (Handler) Run

func (h Handler) Run(ctx context.Context) error

func (Handler) Status

func (h Handler) Status(ctx context.Context) (*oas.Status, error)

type State

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

func Ensure

func Ensure(tx *ent.Tx) *State

Ensure condition on transaction state change.

func (*State) Rollback

func (s *State) Rollback()

Rollback ensures rollback for transactions that are not done.