manager

package
v1.22.1-rc1 Latest Latest
Warning

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

 Go to latest Published: Oct 6, 2023 License: MIT Imports: 10 Imported by: 2

Documentation

Overview

Package manager is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CountWorkflowExecutionsRequest 

type CountWorkflowExecutionsRequest struct {
	NamespaceID namespace.ID
	Namespace   namespace.Name // namespace.Name is not persisted.
	Query       string
}

CountWorkflowExecutionsRequest is request from CountWorkflowExecutions

type CountWorkflowExecutionsResponse 

type CountWorkflowExecutionsResponse struct {
	Count  int64 // sum of counts in Groups
	Groups []*workflowservice.CountWorkflowExecutionsResponse_AggregationGroup
}

CountWorkflowExecutionsResponse is response to CountWorkflowExecutions

type GetWorkflowExecutionRequest added in v1.19.0 

type GetWorkflowExecutionRequest struct {
	NamespaceID namespace.ID
	Namespace   namespace.Name // namespace.Name is not persisted
	RunID       string
	WorkflowID  string
	StartTime   *time.Time // if start time is not empty, search record from open_execution for cassandra db
	CloseTime   *time.Time // if end time is not empty, search record from closed_execution for cassandra db
}

GetWorkflowExecutionRequest is request from GetWorkflowExecution

type GetWorkflowExecutionResponse added in v1.19.0 

type GetWorkflowExecutionResponse struct {
	Execution *workflowpb.WorkflowExecutionInfo
}

GetWorkflowExecutionResponse is response to GetWorkflowExecution

type ListClosedWorkflowExecutionsByStatusRequest 

type ListClosedWorkflowExecutionsByStatusRequest struct {
	*ListWorkflowExecutionsRequest
	Status enumspb.WorkflowExecutionStatus
}

ListClosedWorkflowExecutionsByStatusRequest is used to list executions that have specific close status

type ListWorkflowExecutionsByTypeRequest 

type ListWorkflowExecutionsByTypeRequest struct {
	*ListWorkflowExecutionsRequest
	WorkflowTypeName string
}

ListWorkflowExecutionsByTypeRequest is used to list executions of a specific type in a namespace

type ListWorkflowExecutionsByWorkflowIDRequest 

type ListWorkflowExecutionsByWorkflowIDRequest struct {
	*ListWorkflowExecutionsRequest
	WorkflowID string
}

ListWorkflowExecutionsByWorkflowIDRequest is used to list executions that have specific WorkflowID in a namespace

type ListWorkflowExecutionsRequest 

type ListWorkflowExecutionsRequest struct {
	NamespaceID       namespace.ID
	Namespace         namespace.Name // namespace.Name is not persisted.
	NamespaceDivision string
	EarliestStartTime time.Time
	LatestStartTime   time.Time
	// Maximum number of workflow executions per page
	PageSize int
	// Token to continue reading next page of workflow executions.
	// Pass in empty slice for first page.
	NextPageToken []byte
}

ListWorkflowExecutionsRequest is used to list executions in a namespace

func (*ListWorkflowExecutionsRequest) GetPageSize added in v1.14.0 

func (r *ListWorkflowExecutionsRequest) GetPageSize() int

func (*ListWorkflowExecutionsRequest) GetToken added in v1.14.0 

func (r *ListWorkflowExecutionsRequest) GetToken() []byte

func (*ListWorkflowExecutionsRequest) OverridePageSize added in v1.14.0 

func (r *ListWorkflowExecutionsRequest) OverridePageSize(pageSize int)

func (*ListWorkflowExecutionsRequest) OverrideToken added in v1.14.0 

func (r *ListWorkflowExecutionsRequest) OverrideToken(token []byte)

type ListWorkflowExecutionsRequestV2 

type ListWorkflowExecutionsRequestV2 struct {
	NamespaceID namespace.ID
	Namespace   namespace.Name // namespace.Name is not persisted.
	PageSize    int            // Maximum number of workflow executions per page
	// Token to continue reading next page of workflow executions.
	// Pass in empty slice for first page.
	NextPageToken []byte
	Query         string
}

ListWorkflowExecutionsRequestV2 is used to list executions in a namespace

type ListWorkflowExecutionsResponse 

type ListWorkflowExecutionsResponse struct {
	Executions []*workflowpb.WorkflowExecutionInfo
	// Token to read next page if there are more workflow executions beyond page size.
	// Use this to set NextPageToken on ListWorkflowExecutionsRequest to read the next page.
	NextPageToken []byte
}

ListWorkflowExecutionsResponse is the response to ListWorkflowExecutionsRequest

type MockVisibilityManager 

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

MockVisibilityManager is a mock of VisibilityManager interface.

func NewMockVisibilityManager 

func NewMockVisibilityManager(ctrl *gomock.Controller) *MockVisibilityManager

NewMockVisibilityManager creates a new mock instance.

func (*MockVisibilityManager) Close 

func (m *MockVisibilityManager) Close()

Close mocks base method.

func (*MockVisibilityManager) CountWorkflowExecutions 

func (m *MockVisibilityManager) CountWorkflowExecutions(ctx context.Context, request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockVisibilityManager) DeleteWorkflowExecution 

func (m *MockVisibilityManager) DeleteWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution mocks base method.

func (*MockVisibilityManager) EXPECT 

func (m *MockVisibilityManager) EXPECT() *MockVisibilityManagerMockRecorder

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

func (*MockVisibilityManager) GetIndexName added in v1.20.0 

func (m *MockVisibilityManager) GetIndexName() string

GetIndexName mocks base method.

func (*MockVisibilityManager) GetReadStoreName added in v1.20.0 

func (m *MockVisibilityManager) GetReadStoreName(nsName namespace.Name) string

GetReadStoreName mocks base method.

func (*MockVisibilityManager) GetStoreNames added in v1.20.0 

func (m *MockVisibilityManager) GetStoreNames() []string

GetStoreNames mocks base method.

func (*MockVisibilityManager) GetWorkflowExecution added in v1.19.0 

func (m *MockVisibilityManager) GetWorkflowExecution(ctx context.Context, request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)

GetWorkflowExecution mocks base method.

func (*MockVisibilityManager) HasStoreName added in v1.20.0 

func (m *MockVisibilityManager) HasStoreName(stName string) bool

HasStoreName mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutions 

func (m *MockVisibilityManager) ListClosedWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByStatus 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByType 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutions 

func (m *MockVisibilityManager) ListOpenWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutionsByType 

func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityManager) ListWorkflowExecutions 

func (m *MockVisibilityManager) ListWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method.

func (*MockVisibilityManager) RecordWorkflowExecutionClosed 

func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(ctx context.Context, request *RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed mocks base method.

func (*MockVisibilityManager) RecordWorkflowExecutionStarted 

func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(ctx context.Context, request *RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted mocks base method.

func (*MockVisibilityManager) ScanWorkflowExecutions 

func (m *MockVisibilityManager) ScanWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockVisibilityManager) UpsertWorkflowExecution 

func (m *MockVisibilityManager) UpsertWorkflowExecution(ctx context.Context, request *UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution mocks base method.

func (*MockVisibilityManager) ValidateCustomSearchAttributes added in v1.21.3 

func (m *MockVisibilityManager) ValidateCustomSearchAttributes(searchAttributes map[string]any) (map[string]any, error)

ValidateCustomSearchAttributes mocks base method.

type MockVisibilityManagerMockRecorder 

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

MockVisibilityManagerMockRecorder is the mock recorder for MockVisibilityManager.

func (*MockVisibilityManagerMockRecorder) Close 

func (mr *MockVisibilityManagerMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockVisibilityManagerMockRecorder) CountWorkflowExecutions 

func (mr *MockVisibilityManagerMockRecorder) CountWorkflowExecutions(ctx, request interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) DeleteWorkflowExecution 

func (mr *MockVisibilityManagerMockRecorder) DeleteWorkflowExecution(ctx, request interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockVisibilityManagerMockRecorder) GetIndexName added in v1.20.0 

func (mr *MockVisibilityManagerMockRecorder) GetIndexName() *gomock.Call

GetIndexName indicates an expected call of GetIndexName.

func (*MockVisibilityManagerMockRecorder) GetReadStoreName added in v1.20.0 

func (mr *MockVisibilityManagerMockRecorder) GetReadStoreName(nsName interface{}) *gomock.Call

GetReadStoreName indicates an expected call of GetReadStoreName.

func (*MockVisibilityManagerMockRecorder) GetStoreNames added in v1.20.0 

func (mr *MockVisibilityManagerMockRecorder) GetStoreNames() *gomock.Call

GetStoreNames indicates an expected call of GetStoreNames.

func (*MockVisibilityManagerMockRecorder) GetWorkflowExecution added in v1.19.0 

func (mr *MockVisibilityManagerMockRecorder) GetWorkflowExecution(ctx, request interface{}) *gomock.Call

GetWorkflowExecution indicates an expected call of GetWorkflowExecution.

func (*MockVisibilityManagerMockRecorder) HasStoreName added in v1.20.0 

func (mr *MockVisibilityManagerMockRecorder) HasStoreName(stName interface{}) *gomock.Call

HasStoreName indicates an expected call of HasStoreName.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions 

func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions(ctx, request interface{}) *gomock.Call

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus 

func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus(ctx, request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByStatus indicates an expected call of ListClosedWorkflowExecutionsByStatus.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType 

func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType(ctx, request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByType indicates an expected call of ListClosedWorkflowExecutionsByType.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID 

func (mr *MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(ctx, request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByWorkflowID indicates an expected call of ListClosedWorkflowExecutionsByWorkflowID.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions 

func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions(ctx, request interface{}) *gomock.Call

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType 

func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType(ctx, request interface{}) *gomock.Call

ListOpenWorkflowExecutionsByType indicates an expected call of ListOpenWorkflowExecutionsByType.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID 

func (mr *MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(ctx, request interface{}) *gomock.Call

ListOpenWorkflowExecutionsByWorkflowID indicates an expected call of ListOpenWorkflowExecutionsByWorkflowID.

func (*MockVisibilityManagerMockRecorder) ListWorkflowExecutions 

func (mr *MockVisibilityManagerMockRecorder) ListWorkflowExecutions(ctx, request interface{}) *gomock.Call

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed 

func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed(ctx, request interface{}) *gomock.Call

RecordWorkflowExecutionClosed indicates an expected call of RecordWorkflowExecutionClosed.

func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted 

func (mr *MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted(ctx, request interface{}) *gomock.Call

RecordWorkflowExecutionStarted indicates an expected call of RecordWorkflowExecutionStarted.

func (*MockVisibilityManagerMockRecorder) ScanWorkflowExecutions 

func (mr *MockVisibilityManagerMockRecorder) ScanWorkflowExecutions(ctx, request interface{}) *gomock.Call

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) UpsertWorkflowExecution 

func (mr *MockVisibilityManagerMockRecorder) UpsertWorkflowExecution(ctx, request interface{}) *gomock.Call

UpsertWorkflowExecution indicates an expected call of UpsertWorkflowExecution.

func (*MockVisibilityManagerMockRecorder) ValidateCustomSearchAttributes added in v1.21.3 

func (mr *MockVisibilityManagerMockRecorder) ValidateCustomSearchAttributes(searchAttributes interface{}) *gomock.Call

ValidateCustomSearchAttributes indicates an expected call of ValidateCustomSearchAttributes.

type RecordWorkflowExecutionClosedRequest 

type RecordWorkflowExecutionClosedRequest struct {
	*VisibilityRequestBase
	CloseTime        time.Time
	HistoryLength    int64
	HistorySizeBytes int64
}

RecordWorkflowExecutionClosedRequest is used to add a record of a closed execution

type RecordWorkflowExecutionStartedRequest 

type RecordWorkflowExecutionStartedRequest struct {
	*VisibilityRequestBase
}

RecordWorkflowExecutionStartedRequest is used to add a record of a newly started execution

type UpsertWorkflowExecutionRequest 

type UpsertWorkflowExecutionRequest struct {
	*VisibilityRequestBase
}

UpsertWorkflowExecutionRequest is used to upsert workflow execution

type VisibilityDeleteWorkflowExecutionRequest 

type VisibilityDeleteWorkflowExecutionRequest struct {
	NamespaceID namespace.ID
	RunID       string
	WorkflowID  string
	TaskID      int64
	StartTime   *time.Time // if start time is not empty, delete record from open_execution for cassandra db
	CloseTime   *time.Time // if end time is not empty, delete record from closed_execution for cassandra db
}

VisibilityDeleteWorkflowExecutionRequest contains the request params for DeleteWorkflowExecution call

type VisibilityManager 

type VisibilityManager interface {
	persistence.Closeable
	GetReadStoreName(nsName namespace.Name) string
	GetStoreNames() []string
	HasStoreName(stName string) bool
	GetIndexName() string
	ValidateCustomSearchAttributes(searchAttributes map[string]any) (map[string]any, error)

	// Write APIs.
	RecordWorkflowExecutionStarted(ctx context.Context, request *RecordWorkflowExecutionStartedRequest) error
	RecordWorkflowExecutionClosed(ctx context.Context, request *RecordWorkflowExecutionClosedRequest) error
	UpsertWorkflowExecution(ctx context.Context, request *UpsertWorkflowExecutionRequest) error
	DeleteWorkflowExecution(ctx context.Context, request *VisibilityDeleteWorkflowExecutionRequest) error

	// Read APIs.
	ListOpenWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByType(ctx context.Context, request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByWorkflowID(ctx context.Context, request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByStatus(ctx context.Context, request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)
	ListWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(ctx context.Context, request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(ctx context.Context, request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	GetWorkflowExecution(ctx context.Context, request *GetWorkflowExecutionRequest) (*GetWorkflowExecutionResponse, error)
}

VisibilityManager is used to manage the visibility store

type VisibilityRequestBase 

type VisibilityRequestBase struct {
	NamespaceID          namespace.ID
	Namespace            namespace.Name // namespace.Name is not persisted.
	Execution            commonpb.WorkflowExecution
	WorkflowTypeName     string
	StartTime            time.Time
	Status               enumspb.WorkflowExecutionStatus
	ExecutionTime        time.Time
	StateTransitionCount int64
	TaskID               int64 // not persisted, used as condition update version for ES
	ShardID              int32 // not persisted
	Memo                 *commonpb.Memo
	TaskQueue            string
	SearchAttributes     *commonpb.SearchAttributes
}

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.