workflowssdk

package
v2.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExecutionStart      = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.Start")
	ExecutionStop       = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.Stop")
	ExecutionTerminate  = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.Terminate")
	ExecutionGet        = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.Get")
	ExecutionGetHistory = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.GetHistory")
	ExecutionList       = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.ExecutionService.List")
)
View Source 
var (
	WorkflowCreate          = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.Create")
	WorkflowUpdate          = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.Update")
	WorkflowGet             = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.Get")
	WorkflowDelete          = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.Delete")
	WorkflowList            = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.List")
	WorkflowListOperations  = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.ListOperations")
	WorkflowOperationPoller = protoreflect.FullName("yandex.cloud.operation.OperationService.Get")
)

Functions

This section is empty.

Types

type ExecutionClient 

type ExecutionClient interface {
	Start(context.Context, *workflows.StartExecutionRequest, ...grpc.CallOption) (*workflows.StartExecutionResponse, error)
	Stop(context.Context, *workflows.StopExecutionRequest, ...grpc.CallOption) (*workflows.StopExecutionResponse, error)
	Terminate(context.Context, *workflows.TerminateExecutionRequest, ...grpc.CallOption) (*workflows.TerminateExecutionResponse, error)
	Get(context.Context, *workflows.GetExecutionRequest, ...grpc.CallOption) (*workflows.GetExecutionResponse, error)
	GetHistory(context.Context, *workflows.GetExecutionHistoryRequest, ...grpc.CallOption) (*workflows.GetExecutionHistoryResponse, error)
	List(context.Context, *workflows.ListExecutionsRequest, ...grpc.CallOption) (*workflows.ListExecutionsResponse, error)
}

ExecutionClient provides methods for managing Execution resources of Yandex.Cloud Workflows.

func NewExecutionClient 

func NewExecutionClient(connector transport.Connector) ExecutionClient

NewExecutionClient returns ExecutionClient implementation.

type WorkflowClient 

type WorkflowClient interface {
	Create(context.Context, *workflows.CreateWorkflowRequest, ...grpc.CallOption) (*WorkflowCreateOperation, error)
	Update(context.Context, *workflows.UpdateWorkflowRequest, ...grpc.CallOption) (*WorkflowUpdateOperation, error)
	Get(context.Context, *workflows.GetWorkflowRequest, ...grpc.CallOption) (*workflows.GetWorkflowResponse, error)
	Delete(context.Context, *workflows.DeleteWorkflowRequest, ...grpc.CallOption) (*WorkflowDeleteOperation, error)
	List(context.Context, *workflows.ListWorkflowsRequest, ...grpc.CallOption) (*workflows.ListWorkflowsResponse, error)
	ListOperations(context.Context, *workflows.ListOperationsRequest, ...grpc.CallOption) (*workflows.ListOperationsResponse, error)
}

WorkflowClient provides methods for managing Workflow resources of Yandex.Cloud Workflows.

func NewWorkflowClient 

func NewWorkflowClient(connector transport.Connector) WorkflowClient

NewWorkflowClient returns WorkflowClient implementation.

type WorkflowCreateOperation 

type WorkflowCreateOperation struct {
	sdkop.Operation
}

WorkflowCreateOperation is used to monitor the state of Create operations.

func (*WorkflowCreateOperation) Metadata 

func (o *WorkflowCreateOperation) Metadata() *workflows.CreateWorkflowMetadata

Metadata retrieves the operation metadata.

func (*WorkflowCreateOperation) Response 

func (o *WorkflowCreateOperation) Response() *workflows.Workflow

Response retrieves the operation response.

func (*WorkflowCreateOperation) Wait 

func (o *WorkflowCreateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*workflows.Workflow, error)

Wait polls the operation until it's done.

func (*WorkflowCreateOperation) WaitInterval 

func (o *WorkflowCreateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*workflows.Workflow, error)

WaitInterval polls the operation until it's done with custom interval.

type WorkflowDeleteOperation 

type WorkflowDeleteOperation struct {
	sdkop.Operation
}

WorkflowDeleteOperation is used to monitor the state of Delete operations.

func (*WorkflowDeleteOperation) Metadata 

func (o *WorkflowDeleteOperation) Metadata() *workflows.DeleteWorkflowMetadata

Metadata retrieves the operation metadata.

func (*WorkflowDeleteOperation) Response 

func (o *WorkflowDeleteOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*WorkflowDeleteOperation) Wait 

func (o *WorkflowDeleteOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*WorkflowDeleteOperation) WaitInterval 

func (o *WorkflowDeleteOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type WorkflowUpdateOperation 

type WorkflowUpdateOperation struct {
	sdkop.Operation
}

WorkflowUpdateOperation is used to monitor the state of Update operations.

func (*WorkflowUpdateOperation) Metadata 

func (o *WorkflowUpdateOperation) Metadata() *workflows.UpdateWorkflowMetadata

Metadata retrieves the operation metadata.

func (*WorkflowUpdateOperation) Response 

func (o *WorkflowUpdateOperation) Response() *workflows.Workflow

Response retrieves the operation response.

func (*WorkflowUpdateOperation) Wait 

func (o *WorkflowUpdateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*workflows.Workflow, error)

Wait polls the operation until it's done.

func (*WorkflowUpdateOperation) WaitInterval 

func (o *WorkflowUpdateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*workflows.Workflow, error)

WaitInterval polls the operation until it's done with custom interval.

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.