common

package
Version: v1.7.0 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2021 License: MIT Imports: 14 Imported by: 75

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ActivityType

type ActivityType struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

Represents the identifier used by a activity author to define the activity. Typically, the name of a function. This is sometimes referred to as the activity's "name"

func (*ActivityType) Descriptor

func (*ActivityType) Descriptor() ([]byte, []int)

func (*ActivityType) Equal

func (this *ActivityType) Equal(that interface{}) bool

func (*ActivityType) GetName

func (m *ActivityType) GetName() string

func (*ActivityType) GoString

func (this *ActivityType) GoString() string

func (*ActivityType) Marshal

func (m *ActivityType) Marshal() (dAtA []byte, err error)

func (*ActivityType) MarshalTo

func (m *ActivityType) MarshalTo(dAtA []byte) (int, error)

func (*ActivityType) MarshalToSizedBuffer

func (m *ActivityType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivityType) ProtoMessage

func (*ActivityType) ProtoMessage()

func (*ActivityType) Reset

func (m *ActivityType) Reset()

func (*ActivityType) Size

func (m *ActivityType) Size() (n int)

func (*ActivityType) String

func (this *ActivityType) String() string

func (*ActivityType) Unmarshal

func (m *ActivityType) Unmarshal(dAtA []byte) error

func (*ActivityType) XXX_DiscardUnknown

func (m *ActivityType) XXX_DiscardUnknown()

func (*ActivityType) XXX_Marshal

func (m *ActivityType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivityType) XXX_Merge

func (m *ActivityType) XXX_Merge(src proto.Message)

func (*ActivityType) XXX_Size

func (m *ActivityType) XXX_Size() int

func (*ActivityType) XXX_Unmarshal

func (m *ActivityType) XXX_Unmarshal(b []byte) error

type DataBlob

type DataBlob struct {
	EncodingType v1.EncodingType `` /* 138-byte string literal not displayed */
	Data         []byte          `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*DataBlob) Descriptor

func (*DataBlob) Descriptor() ([]byte, []int)

func (*DataBlob) Equal

func (this *DataBlob) Equal(that interface{}) bool

func (*DataBlob) GetData

func (m *DataBlob) GetData() []byte

func (*DataBlob) GetEncodingType

func (m *DataBlob) GetEncodingType() v1.EncodingType

func (*DataBlob) GoString

func (this *DataBlob) GoString() string

func (*DataBlob) Marshal

func (m *DataBlob) Marshal() (dAtA []byte, err error)

func (*DataBlob) MarshalTo

func (m *DataBlob) MarshalTo(dAtA []byte) (int, error)

func (*DataBlob) MarshalToSizedBuffer

func (m *DataBlob) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DataBlob) ProtoMessage

func (*DataBlob) ProtoMessage()

func (*DataBlob) Reset

func (m *DataBlob) Reset()

func (*DataBlob) Size

func (m *DataBlob) Size() (n int)

func (*DataBlob) String

func (this *DataBlob) String() string

func (*DataBlob) Unmarshal

func (m *DataBlob) Unmarshal(dAtA []byte) error

func (*DataBlob) XXX_DiscardUnknown

func (m *DataBlob) XXX_DiscardUnknown()

func (*DataBlob) XXX_Marshal

func (m *DataBlob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataBlob) XXX_Merge

func (m *DataBlob) XXX_Merge(src proto.Message)

func (*DataBlob) XXX_Size

func (m *DataBlob) XXX_Size() int

func (*DataBlob) XXX_Unmarshal

func (m *DataBlob) XXX_Unmarshal(b []byte) error
type Header struct {
	Fields map[string]*Payload `` /* 153-byte string literal not displayed */
}

Contains metadata that can be attached to a variety of requests, like starting a workflow, and can be propagated between, for example, workflows and activities.

func (*Header) Descriptor

func (*Header) Descriptor() ([]byte, []int)

func (*Header) Equal

func (this *Header) Equal(that interface{}) bool

func (*Header) GetFields

func (m *Header) GetFields() map[string]*Payload

func (*Header) GoString

func (this *Header) GoString() string

func (*Header) Marshal

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalTo

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) MarshalToSizedBuffer

func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) Size

func (m *Header) Size() (n int)

func (*Header) String

func (this *Header) String() string

func (*Header) Unmarshal

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) XXX_DiscardUnknown

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal

func (m *Header) XXX_Unmarshal(b []byte) error

type Memo

type Memo struct {
	Fields map[string]*Payload `` /* 153-byte string literal not displayed */
}

A user-defined set of *unindexed* fields that are exposed when listing/searching workflows

func (*Memo) Descriptor

func (*Memo) Descriptor() ([]byte, []int)

func (*Memo) Equal

func (this *Memo) Equal(that interface{}) bool

func (*Memo) GetFields

func (m *Memo) GetFields() map[string]*Payload

func (*Memo) GoString

func (this *Memo) GoString() string

func (*Memo) Marshal

func (m *Memo) Marshal() (dAtA []byte, err error)

func (*Memo) MarshalTo

func (m *Memo) MarshalTo(dAtA []byte) (int, error)

func (*Memo) MarshalToSizedBuffer

func (m *Memo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Memo) ProtoMessage

func (*Memo) ProtoMessage()

func (*Memo) Reset

func (m *Memo) Reset()

func (*Memo) Size

func (m *Memo) Size() (n int)

func (*Memo) String

func (this *Memo) String() string

func (*Memo) Unmarshal

func (m *Memo) Unmarshal(dAtA []byte) error

func (*Memo) XXX_DiscardUnknown

func (m *Memo) XXX_DiscardUnknown()

func (*Memo) XXX_Marshal

func (m *Memo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Memo) XXX_Merge

func (m *Memo) XXX_Merge(src proto.Message)

func (*Memo) XXX_Size

func (m *Memo) XXX_Size() int

func (*Memo) XXX_Unmarshal

func (m *Memo) XXX_Unmarshal(b []byte) error

type Payload

type Payload struct {
	Metadata map[string][]byte `` /* 157-byte string literal not displayed */
	Data     []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

Represents some binary (byte array) data (ex: activity input parameters or workflow result) with metadata which describes this binary data (format, encoding, encryption, etc). Serialization of the data may be user-defined.

func (*Payload) Descriptor

func (*Payload) Descriptor() ([]byte, []int)

func (*Payload) Equal

func (this *Payload) Equal(that interface{}) bool

func (*Payload) GetData

func (m *Payload) GetData() []byte

func (*Payload) GetMetadata

func (m *Payload) GetMetadata() map[string][]byte

func (*Payload) GoString

func (this *Payload) GoString() string

func (*Payload) Marshal

func (m *Payload) Marshal() (dAtA []byte, err error)

func (*Payload) MarshalTo

func (m *Payload) MarshalTo(dAtA []byte) (int, error)

func (*Payload) MarshalToSizedBuffer

func (m *Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) Size

func (m *Payload) Size() (n int)

func (*Payload) String

func (this *Payload) String() string

func (*Payload) Unmarshal

func (m *Payload) Unmarshal(dAtA []byte) error

func (*Payload) XXX_DiscardUnknown

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal

func (m *Payload) XXX_Unmarshal(b []byte) error

type Payloads

type Payloads struct {
	Payloads []*Payload `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
}

See `Payload`

func (*Payloads) Descriptor

func (*Payloads) Descriptor() ([]byte, []int)

func (*Payloads) Equal

func (this *Payloads) Equal(that interface{}) bool

func (*Payloads) GetPayloads

func (m *Payloads) GetPayloads() []*Payload

func (*Payloads) GoString

func (this *Payloads) GoString() string

func (*Payloads) Marshal

func (m *Payloads) Marshal() (dAtA []byte, err error)

func (*Payloads) MarshalTo

func (m *Payloads) MarshalTo(dAtA []byte) (int, error)

func (*Payloads) MarshalToSizedBuffer

func (m *Payloads) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Payloads) ProtoMessage

func (*Payloads) ProtoMessage()

func (*Payloads) Reset

func (m *Payloads) Reset()

func (*Payloads) Size

func (m *Payloads) Size() (n int)

func (*Payloads) String

func (this *Payloads) String() string

func (*Payloads) Unmarshal

func (m *Payloads) Unmarshal(dAtA []byte) error

func (*Payloads) XXX_DiscardUnknown

func (m *Payloads) XXX_DiscardUnknown()

func (*Payloads) XXX_Marshal

func (m *Payloads) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payloads) XXX_Merge

func (m *Payloads) XXX_Merge(src proto.Message)

func (*Payloads) XXX_Size

func (m *Payloads) XXX_Size() int

func (*Payloads) XXX_Unmarshal

func (m *Payloads) XXX_Unmarshal(b []byte) error

type RetryPolicy

type RetryPolicy struct {
	// Interval of the first retry. If retryBackoffCoefficient is 1.0 then it is used for all retries.
	InitialInterval *time.Duration `protobuf:"bytes,1,opt,name=initial_interval,json=initialInterval,proto3,stdduration" json:"initial_interval,omitempty"`
	// Coefficient used to calculate the next retry interval.
	// The next retry interval is previous interval multiplied by the coefficient.
	// Must be 1 or larger.
	BackoffCoefficient float64 `protobuf:"fixed64,2,opt,name=backoff_coefficient,json=backoffCoefficient,proto3" json:"backoff_coefficient,omitempty"`
	// Maximum interval between retries. Exponential backoff leads to interval increase.
	// This value is the cap of the increase. Default is 100x of the initial interval.
	MaximumInterval *time.Duration `protobuf:"bytes,3,opt,name=maximum_interval,json=maximumInterval,proto3,stdduration" json:"maximum_interval,omitempty"`
	// Maximum number of attempts. When exceeded the retries stop even if not expired yet.
	// 1 disables retries. 0 means unlimited (up to the timeouts)
	MaximumAttempts int32 `protobuf:"varint,4,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	// Non-Retryable errors types. Will stop retrying if the error type matches this list. Note that
	// this is not a substring match, the error *type* (not message) must match exactly.
	NonRetryableErrorTypes []string `` /* 131-byte string literal not displayed */
}

How retries ought to be handled, usable by both workflows and activities

func (*RetryPolicy) Descriptor

func (*RetryPolicy) Descriptor() ([]byte, []int)

func (*RetryPolicy) Equal

func (this *RetryPolicy) Equal(that interface{}) bool

func (*RetryPolicy) GetBackoffCoefficient

func (m *RetryPolicy) GetBackoffCoefficient() float64

func (*RetryPolicy) GetInitialInterval added in v0.28.0

func (m *RetryPolicy) GetInitialInterval() *time.Duration

func (*RetryPolicy) GetMaximumAttempts

func (m *RetryPolicy) GetMaximumAttempts() int32

func (*RetryPolicy) GetMaximumInterval added in v0.28.0

func (m *RetryPolicy) GetMaximumInterval() *time.Duration

func (*RetryPolicy) GetNonRetryableErrorTypes

func (m *RetryPolicy) GetNonRetryableErrorTypes() []string

func (*RetryPolicy) GoString

func (this *RetryPolicy) GoString() string

func (*RetryPolicy) Marshal

func (m *RetryPolicy) Marshal() (dAtA []byte, err error)

func (*RetryPolicy) MarshalTo

func (m *RetryPolicy) MarshalTo(dAtA []byte) (int, error)

func (*RetryPolicy) MarshalToSizedBuffer

func (m *RetryPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RetryPolicy) ProtoMessage

func (*RetryPolicy) ProtoMessage()

func (*RetryPolicy) Reset

func (m *RetryPolicy) Reset()

func (*RetryPolicy) Size

func (m *RetryPolicy) Size() (n int)

func (*RetryPolicy) String

func (this *RetryPolicy) String() string

func (*RetryPolicy) Unmarshal

func (m *RetryPolicy) Unmarshal(dAtA []byte) error

func (*RetryPolicy) XXX_DiscardUnknown

func (m *RetryPolicy) XXX_DiscardUnknown()

func (*RetryPolicy) XXX_Marshal

func (m *RetryPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryPolicy) XXX_Merge

func (m *RetryPolicy) XXX_Merge(src proto.Message)

func (*RetryPolicy) XXX_Size

func (m *RetryPolicy) XXX_Size() int

func (*RetryPolicy) XXX_Unmarshal

func (m *RetryPolicy) XXX_Unmarshal(b []byte) error

type SearchAttributes

type SearchAttributes struct {
	IndexedFields map[string]*Payload `` /* 188-byte string literal not displayed */
}

A user-defined set of *indexed* fields that are used/exposed when listing/searching workflows. The payload is not serialized in a user-defined way.

func (*SearchAttributes) Descriptor

func (*SearchAttributes) Descriptor() ([]byte, []int)

func (*SearchAttributes) Equal

func (this *SearchAttributes) Equal(that interface{}) bool

func (*SearchAttributes) GetIndexedFields

func (m *SearchAttributes) GetIndexedFields() map[string]*Payload

func (*SearchAttributes) GoString

func (this *SearchAttributes) GoString() string

func (*SearchAttributes) Marshal

func (m *SearchAttributes) Marshal() (dAtA []byte, err error)

func (*SearchAttributes) MarshalTo

func (m *SearchAttributes) MarshalTo(dAtA []byte) (int, error)

func (*SearchAttributes) MarshalToSizedBuffer

func (m *SearchAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SearchAttributes) ProtoMessage

func (*SearchAttributes) ProtoMessage()

func (*SearchAttributes) Reset

func (m *SearchAttributes) Reset()

func (*SearchAttributes) Size

func (m *SearchAttributes) Size() (n int)

func (*SearchAttributes) String

func (this *SearchAttributes) String() string

func (*SearchAttributes) Unmarshal

func (m *SearchAttributes) Unmarshal(dAtA []byte) error

func (*SearchAttributes) XXX_DiscardUnknown

func (m *SearchAttributes) XXX_DiscardUnknown()

func (*SearchAttributes) XXX_Marshal

func (m *SearchAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchAttributes) XXX_Merge

func (m *SearchAttributes) XXX_Merge(src proto.Message)

func (*SearchAttributes) XXX_Size

func (m *SearchAttributes) XXX_Size() int

func (*SearchAttributes) XXX_Unmarshal

func (m *SearchAttributes) XXX_Unmarshal(b []byte) error

type WorkflowExecution

type WorkflowExecution struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

Identifies a specific workflow within a namespace. Practically speaking, because run_id is a uuid, a workflow execution is globally unique. Note that many commands allow specifying an empty run id as a way of saying "target the latest run of the workflow".

func (*WorkflowExecution) Descriptor

func (*WorkflowExecution) Descriptor() ([]byte, []int)

func (*WorkflowExecution) Equal

func (this *WorkflowExecution) Equal(that interface{}) bool

func (*WorkflowExecution) GetRunId

func (m *WorkflowExecution) GetRunId() string

func (*WorkflowExecution) GetWorkflowId

func (m *WorkflowExecution) GetWorkflowId() string

func (*WorkflowExecution) GoString

func (this *WorkflowExecution) GoString() string

func (*WorkflowExecution) Marshal

func (m *WorkflowExecution) Marshal() (dAtA []byte, err error)

func (*WorkflowExecution) MarshalTo

func (m *WorkflowExecution) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecution) MarshalToSizedBuffer

func (m *WorkflowExecution) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecution) ProtoMessage

func (*WorkflowExecution) ProtoMessage()

func (*WorkflowExecution) Reset

func (m *WorkflowExecution) Reset()

func (*WorkflowExecution) Size

func (m *WorkflowExecution) Size() (n int)

func (*WorkflowExecution) String

func (this *WorkflowExecution) String() string

func (*WorkflowExecution) Unmarshal

func (m *WorkflowExecution) Unmarshal(dAtA []byte) error

func (*WorkflowExecution) XXX_DiscardUnknown

func (m *WorkflowExecution) XXX_DiscardUnknown()

func (*WorkflowExecution) XXX_Marshal

func (m *WorkflowExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecution) XXX_Merge

func (m *WorkflowExecution) XXX_Merge(src proto.Message)

func (*WorkflowExecution) XXX_Size

func (m *WorkflowExecution) XXX_Size() int

func (*WorkflowExecution) XXX_Unmarshal

func (m *WorkflowExecution) XXX_Unmarshal(b []byte) error

type WorkflowType

type WorkflowType struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

Represents the identifier used by a workflow author to define the workflow. Typically, the name of a function. This is sometimes referred to as the workflow's "name"

func (*WorkflowType) Descriptor

func (*WorkflowType) Descriptor() ([]byte, []int)

func (*WorkflowType) Equal

func (this *WorkflowType) Equal(that interface{}) bool

func (*WorkflowType) GetName

func (m *WorkflowType) GetName() string

func (*WorkflowType) GoString

func (this *WorkflowType) GoString() string

func (*WorkflowType) Marshal

func (m *WorkflowType) Marshal() (dAtA []byte, err error)

func (*WorkflowType) MarshalTo

func (m *WorkflowType) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowType) MarshalToSizedBuffer

func (m *WorkflowType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowType) ProtoMessage

func (*WorkflowType) ProtoMessage()

func (*WorkflowType) Reset

func (m *WorkflowType) Reset()

func (*WorkflowType) Size

func (m *WorkflowType) Size() (n int)

func (*WorkflowType) String

func (this *WorkflowType) String() string

func (*WorkflowType) Unmarshal

func (m *WorkflowType) Unmarshal(dAtA []byte) error

func (*WorkflowType) XXX_DiscardUnknown

func (m *WorkflowType) XXX_DiscardUnknown()

func (*WorkflowType) XXX_Marshal

func (m *WorkflowType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowType) XXX_Merge

func (m *WorkflowType) XXX_Merge(src proto.Message)

func (*WorkflowType) XXX_Size

func (m *WorkflowType) XXX_Size() int

func (*WorkflowType) XXX_Unmarshal

func (m *WorkflowType) XXX_Unmarshal(b []byte) error

Source Files

Jump to

Keyboard shortcuts

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