visibility

package
v1.12.1 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2021 License: MIT Imports: 18 Imported by: 1

Documentation

Overview

Package visibility is a generated GoMock package.

Package visibility is a generated GoMock package.

Index

Constants

View Source 
const MemoEncoding = enumspb.ENCODING_TYPE_PROTO3

MemoEncoding is default encoding for visibility memo.

Variables

View Source 
var (
	// OperationNotSupportedErr is returned when visibility operation in not supported.
	OperationNotSupportedErr = serviceerror.NewInvalidArgument("Operation not supported. Please use on Elasticsearch")
)

Functions

This section is empty.

Types

type CountWorkflowExecutionsRequest 

type CountWorkflowExecutionsRequest struct {
	NamespaceID string
	Namespace   string // namespace name is not persisted
	Query       string
}

CountWorkflowExecutionsRequest is request from CountWorkflowExecutions

type CountWorkflowExecutionsResponse 

type CountWorkflowExecutionsResponse struct {
	Count int64
}

CountWorkflowExecutionsResponse is response to CountWorkflowExecutions

type InternalListWorkflowExecutionsResponse 

type InternalListWorkflowExecutionsResponse struct {
	Executions []*VisibilityWorkflowExecutionInfo
	// 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
}

InternalListWorkflowExecutionsResponse is response from ListWorkflowExecutions

type InternalRecordWorkflowExecutionClosedRequest 

type InternalRecordWorkflowExecutionClosedRequest struct {
	*InternalVisibilityRequestBase
	CloseTime     time.Time
	HistoryLength int64
	Retention     *time.Duration
}

InternalRecordWorkflowExecutionClosedRequest is request to RecordWorkflowExecutionClosed

type InternalRecordWorkflowExecutionStartedRequest 

type InternalRecordWorkflowExecutionStartedRequest struct {
	*InternalVisibilityRequestBase
}

InternalRecordWorkflowExecutionStartedRequest request to RecordWorkflowExecutionStarted

type InternalUpsertWorkflowExecutionRequest 

type InternalUpsertWorkflowExecutionRequest struct {
	*InternalVisibilityRequestBase
}

InternalUpsertWorkflowExecutionRequest is request to UpsertWorkflowExecution

type InternalVisibilityRequestBase 

type InternalVisibilityRequestBase struct {
	NamespaceID          string
	WorkflowID           string
	RunID                string
	WorkflowTypeName     string
	StartTime            time.Time
	Status               enumspb.WorkflowExecutionStatus
	ExecutionTime        time.Time
	StateTransitionCount int64
	TaskID               int64
	ShardID              int32
	Memo                 *commonpb.DataBlob
	TaskQueue            string
	SearchAttributes     *commonpb.SearchAttributes
}

InternalVisibilityRequestBase is a base request to visibility APIs.

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       string
	Namespace         string // namespace name is not persisted, but used as config filter key
	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

type ListWorkflowExecutionsRequestV2 

type ListWorkflowExecutionsRequestV2 struct {
	NamespaceID string
	Namespace   string // 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(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockVisibilityManager) DeleteWorkflowExecution 

func (m *MockVisibilityManager) DeleteWorkflowExecution(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) GetName 

func (m *MockVisibilityManager) GetName() string

GetName mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutions 

func (m *MockVisibilityManager) ListClosedWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByStatus 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByStatus(request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByType 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType mocks base method.

func (*MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityManager) ListClosedWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutions 

func (m *MockVisibilityManager) ListOpenWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutionsByType 

func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType mocks base method.

func (*MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityManager) ListOpenWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityManager) ListWorkflowExecutions 

func (m *MockVisibilityManager) ListWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method.

func (*MockVisibilityManager) RecordWorkflowExecutionClosed 

func (m *MockVisibilityManager) RecordWorkflowExecutionClosed(request *RecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed mocks base method.

func (*MockVisibilityManager) RecordWorkflowExecutionStarted 

func (m *MockVisibilityManager) RecordWorkflowExecutionStarted(request *RecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted mocks base method.

func (*MockVisibilityManager) ScanWorkflowExecutions 

func (m *MockVisibilityManager) ScanWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockVisibilityManager) UpsertWorkflowExecution 

func (m *MockVisibilityManager) UpsertWorkflowExecution(request *UpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution 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(request interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) DeleteWorkflowExecution 

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

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockVisibilityManagerMockRecorder) GetName 

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

GetName indicates an expected call of GetName.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutions 

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

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByStatus 

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

ListClosedWorkflowExecutionsByStatus indicates an expected call of ListClosedWorkflowExecutionsByStatus.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByType 

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

ListClosedWorkflowExecutionsByType indicates an expected call of ListClosedWorkflowExecutionsByType.

func (*MockVisibilityManagerMockRecorder) ListClosedWorkflowExecutionsByWorkflowID 

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

ListClosedWorkflowExecutionsByWorkflowID indicates an expected call of ListClosedWorkflowExecutionsByWorkflowID.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByType 

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

ListOpenWorkflowExecutionsByType indicates an expected call of ListOpenWorkflowExecutionsByType.

func (*MockVisibilityManagerMockRecorder) ListOpenWorkflowExecutionsByWorkflowID 

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

ListOpenWorkflowExecutionsByWorkflowID indicates an expected call of ListOpenWorkflowExecutionsByWorkflowID.

func (*MockVisibilityManagerMockRecorder) ListWorkflowExecutions 

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

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionClosed 

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

RecordWorkflowExecutionClosed indicates an expected call of RecordWorkflowExecutionClosed.

func (*MockVisibilityManagerMockRecorder) RecordWorkflowExecutionStarted 

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

RecordWorkflowExecutionStarted indicates an expected call of RecordWorkflowExecutionStarted.

func (*MockVisibilityManagerMockRecorder) ScanWorkflowExecutions 

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

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockVisibilityManagerMockRecorder) UpsertWorkflowExecution 

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

UpsertWorkflowExecution indicates an expected call of UpsertWorkflowExecution.

type MockVisibilityStore 

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

MockVisibilityStore is a mock of VisibilityStore interface.

func NewMockVisibilityStore 

func NewMockVisibilityStore(ctrl *gomock.Controller) *MockVisibilityStore

NewMockVisibilityStore creates a new mock instance.

func (*MockVisibilityStore) Close 

func (m *MockVisibilityStore) Close()

Close mocks base method.

func (*MockVisibilityStore) CountWorkflowExecutions 

func (m *MockVisibilityStore) CountWorkflowExecutions(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockVisibilityStore) DeleteWorkflowExecution 

func (m *MockVisibilityStore) DeleteWorkflowExecution(request *VisibilityDeleteWorkflowExecutionRequest) error

DeleteWorkflowExecution mocks base method.

func (*MockVisibilityStore) EXPECT 

func (m *MockVisibilityStore) EXPECT() *MockVisibilityStoreMockRecorder

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

func (*MockVisibilityStore) GetName 

func (m *MockVisibilityStore) GetName() string

GetName mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutions 

func (m *MockVisibilityStore) ListClosedWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByStatus 

func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByStatus(request *ListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByStatus mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByType 

func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByType mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutions 

func (m *MockVisibilityStore) ListOpenWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutions mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutionsByType 

func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByType mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID 

func (m *MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)

ListOpenWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityStore) ListWorkflowExecutions 

func (m *MockVisibilityStore) ListWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)

ListWorkflowExecutions mocks base method.

func (*MockVisibilityStore) RecordWorkflowExecutionClosed 

func (m *MockVisibilityStore) RecordWorkflowExecutionClosed(request *InternalRecordWorkflowExecutionClosedRequest) error

RecordWorkflowExecutionClosed mocks base method.

func (*MockVisibilityStore) RecordWorkflowExecutionStarted 

func (m *MockVisibilityStore) RecordWorkflowExecutionStarted(request *InternalRecordWorkflowExecutionStartedRequest) error

RecordWorkflowExecutionStarted mocks base method.

func (*MockVisibilityStore) ScanWorkflowExecutions 

func (m *MockVisibilityStore) ScanWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)

ScanWorkflowExecutions mocks base method.

func (*MockVisibilityStore) UpsertWorkflowExecution 

func (m *MockVisibilityStore) UpsertWorkflowExecution(request *InternalUpsertWorkflowExecutionRequest) error

UpsertWorkflowExecution mocks base method.

type MockVisibilityStoreMockRecorder 

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

MockVisibilityStoreMockRecorder is the mock recorder for MockVisibilityStore.

func (*MockVisibilityStoreMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockVisibilityStoreMockRecorder) CountWorkflowExecutions 

func (mr *MockVisibilityStoreMockRecorder) CountWorkflowExecutions(request interface{}) *gomock.Call

CountWorkflowExecutions indicates an expected call of CountWorkflowExecutions.

func (*MockVisibilityStoreMockRecorder) DeleteWorkflowExecution 

func (mr *MockVisibilityStoreMockRecorder) DeleteWorkflowExecution(request interface{}) *gomock.Call

DeleteWorkflowExecution indicates an expected call of DeleteWorkflowExecution.

func (*MockVisibilityStoreMockRecorder) GetName 

func (mr *MockVisibilityStoreMockRecorder) GetName() *gomock.Call

GetName indicates an expected call of GetName.

func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutions 

func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutions(request interface{}) *gomock.Call

ListClosedWorkflowExecutions indicates an expected call of ListClosedWorkflowExecutions.

func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByStatus 

func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByStatus(request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByStatus indicates an expected call of ListClosedWorkflowExecutionsByStatus.

func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByType 

func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByType(request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByType indicates an expected call of ListClosedWorkflowExecutionsByType.

func (*MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByWorkflowID 

func (mr *MockVisibilityStoreMockRecorder) ListClosedWorkflowExecutionsByWorkflowID(request interface{}) *gomock.Call

ListClosedWorkflowExecutionsByWorkflowID indicates an expected call of ListClosedWorkflowExecutionsByWorkflowID.

func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutions 

func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutions(request interface{}) *gomock.Call

ListOpenWorkflowExecutions indicates an expected call of ListOpenWorkflowExecutions.

func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByType 

func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByType(request interface{}) *gomock.Call

ListOpenWorkflowExecutionsByType indicates an expected call of ListOpenWorkflowExecutionsByType.

func (*MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByWorkflowID 

func (mr *MockVisibilityStoreMockRecorder) ListOpenWorkflowExecutionsByWorkflowID(request interface{}) *gomock.Call

ListOpenWorkflowExecutionsByWorkflowID indicates an expected call of ListOpenWorkflowExecutionsByWorkflowID.

func (*MockVisibilityStoreMockRecorder) ListWorkflowExecutions 

func (mr *MockVisibilityStoreMockRecorder) ListWorkflowExecutions(request interface{}) *gomock.Call

ListWorkflowExecutions indicates an expected call of ListWorkflowExecutions.

func (*MockVisibilityStoreMockRecorder) RecordWorkflowExecutionClosed 

func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionClosed(request interface{}) *gomock.Call

RecordWorkflowExecutionClosed indicates an expected call of RecordWorkflowExecutionClosed.

func (*MockVisibilityStoreMockRecorder) RecordWorkflowExecutionStarted 

func (mr *MockVisibilityStoreMockRecorder) RecordWorkflowExecutionStarted(request interface{}) *gomock.Call

RecordWorkflowExecutionStarted indicates an expected call of RecordWorkflowExecutionStarted.

func (*MockVisibilityStoreMockRecorder) ScanWorkflowExecutions 

func (mr *MockVisibilityStoreMockRecorder) ScanWorkflowExecutions(request interface{}) *gomock.Call

ScanWorkflowExecutions indicates an expected call of ScanWorkflowExecutions.

func (*MockVisibilityStoreMockRecorder) UpsertWorkflowExecution 

func (mr *MockVisibilityStoreMockRecorder) UpsertWorkflowExecution(request interface{}) *gomock.Call

UpsertWorkflowExecution indicates an expected call of UpsertWorkflowExecution.

type RecordWorkflowExecutionClosedRequest 

type RecordWorkflowExecutionClosedRequest struct {
	*VisibilityRequestBase
	CloseTime     time.Time
	HistoryLength int64
	Retention     *time.Duration // not persisted, used for cassandra ttl
}

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 string
	RunID       string
	WorkflowID  string
	TaskID      int64
}

VisibilityDeleteWorkflowExecutionRequest contains the request params for DeleteWorkflowExecution call

type VisibilityManager 

type VisibilityManager interface {
	persistence.Closeable
	GetName() string
	RecordWorkflowExecutionStarted(request *RecordWorkflowExecutionStartedRequest) error
	RecordWorkflowExecutionClosed(request *RecordWorkflowExecutionClosedRequest) error
	UpsertWorkflowExecution(request *UpsertWorkflowExecutionRequest) error
	ListOpenWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*ListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*ListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByStatus(request *ListClosedWorkflowExecutionsByStatusRequest) (*ListWorkflowExecutionsResponse, error)
	DeleteWorkflowExecution(request *VisibilityDeleteWorkflowExecutionRequest) error
	ListWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*ListWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
}

VisibilityManager is used to manage the visibility store

func NewVisibilityManagerImpl 

func NewVisibilityManagerImpl(store VisibilityStore, searchAttributesProvider searchattribute.Provider, defaultVisibilityIndexName string, logger log.Logger) VisibilityManager

NewVisibilityManagerImpl returns new VisibilityManager

func NewVisibilityManagerWrapper 

func NewVisibilityManagerWrapper(
	visibilityManager VisibilityManager,
	esVisibilityManager VisibilityManager,
	enableReadVisibilityFromES dynamicconfig.BoolPropertyFnWithNamespaceFilter,
	advancedVisWritingMode dynamicconfig.StringPropertyFn,
) VisibilityManager

NewVisibilityManagerWrapper create a visibility manager that operate on DB or ElasticSearch based on dynamic config.

func NewVisibilityPersistenceMetricsClient 

func NewVisibilityPersistenceMetricsClient(persistence VisibilityManager, metricClient metrics.Client, logger log.Logger) VisibilityManager

NewVisibilityPersistenceMetricsClient creates a client to manage visibility

func NewVisibilityPersistenceRateLimitedClient 

func NewVisibilityPersistenceRateLimitedClient(persistence VisibilityManager, rateLimiter quotas.RateLimiter, logger log.Logger) VisibilityManager

NewVisibilityPersistenceRateLimitedClient creates a client to manage visibility

func NewVisibilitySamplingClient 

func NewVisibilitySamplingClient(
	persistence VisibilityManager,
	config *config.VisibilityConfig,
	metricClient metrics.Client,
	logger log.Logger,
) VisibilityManager

NewVisibilitySamplingClient creates a client to manage visibility with sampling

type VisibilityRequestBase 

type VisibilityRequestBase struct {
	NamespaceID          string
	Namespace            string // not persisted, used as config filter key
	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
}

type VisibilityStore 

type VisibilityStore interface {
	persistence.Closeable
	GetName() string
	RecordWorkflowExecutionStarted(request *InternalRecordWorkflowExecutionStartedRequest) error
	RecordWorkflowExecutionClosed(request *InternalRecordWorkflowExecutionClosedRequest) error
	UpsertWorkflowExecution(request *InternalUpsertWorkflowExecutionRequest) error
	ListOpenWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(request *ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByType(request *ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByWorkflowID(request *ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByStatus(request *ListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error)
	DeleteWorkflowExecution(request *VisibilityDeleteWorkflowExecutionRequest) error
	ListWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(request *ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(request *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
}

VisibilityStore is the store interface for visibility

type VisibilityWorkflowExecutionInfo 

type VisibilityWorkflowExecutionInfo struct {
	WorkflowID           string
	RunID                string
	TypeName             string
	StartTime            time.Time
	ExecutionTime        time.Time
	CloseTime            time.Time
	Status               enumspb.WorkflowExecutionStatus
	HistoryLength        int64
	StateTransitionCount int64
	Memo                 *commonpb.DataBlob
	TaskQueue            string
	SearchAttributes     *commonpb.SearchAttributes
}

VisibilityWorkflowExecutionInfo is visibility info for internal response

Source Files

View all Source files

Directories

Path Synopsis
Package elasticsearch is a generated GoMock package.
 Package elasticsearch is a generated GoMock package.
client
Package client is a generated GoMock package.
 Package client is a generated GoMock package.
query
Package query is inspired and partially copied from by github.com/cch123/elasticsql.
 Package query is inspired and partially copied from by github.com/cch123/elasticsql.

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.