entity

package
v1.2.11-prerelease7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 21, 2024 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConcreteExecution

type ConcreteExecution struct {
	BranchToken []byte
	TreeID      string
	BranchID    string
	Execution
}

ConcreteExecution is a concrete execution.

func (ConcreteExecution) Clone

func (ConcreteExecution) Clone() Entity

Clone will return a new copy of ConcreteExecution

func (*ConcreteExecution) GetDomainID added in v0.17.0

func (ce *ConcreteExecution) GetDomainID() string

GetDomainID returns the domain id

func (*ConcreteExecution) GetShardID added in v0.16.0

func (ce *ConcreteExecution) GetShardID() int

GetShardID returns shard id

func (*ConcreteExecution) Validate

func (ce *ConcreteExecution) Validate() error

Validate returns an error if ConcreteExecution is not valid, nil otherwise.

type CurrentExecution

type CurrentExecution struct {
	CurrentRunID string
	Execution
}

CurrentExecution is a current execution.

func (CurrentExecution) Clone

func (CurrentExecution) Clone() Entity

Clone will return a new copy of CurrentExecution

func (*CurrentExecution) GetDomainID added in v0.17.0

func (curre *CurrentExecution) GetDomainID() string

GetDomainID returns the domain id

func (*CurrentExecution) GetShardID added in v0.16.0

func (curre *CurrentExecution) GetShardID() int

GetShardID returns shard id

func (*CurrentExecution) Validate

func (curre *CurrentExecution) Validate() error

Validate returns an error if CurrentExecution is not valid, nil otherwise.

type Entity

type Entity interface {
	Validate() error
	Clone() Entity
	GetShardID() int
	GetDomainID() string
}

Entity allows to deserialize and validate different type of executions

type Execution

type Execution struct {
	ShardID    int
	DomainID   string
	WorkflowID string
	RunID      string
	State      int
}

Execution is a base type for executions which should be checked or fixed.

type Timer added in v0.18.0

type Timer struct {
	ShardID             int
	WorkflowID          string
	DomainID            string
	RunID               string
	VisibilityTimestamp time.Time
	TaskID              int64
	TaskType            int
	TimeoutType         int
	EventID             int64
	ScheduleAttempt     int64
	Version             int64
}

Timer is a timer scheduled to be fired

func (*Timer) Clone added in v0.18.0

func (t *Timer) Clone() Entity

func (*Timer) GetDomainID added in v0.18.0

func (t *Timer) GetDomainID() string

func (*Timer) GetShardID added in v0.18.0

func (t *Timer) GetShardID() int

func (*Timer) Validate added in v0.18.0

func (t *Timer) Validate() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL