entity

Documentation

Index

• type ConcreteExecution
  • func (ConcreteExecution) Clone() Entity
  • func (ce *ConcreteExecution) GetDomainID() string
  • func (ce *ConcreteExecution) GetShardID() int
  • func (ce *ConcreteExecution) Validate() error
• type CurrentExecution
  • func (CurrentExecution) Clone() Entity
  • func (curre *CurrentExecution) GetDomainID() string
  • func (curre *CurrentExecution) GetShardID() int
  • func (curre *CurrentExecution) Validate() error
• type Entity
• type Execution
• type Timer
  • func (t *Timer) Clone() Entity
  • func (t *Timer) GetDomainID() string
  • func (t *Timer) GetShardID() int
  • func (t *Timer) Validate() error

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

func (ce *ConcreteExecution) GetDomainID() string

GetDomainID returns the domain id

func (*ConcreteExecution) GetShardID

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

func (curre *CurrentExecution) GetDomainID() string

GetDomainID returns the domain id

func (*CurrentExecution) GetShardID

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

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

func (t *Timer) Clone() Entity

func (*Timer) GetDomainID

func (t *Timer) GetDomainID() string

func (*Timer) GetShardID

func (t *Timer) GetShardID() int

func (*Timer) Validate

func (t *Timer) Validate() error