parentclosepolicy

package
v1.3.7-prerelease21 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2025 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package parentclosepolicy is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProcessorActivity

func ProcessorActivity(ctx context.Context, request Request) error

ProcessorActivity is activity for processing batch operation

func ProcessorWorkflow

func ProcessorWorkflow(ctx workflow.Context) error

ProcessorWorkflow is the workflow that performs actions for ParentClosePolicy

Types

type BootstrapParams

type BootstrapParams struct {
	// Config contains the configuration for scanner
	// ServiceClient is an instance of cadence service client
	ServiceClient workflowserviceclient.Interface
	// MetricsClient is an instance of metrics object for emitting stats
	MetricsClient metrics.Client
	Logger        log.Logger
	// TallyScope is an instance of tally metrics scope
	TallyScope tally.Scope
	// ClientBean is the collection of clients
	ClientBean client.Bean
	// DomainCache is the cache for domain information and configuration
	DomainCache cache.DomainCache
	// NumWorkflows is the total number of workflows for processing parent close policy
	NumWorkflows int
}

BootstrapParams contains the set of params needed to bootstrap the sub-system

type Client

type Client interface {
	SendParentClosePolicyRequest(context.Context, Request) error
}

Client is used to send request to processor workflow

func NewClient

func NewClient(
	metricsClient metrics.Client,
	logger log.Logger,
	publicClient workflowserviceclient.Interface,
	numWorkflows int,
) Client

NewClient creates a new Client

type MockClient added in v1.3.6

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

MockClient is a mock of Client interface.

func NewMockClient added in v1.3.6

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) EXPECT added in v1.3.6

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClient) SendParentClosePolicyRequest added in v1.3.6

func (m *MockClient) SendParentClosePolicyRequest(arg0 context.Context, arg1 Request) error

SendParentClosePolicyRequest mocks base method.

type MockClientMockRecorder added in v1.3.6

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) SendParentClosePolicyRequest added in v1.3.6

func (mr *MockClientMockRecorder) SendParentClosePolicyRequest(arg0, arg1 any) *gomock.Call

SendParentClosePolicyRequest indicates an expected call of SendParentClosePolicyRequest.

type Processor

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

Processor is the background sub-system that execute workflow for ParentClosePolicy

func New

func New(params *BootstrapParams) *Processor

New returns a new instance as daemon

func (*Processor) Start

func (s *Processor) Start() error

Start starts the scanner

type Request

type Request struct {
	ParentExecution types.WorkflowExecution
	Executions      []RequestDetail

	// DEPRECATED: the following field is deprecated since childworkflow
	// might in a different domain, use the DomainName field in RequestDetail
	DomainName string
}

Request defines the request for parent close policy

type RequestDetail

type RequestDetail struct {
	DomainID   string
	DomainName string
	WorkflowID string
	RunID      string
	Policy     types.ParentClosePolicy
}

RequestDetail defines detail of each workflow to process

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL