workflowssdk

package
v0.0.35 Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

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")
	WorkflowListAccessBindings   = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.ListAccessBindings")
	WorkflowSetAccessBindings    = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.SetAccessBindings")
	WorkflowUpdateAccessBindings = protoreflect.FullName("yandex.cloud.serverless.workflows.v1.WorkflowService.UpdateAccessBindings")
	WorkflowOperationPoller      = protoreflect.FullName("yandex.cloud.operation.OperationService.Get")
)

Functions

func WorkflowResolver added in v0.0.21 

func WorkflowResolver(name string, client WorkflowClient, opts ...sdkresolvers.ResolveOption) sdkresolvers.Resolver

Types

type ExecutionClient 

type ExecutionClient interface {
	ExecutionClientIterator
	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 ExecutionClientIterator added in v0.0.17 

type ExecutionClientIterator interface {
	Iterator(context.Context, *workflows.ListExecutionsRequest, ...grpc.CallOption) *iterator.Iterator[*workflows.ListExecutionsRequest, *workflows.ExecutionPreview]
}

type WorkflowClient 

type WorkflowClient interface {
	WorkflowClientIterator
	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)
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest, ...grpc.CallOption) (*WorkflowSetAccessBindingsOperation, error)
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest, ...grpc.CallOption) (*WorkflowUpdateAccessBindingsOperation, 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 WorkflowClientIterator added in v0.0.17 

type WorkflowClientIterator interface {
	Iterator(context.Context, *workflows.ListWorkflowsRequest, ...grpc.CallOption) *iterator.Iterator[*workflows.ListWorkflowsRequest, *workflows.WorkflowPreview]
	OperationsIterator(context.Context, *workflows.ListOperationsRequest, ...grpc.CallOption) *iterator.Iterator[*workflows.ListOperationsRequest, *operation.Operation]
	AccessBindingsIterator(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) *iterator.Iterator[*access.ListAccessBindingsRequest, *access.AccessBinding]
}

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 WorkflowSetAccessBindingsOperation added in v0.0.8 

type WorkflowSetAccessBindingsOperation struct {
	sdkop.Operation
}

WorkflowSetAccessBindingsOperation is used to monitor the state of SetAccessBindings operations.

func (*WorkflowSetAccessBindingsOperation) Metadata added in v0.0.8 

func (o *WorkflowSetAccessBindingsOperation) Metadata() *access.SetAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*WorkflowSetAccessBindingsOperation) Response added in v0.0.8 

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

Response retrieves the operation response.

func (*WorkflowSetAccessBindingsOperation) Wait added in v0.0.8 

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

Wait polls the operation until it's done.

func (*WorkflowSetAccessBindingsOperation) WaitInterval added in v0.0.8 

func (o *WorkflowSetAccessBindingsOperation) 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 WorkflowUpdateAccessBindingsOperation added in v0.0.8 

type WorkflowUpdateAccessBindingsOperation struct {
	sdkop.Operation
}

WorkflowUpdateAccessBindingsOperation is used to monitor the state of UpdateAccessBindings operations.

func (*WorkflowUpdateAccessBindingsOperation) Metadata added in v0.0.8 

func (o *WorkflowUpdateAccessBindingsOperation) Metadata() *access.UpdateAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*WorkflowUpdateAccessBindingsOperation) Response added in v0.0.8 

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

Response retrieves the operation response.

func (*WorkflowUpdateAccessBindingsOperation) Wait added in v0.0.8 

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

Wait polls the operation until it's done.

func (*WorkflowUpdateAccessBindingsOperation) WaitInterval added in v0.0.8 

func (o *WorkflowUpdateAccessBindingsOperation) 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.