workflows

package
v0.16.0 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2025 License: MIT Imports: 4 Imported by: 0

Documentation

Overview

nolint

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExecutionIterator 

type ExecutionIterator struct {
	// contains filtered or unexported fields
}

func (*ExecutionIterator) Error 

func (it *ExecutionIterator) Error() error

func (*ExecutionIterator) Next 

func (it *ExecutionIterator) Next() bool

func (*ExecutionIterator) Take 

func (it *ExecutionIterator) Take(size int64) ([]*workflows.ExecutionPreview, error)

func (*ExecutionIterator) TakeAll 

func (it *ExecutionIterator) TakeAll() ([]*workflows.ExecutionPreview, error)

func (*ExecutionIterator) Value 

func (it *ExecutionIterator) Value() *workflows.ExecutionPreview

type ExecutionServiceClient 

type ExecutionServiceClient struct {
	// contains filtered or unexported fields
}

ExecutionServiceClient is a workflows.ExecutionServiceClient with lazy GRPC connection initialization.

func (*ExecutionServiceClient) ExecutionIterator 

func (c *ExecutionServiceClient) ExecutionIterator(ctx context.Context, req *workflows.ListExecutionsRequest, opts ...grpc.CallOption) *ExecutionIterator

func (*ExecutionServiceClient) Get 

func (c *ExecutionServiceClient) Get(ctx context.Context, in *workflows.GetExecutionRequest, opts ...grpc.CallOption) (*workflows.GetExecutionResponse, error)

Get implements workflows.ExecutionServiceClient

func (*ExecutionServiceClient) GetHistory 

func (c *ExecutionServiceClient) GetHistory(ctx context.Context, in *workflows.GetExecutionHistoryRequest, opts ...grpc.CallOption) (*workflows.GetExecutionHistoryResponse, error)

GetHistory implements workflows.ExecutionServiceClient

func (*ExecutionServiceClient) List 

func (c *ExecutionServiceClient) List(ctx context.Context, in *workflows.ListExecutionsRequest, opts ...grpc.CallOption) (*workflows.ListExecutionsResponse, error)

List implements workflows.ExecutionServiceClient

func (*ExecutionServiceClient) Start 

func (c *ExecutionServiceClient) Start(ctx context.Context, in *workflows.StartExecutionRequest, opts ...grpc.CallOption) (*workflows.StartExecutionResponse, error)

Start implements workflows.ExecutionServiceClient

func (*ExecutionServiceClient) Stop 

func (c *ExecutionServiceClient) Stop(ctx context.Context, in *workflows.StopExecutionRequest, opts ...grpc.CallOption) (*workflows.StopExecutionResponse, error)

Stop implements workflows.ExecutionServiceClient

func (*ExecutionServiceClient) Terminate 

func (c *ExecutionServiceClient) Terminate(ctx context.Context, in *workflows.TerminateExecutionRequest, opts ...grpc.CallOption) (*workflows.TerminateExecutionResponse, error)

Terminate implements workflows.ExecutionServiceClient

type Workflow 

type Workflow struct {
	// contains filtered or unexported fields
}

Workflow provides access to "workflows" component of Yandex.Cloud

func NewWorkflow 

func NewWorkflow(g func(ctx context.Context) (*grpc.ClientConn, error)) *Workflow

NewWorkflow creates instance of Workflow

func (*Workflow) Execution 

func (w *Workflow) Execution() *ExecutionServiceClient

Execution gets ExecutionService client

func (*Workflow) Workflow 

func (w *Workflow) Workflow() *WorkflowServiceClient

Workflow gets WorkflowService client

type WorkflowIterator 

type WorkflowIterator struct {
	// contains filtered or unexported fields
}

func (*WorkflowIterator) Error 

func (it *WorkflowIterator) Error() error

func (*WorkflowIterator) Next 

func (it *WorkflowIterator) Next() bool

func (*WorkflowIterator) Take 

func (it *WorkflowIterator) Take(size int64) ([]*workflows.WorkflowPreview, error)

func (*WorkflowIterator) TakeAll 

func (it *WorkflowIterator) TakeAll() ([]*workflows.WorkflowPreview, error)

func (*WorkflowIterator) Value 

func (it *WorkflowIterator) Value() *workflows.WorkflowPreview

type WorkflowOperationsIterator 

type WorkflowOperationsIterator struct {
	// contains filtered or unexported fields
}

func (*WorkflowOperationsIterator) Error 

func (it *WorkflowOperationsIterator) Error() error

func (*WorkflowOperationsIterator) Next 

func (it *WorkflowOperationsIterator) Next() bool

func (*WorkflowOperationsIterator) Take 

func (it *WorkflowOperationsIterator) Take(size int64) ([]*operation.Operation, error)

func (*WorkflowOperationsIterator) TakeAll 

func (it *WorkflowOperationsIterator) TakeAll() ([]*operation.Operation, error)

func (*WorkflowOperationsIterator) Value 

func (it *WorkflowOperationsIterator) Value() *operation.Operation

type WorkflowServiceClient 

type WorkflowServiceClient struct {
	// contains filtered or unexported fields
}

WorkflowServiceClient is a workflows.WorkflowServiceClient with lazy GRPC connection initialization.

func (*WorkflowServiceClient) Create 

func (c *WorkflowServiceClient) Create(ctx context.Context, in *workflows.CreateWorkflowRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) Delete 

func (c *WorkflowServiceClient) Delete(ctx context.Context, in *workflows.DeleteWorkflowRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) Get 

func (c *WorkflowServiceClient) Get(ctx context.Context, in *workflows.GetWorkflowRequest, opts ...grpc.CallOption) (*workflows.GetWorkflowResponse, error)

Get implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) List 

func (c *WorkflowServiceClient) List(ctx context.Context, in *workflows.ListWorkflowsRequest, opts ...grpc.CallOption) (*workflows.ListWorkflowsResponse, error)

List implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) ListOperations 

func (c *WorkflowServiceClient) ListOperations(ctx context.Context, in *workflows.ListOperationsRequest, opts ...grpc.CallOption) (*workflows.ListOperationsResponse, error)

ListOperations implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) Update 

func (c *WorkflowServiceClient) Update(ctx context.Context, in *workflows.UpdateWorkflowRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements workflows.WorkflowServiceClient

func (*WorkflowServiceClient) WorkflowIterator 

func (c *WorkflowServiceClient) WorkflowIterator(ctx context.Context, req *workflows.ListWorkflowsRequest, opts ...grpc.CallOption) *WorkflowIterator

func (*WorkflowServiceClient) WorkflowOperationsIterator 

func (c *WorkflowServiceClient) WorkflowOperationsIterator(ctx context.Context, req *workflows.ListOperationsRequest, opts ...grpc.CallOption) *WorkflowOperationsIterator

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.