query

package
v1.2.13-prerelease08 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package query is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockRegistry added in v1.2.10 

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

MockRegistry is a mock of Registry interface.

func NewMockRegistry added in v1.2.10 

func NewMockRegistry(ctrl *gomock.Controller) *MockRegistry

NewMockRegistry creates a new mock instance.

func (*MockRegistry) BufferQuery added in v1.2.10 

func (m *MockRegistry) BufferQuery(queryInput *types.WorkflowQuery) (string, <-chan struct{})

BufferQuery mocks base method.

func (*MockRegistry) EXPECT added in v1.2.10 

func (m *MockRegistry) EXPECT() *MockRegistryMockRecorder

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

func (*MockRegistry) GetBufferedIDs added in v1.2.10 

func (m *MockRegistry) GetBufferedIDs() []string

GetBufferedIDs mocks base method.

func (*MockRegistry) GetCompletedIDs added in v1.2.10 

func (m *MockRegistry) GetCompletedIDs() []string

GetCompletedIDs mocks base method.

func (*MockRegistry) GetFailedIDs added in v1.2.10 

func (m *MockRegistry) GetFailedIDs() []string

GetFailedIDs mocks base method.

func (*MockRegistry) GetQueryInput added in v1.2.10 

func (m *MockRegistry) GetQueryInput(arg0 string) (*types.WorkflowQuery, error)

GetQueryInput mocks base method.

func (*MockRegistry) GetQueryTermCh added in v1.2.10 

func (m *MockRegistry) GetQueryTermCh(arg0 string) (<-chan struct{}, error)

GetQueryTermCh mocks base method.

func (*MockRegistry) GetTerminationState added in v1.2.10 

func (m *MockRegistry) GetTerminationState(arg0 string) (*TerminationState, error)

GetTerminationState mocks base method.

func (*MockRegistry) GetUnblockedIDs added in v1.2.10 

func (m *MockRegistry) GetUnblockedIDs() []string

GetUnblockedIDs mocks base method.

func (*MockRegistry) HasBufferedQuery added in v1.2.10 

func (m *MockRegistry) HasBufferedQuery() bool

HasBufferedQuery mocks base method.

func (*MockRegistry) HasCompletedQuery added in v1.2.10 

func (m *MockRegistry) HasCompletedQuery() bool

HasCompletedQuery mocks base method.

func (*MockRegistry) HasFailedQuery added in v1.2.10 

func (m *MockRegistry) HasFailedQuery() bool

HasFailedQuery mocks base method.

func (*MockRegistry) HasUnblockedQuery added in v1.2.10 

func (m *MockRegistry) HasUnblockedQuery() bool

HasUnblockedQuery mocks base method.

func (*MockRegistry) RemoveQuery added in v1.2.10 

func (m *MockRegistry) RemoveQuery(id string)

RemoveQuery mocks base method.

func (*MockRegistry) SetTerminationState added in v1.2.10 

func (m *MockRegistry) SetTerminationState(arg0 string, arg1 *TerminationState) error

SetTerminationState mocks base method.

type MockRegistryMockRecorder added in v1.2.10 

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

MockRegistryMockRecorder is the mock recorder for MockRegistry.

func (*MockRegistryMockRecorder) BufferQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) BufferQuery(queryInput interface{}) *gomock.Call

BufferQuery indicates an expected call of BufferQuery.

func (*MockRegistryMockRecorder) GetBufferedIDs added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetBufferedIDs() *gomock.Call

GetBufferedIDs indicates an expected call of GetBufferedIDs.

func (*MockRegistryMockRecorder) GetCompletedIDs added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetCompletedIDs() *gomock.Call

GetCompletedIDs indicates an expected call of GetCompletedIDs.

func (*MockRegistryMockRecorder) GetFailedIDs added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetFailedIDs() *gomock.Call

GetFailedIDs indicates an expected call of GetFailedIDs.

func (*MockRegistryMockRecorder) GetQueryInput added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetQueryInput(arg0 interface{}) *gomock.Call

GetQueryInput indicates an expected call of GetQueryInput.

func (*MockRegistryMockRecorder) GetQueryTermCh added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetQueryTermCh(arg0 interface{}) *gomock.Call

GetQueryTermCh indicates an expected call of GetQueryTermCh.

func (*MockRegistryMockRecorder) GetTerminationState added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetTerminationState(arg0 interface{}) *gomock.Call

GetTerminationState indicates an expected call of GetTerminationState.

func (*MockRegistryMockRecorder) GetUnblockedIDs added in v1.2.10 

func (mr *MockRegistryMockRecorder) GetUnblockedIDs() *gomock.Call

GetUnblockedIDs indicates an expected call of GetUnblockedIDs.

func (*MockRegistryMockRecorder) HasBufferedQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) HasBufferedQuery() *gomock.Call

HasBufferedQuery indicates an expected call of HasBufferedQuery.

func (*MockRegistryMockRecorder) HasCompletedQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) HasCompletedQuery() *gomock.Call

HasCompletedQuery indicates an expected call of HasCompletedQuery.

func (*MockRegistryMockRecorder) HasFailedQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) HasFailedQuery() *gomock.Call

HasFailedQuery indicates an expected call of HasFailedQuery.

func (*MockRegistryMockRecorder) HasUnblockedQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) HasUnblockedQuery() *gomock.Call

HasUnblockedQuery indicates an expected call of HasUnblockedQuery.

func (*MockRegistryMockRecorder) RemoveQuery added in v1.2.10 

func (mr *MockRegistryMockRecorder) RemoveQuery(id interface{}) *gomock.Call

RemoveQuery indicates an expected call of RemoveQuery.

func (*MockRegistryMockRecorder) SetTerminationState added in v1.2.10 

func (mr *MockRegistryMockRecorder) SetTerminationState(arg0, arg1 interface{}) *gomock.Call

SetTerminationState indicates an expected call of SetTerminationState.

type Registry 

type Registry interface {
	HasBufferedQuery() bool
	GetBufferedIDs() []string
	HasCompletedQuery() bool
	GetCompletedIDs() []string
	HasUnblockedQuery() bool
	GetUnblockedIDs() []string
	HasFailedQuery() bool
	GetFailedIDs() []string

	GetQueryTermCh(string) (<-chan struct{}, error)
	GetQueryInput(string) (*types.WorkflowQuery, error)
	GetTerminationState(string) (*TerminationState, error)

	BufferQuery(queryInput *types.WorkflowQuery) (string, <-chan struct{})
	SetTerminationState(string, *TerminationState) error
	RemoveQuery(id string)
}

Registry manages all the queries for a workflow

func NewRegistry 

func NewRegistry() Registry

NewRegistry creates a new query registry

type TerminationState 

type TerminationState struct {
	TerminationType TerminationType
	QueryResult     *types.WorkflowQueryResult
	Failure         error
}

TerminationState describes a query's termination state

type TerminationType 

type TerminationType int

TerminationType is the type of a query's termination state 

const (
	// TerminationTypeCompleted means a query reaches its termination state because it has been completed
	TerminationTypeCompleted TerminationType = iota
	// TerminationTypeUnblocked means a query reaches its termination state because it has been unblocked
	TerminationTypeUnblocked
	// TerminationTypeFailed means a query reaches its termination state because it has failed
	TerminationTypeFailed
)

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.