protocol

Mar 2, 2021

Changes in this version

+ const DebugHumanized

+ const DebugNone

+ const DebugNormal

+ func NewDataConverter(fallback converter.DataConverter) converter.DataConverter

+ type ActivityInfo struct

+ Name string

+ type Cancel struct

+ CommandIDs []uint64

+ type CancelExternalWorkflow struct

+ Namespace string

+ RunID string

+ WorkflowID string

+ type CancelWorkflow struct

+ RunID string

+ type Codec interface

+ Execute func(e Endpoint, ctx Context, msg ...Message) ([]Message, error)

+ GetName func() string

+ WithLogger func(logger.Logger) Codec

+ func NewJSONCodec(level DebugLevel, logger logger.Logger) Codec

+ func NewProtoCodec() Codec

+ type CompleteWorkflow struct

+ type Context struct

+ Replay bool

+ TaskQueue string

+ TickTime string

+ func (ctx Context) IsEmpty() bool

+ type ContinueAsNew struct

+ Name string

+ Options struct{ ... }

+ type DataConverter struct

+ func (r *DataConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error

+ func (r *DataConverter) FromPayloads(payloads *commonpb.Payloads, valuePtrs ...interface{}) error

+ func (r *DataConverter) ToPayload(value interface{}) (*commonpb.Payload, error)

+ func (r *DataConverter) ToPayloads(values ...interface{}) (*commonpb.Payloads, error)

+ func (r *DataConverter) ToString(input *commonpb.Payload) string

+ func (r *DataConverter) ToStrings(input *commonpb.Payloads) []string

+ type DebugLevel int

+ type DestroyWorkflow struct

+ RunID string

+ type Endpoint interface

+ Exec func(p payload.Payload) (payload.Payload, error)

+ type ExecuteActivity struct

+ Name string

+ Options bindings.ExecuteActivityOptions

+ func (cmd ExecuteActivity) ActivityParams(env bindings.WorkflowEnvironment, payloads *commonpb.Payloads) bindings.ExecuteActivityParams

+ type ExecuteChildWorkflow struct

+ Name string

+ Options bindings.WorkflowOptions

+ func (cmd ExecuteChildWorkflow) WorkflowParams(env bindings.WorkflowEnvironment, payloads *commonpb.Payloads) bindings.ExecuteWorkflowParams

+ type GetChildWorkflowExecution struct

+ ID uint64

+ type GetStackTrace struct

+ RunID string

+ type GetVersion struct

+ ChangeID string

+ MaxSupported int

+ MinSupported int

+ type GetWorkerInfo struct

+ type InvokeActivity struct

+ HeartbeatDetails int

+ Info activity.Info

+ Name string

+ type InvokeQuery struct

+ Name string

+ RunID string

+ type InvokeSignal struct

+ Name string

+ RunID string

+ type JSONCodec struct

+ func (c *JSONCodec) Execute(e Endpoint, ctx Context, msg ...Message) ([]Message, error)

+ func (c *JSONCodec) GetName() string

+ func (c *JSONCodec) WithLogger(logger logger.Logger) Codec

+ type Message struct

+ Command interface{}

+ Failure *failure.Failure

+ ID uint64

+ Payloads *commonpb.Payloads

+ func (msg Message) IsCommand() bool

+ type NewTimer struct

+ Milliseconds int

+ func (cmd NewTimer) ToDuration() time.Duration

+ type Panic struct

+ Message string

+ type ProtoCodec struct

+ func (c *ProtoCodec) Execute(e Endpoint, ctx Context, msg ...Message) ([]Message, error)

+ func (c *ProtoCodec) GetName() string

+ func (c *ProtoCodec) WithLogger(logger logger.Logger) Codec

+ type SideEffect struct

+ type SignalExternalWorkflow struct

+ ChildWorkflowOnly bool

+ Namespace string

+ RunID string

+ Signal string

+ WorkflowID string

+ type StartWorkflow struct

+ Info *workflow.Info

+ LastCompletion int

+ type WorkerInfo struct

+ Activities []ActivityInfo

+ Options worker.Options

+ TaskQueue string

+ Workflows []WorkflowInfo

+ func FetchWorkerInfo(c Codec, e Endpoint, dc converter.DataConverter) ([]WorkerInfo, error)

+ type WorkflowInfo struct

+ Name string

+ Queries []string

+ Signals []string