Documentation
¶
Overview ¶
Package parentclosepolicy is a generated GoMock package.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ProcessorActivity ¶
ProcessorActivity is activity for processing batch operation
func ProcessorWorkflow ¶
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 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
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