store

package
v1.13.4 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2022 License: MIT Imports: 8 Imported by: 2

Documentation

Overview

Package store is a generated GoMock package.

Index

Constants

This section is empty.

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 InternalListWorkflowExecutionsResponse 

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

type InternalWorkflowExecutionInfo 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
}

InternalWorkflowExecutionInfo is visibility info for internal response

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 *manager.CountWorkflowExecutionsRequest) (*manager.CountWorkflowExecutionsResponse, error)

CountWorkflowExecutions mocks base method.

func (*MockVisibilityStore) DeleteWorkflowExecution 

func (m *MockVisibilityStore) DeleteWorkflowExecution(request *manager.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 *manager.ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)

ListClosedWorkflowExecutions mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByStatus 

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

ListClosedWorkflowExecutionsByStatus mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByType 

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

ListClosedWorkflowExecutionsByType mocks base method.

func (*MockVisibilityStore) ListClosedWorkflowExecutionsByWorkflowID 

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

ListClosedWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutions 

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

ListOpenWorkflowExecutions mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutionsByType 

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

ListOpenWorkflowExecutionsByType mocks base method.

func (*MockVisibilityStore) ListOpenWorkflowExecutionsByWorkflowID 

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

ListOpenWorkflowExecutionsByWorkflowID mocks base method.

func (*MockVisibilityStore) ListWorkflowExecutions 

func (m *MockVisibilityStore) ListWorkflowExecutions(request *manager.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 *manager.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 VisibilityStore 

type VisibilityStore interface {
	persistence.Closeable
	GetName() string

	// Write APIs.
	RecordWorkflowExecutionStarted(request *InternalRecordWorkflowExecutionStartedRequest) error
	RecordWorkflowExecutionClosed(request *InternalRecordWorkflowExecutionClosedRequest) error
	UpsertWorkflowExecution(request *InternalUpsertWorkflowExecutionRequest) error
	DeleteWorkflowExecution(request *manager.VisibilityDeleteWorkflowExecutionRequest) error

	// Read APIs.
	ListOpenWorkflowExecutions(request *manager.ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutions(request *manager.ListWorkflowExecutionsRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByType(request *manager.ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByType(request *manager.ListWorkflowExecutionsByTypeRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListOpenWorkflowExecutionsByWorkflowID(request *manager.ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByWorkflowID(request *manager.ListWorkflowExecutionsByWorkflowIDRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListClosedWorkflowExecutionsByStatus(request *manager.ListClosedWorkflowExecutionsByStatusRequest) (*InternalListWorkflowExecutionsResponse, error)
	ListWorkflowExecutions(request *manager.ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)
	ScanWorkflowExecutions(request *manager.ListWorkflowExecutionsRequestV2) (*InternalListWorkflowExecutionsResponse, error)
	CountWorkflowExecutions(request *manager.CountWorkflowExecutionsRequest) (*manager.CountWorkflowExecutionsResponse, error)
}

VisibilityStore is the store interface for visibility

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.