service

package
v0.2.7 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2023 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewServiceTask 

func NewServiceTask(ctx context.Context, task *schema.ServiceTask) activity.Constructor

Types

type ActiveTrace 

type ActiveTrace struct {
	context.Context
	Activity    activity.Activity
	Headers     map[string]any
	Properties  map[string]any
	DataObjects map[string]any
	// contains filtered or unexported fields
}

func (*ActiveTrace) Do 

func (t *ActiveTrace) Do(options ...DoOption)

func (*ActiveTrace) Execute 

func (t *ActiveTrace) Execute()

func (*ActiveTrace) TraceInterface 

func (t *ActiveTrace) TraceInterface()

type DoOption added in v0.2.7 

type DoOption func(*callResponse)

func WithErrExit added in v0.2.7 

func WithErrExit(err error) DoOption

func WithErrRetry added in v0.2.7 

func WithErrRetry(err error, retries int32) DoOption

func WithErrSkip added in v0.2.7 

func WithErrSkip(err error) DoOption

func WithObjects added in v0.2.7 

func WithObjects(dataObjects map[string]any) DoOption

func WithProperties added in v0.2.7 

func WithProperties(properties map[string]any) DoOption

type ServiceTask 

type ServiceTask struct {
	*flow_node.Wiring
	// contains filtered or unexported fields
}

func (*ServiceTask) Cancel 

func (node *ServiceTask) Cancel() <-chan bool

func (*ServiceTask) Element 

func (node *ServiceTask) Element() schema.FlowNodeInterface

func (*ServiceTask) NextAction 

func (node *ServiceTask) NextAction(flow_interface.T) chan flow_node.IAction

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.