state

Documentation

Index

• Constants
• type Repository
• type RepositoryRedis
  • func (r RepositoryRedis) GetByID(ctx context.Context, key string) (State, error)
  • func (r RepositoryRedis) Save(ctx context.Context, item State) error
• type Service
  • func (s Service[T]) Create(ctx context.Context, resourceID string) error
  • func (s Service[T]) Get(ctx context.Context, resourceID string) (State, error)
  • func (s Service[T]) MarkAsCompleted(ctx context.Context, resourceID string) error
  • func (s Service[T]) MarkAsFailed(ctx context.Context, resourceID string, procErr error) error
• type State
  • func (s *State) View() View
• type View

Constants

const (
	StatusRunning   = "RUNNING"
	StatusCompleted = "COMPLETED"
	StatusFailed    = "FAILED"
)

Types

type Repository

type Repository interface {
	Save(ctx context.Context, item State) error
	GetByID(ctx context.Context, key string) (State, error)
}

type RepositoryRedis

type RepositoryRedis struct {
	Config boltzmann.RepositoryConfig
	Codec  codec.Msgpack
	RDB    redis.UniversalClient
}

func (RepositoryRedis) GetByID

func (r RepositoryRedis) GetByID(ctx context.Context, key string) (State, error)

func (RepositoryRedis) Save

func (r RepositoryRedis) Save(ctx context.Context, item State) error

type Service

type Service[T any] struct {
	Repository Repository
}

func (Service[T]) Create

func (s Service[T]) Create(ctx context.Context, resourceID string) error

func (Service[T]) Get

func (s Service[T]) Get(ctx context.Context, resourceID string) (State, error)

func (Service[T]) MarkAsCompleted

func (s Service[T]) MarkAsCompleted(ctx context.Context, resourceID string) error

func (Service[T]) MarkAsFailed

func (s Service[T]) MarkAsFailed(ctx context.Context, resourceID string, procErr error) error

type State

type State struct {
	StateID           string
	ResourceName      string
	ResourceID        string
	Status            string
	StartTime         time.Time
	EndTime           time.Time
	ExecutionDuration time.Duration
	ExecutionError    string
}

func (*State) View

func (s *State) View() View

type View

type View struct {
	StateID                 string        `json:"state_id"`
	ResourceName            string        `json:"resource_name"`
	ResourceID              string        `json:"resource_id"`
	Status                  string        `json:"status"`
	StartTime               time.Time     `json:"start_time"`
	StartTimeMillis         int64         `json:"start_time_millis"`
	EndTime                 time.Time     `json:"end_time"`
	EndTimeMillis           int64         `json:"end_time_millis"`
	ExecutionDuration       time.Duration `json:"execution_duration"`
	ExecutionDurationMillis int64         `json:"execution_duration_millis"`
	ExecutionError          string        `json:"execution_error"`
}