pinot

Documentation

Overview

Package pinot is a generated GoMock package.

Index

• Constants
• func ConvertSearchResultToVisibilityRecord(hit []interface{}, columnNames []string) (*p.InternalVisibilityWorkflowExecutionInfo, error)
• func SerializePageToken(token *PinotVisibilityPageToken) ([]byte, error)
• type AggrResponse
• type GenericClient
  • func NewPinotClient(client *pinot.Connection, logger log.Logger, ...) GenericClient
• type IsRecordValidFilter
• type MockGenericClient
  • func NewMockGenericClient(ctrl *gomock.Controller) *MockGenericClient
  • func (m *MockGenericClient) CountByQuery(query string) (int64, error)
  • func (m *MockGenericClient) EXPECT() *MockGenericClientMockRecorder
  • func (m *MockGenericClient) GetTableName() string
  • func (m *MockGenericClient) Search(request *SearchRequest) (*SearchResponse, error)
  • func (m *MockGenericClient) SearchAggr(request *SearchRequest) (AggrResponse, error)
• type MockGenericClientMockRecorder
  • func (mr *MockGenericClientMockRecorder) CountByQuery(query interface{}) *gomock.Call
  • func (mr *MockGenericClientMockRecorder) GetTableName() *gomock.Call
  • func (mr *MockGenericClientMockRecorder) Search(request interface{}) *gomock.Call
  • func (mr *MockGenericClientMockRecorder) SearchAggr(request interface{}) *gomock.Call
• type PinotClient
  • func (c *PinotClient) CountByQuery(query string) (int64, error)
  • func (c *PinotClient) GetTableName() string
  • func (c *PinotClient) Search(request *SearchRequest) (*SearchResponse, error)
  • func (c *PinotClient) SearchAggr(request *SearchRequest) (AggrResponse, error)
• type PinotVisibilityPageToken
  • func DeserializePageToken(data []byte) (*PinotVisibilityPageToken, error)
  • func GetNextPageToken(token []byte) (*PinotVisibilityPageToken, error)
• type SearchRequest
• type SearchResponse
• type VisibilityQueryValidator
  • func NewPinotQueryValidator(validSearchAttributes dynamicconfig.MapPropertyFn) *VisibilityQueryValidator
  • func (qv *VisibilityQueryValidator) IsValidSearchAttributes(key string) bool
  • func (qv *VisibilityQueryValidator) ValidateQuery(whereClause string) (string, error)
• type VisibilityRecord

Constants

const (
	Memo = "Memo"
	Attr = "Attr"
)

Functions

func ConvertSearchResultToVisibilityRecord

func ConvertSearchResultToVisibilityRecord(hit []interface{}, columnNames []string) (*p.InternalVisibilityWorkflowExecutionInfo, error)

func SerializePageToken

func SerializePageToken(token *PinotVisibilityPageToken) ([]byte, error)

SerializePageToken return the token blob

Types

type AggrResponse

type AggrResponse [][]interface{}

type GenericClient

type GenericClient interface {
	// Search API is only for supporting various List[Open/Closed]WorkflowExecutions(ByXyz).
	// Use SearchByQuery or ScanByQuery for generic purpose searching.
	Search(request *SearchRequest) (*SearchResponse, error)
	SearchAggr(request *SearchRequest) (AggrResponse, error)
	// CountByQuery is for returning the count of workflow executions that match the query
	CountByQuery(query string) (int64, error)
	GetTableName() string
}

GenericClient is a generic interface for all versions of Pinot clients

func NewPinotClient

func NewPinotClient(client *pinot.Connection, logger log.Logger, pinotConfig *config.PinotVisibilityConfig) GenericClient

type IsRecordValidFilter

type IsRecordValidFilter func(rec *p.InternalVisibilityWorkflowExecutionInfo) bool

IsRecordValidFilter is a function to filter visibility records

type MockGenericClient

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

MockGenericClient is a mock of GenericClient interface.

func NewMockGenericClient

func NewMockGenericClient(ctrl *gomock.Controller) *MockGenericClient

NewMockGenericClient creates a new mock instance.

func (*MockGenericClient) CountByQuery

func (m *MockGenericClient) CountByQuery(query string) (int64, error)

CountByQuery mocks base method.

func (*MockGenericClient) EXPECT

func (m *MockGenericClient) EXPECT() *MockGenericClientMockRecorder

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

func (*MockGenericClient) GetTableName

func (m *MockGenericClient) GetTableName() string

GetTableName mocks base method.

func (*MockGenericClient) Search

func (m *MockGenericClient) Search(request *SearchRequest) (*SearchResponse, error)

Search mocks base method.

func (*MockGenericClient) SearchAggr

func (m *MockGenericClient) SearchAggr(request *SearchRequest) (AggrResponse, error)

SearchAggr mocks base method.

type MockGenericClientMockRecorder

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

MockGenericClientMockRecorder is the mock recorder for MockGenericClient.

func (*MockGenericClientMockRecorder) CountByQuery

func (mr *MockGenericClientMockRecorder) CountByQuery(query interface{}) *gomock.Call

CountByQuery indicates an expected call of CountByQuery.

func (*MockGenericClientMockRecorder) GetTableName

func (mr *MockGenericClientMockRecorder) GetTableName() *gomock.Call

GetTableName indicates an expected call of GetTableName.

func (*MockGenericClientMockRecorder) Search

func (mr *MockGenericClientMockRecorder) Search(request interface{}) *gomock.Call

Search indicates an expected call of Search.

func (*MockGenericClientMockRecorder) SearchAggr

func (mr *MockGenericClientMockRecorder) SearchAggr(request interface{}) *gomock.Call

SearchAggr indicates an expected call of SearchAggr.

type PinotClient

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

func (*PinotClient) CountByQuery

func (c *PinotClient) CountByQuery(query string) (int64, error)

func (*PinotClient) GetTableName

func (c *PinotClient) GetTableName() string

func (*PinotClient) Search

func (c *PinotClient) Search(request *SearchRequest) (*SearchResponse, error)

func (*PinotClient) SearchAggr

func (c *PinotClient) SearchAggr(request *SearchRequest) (AggrResponse, error)

type PinotVisibilityPageToken

type PinotVisibilityPageToken struct {
	From int
}

PinotVisibilityPageToken holds the paging token for Pinot

func DeserializePageToken

func DeserializePageToken(data []byte) (*PinotVisibilityPageToken, error)

DeserializePageToken return the structural token

func GetNextPageToken

func GetNextPageToken(token []byte) (*PinotVisibilityPageToken, error)

GetNextPageToken returns the structural token with nil handling

type SearchRequest

type SearchRequest struct {
	Query           string
	IsOpen          bool
	Filter          IsRecordValidFilter
	MaxResultWindow int
	ListRequest     *p.InternalListWorkflowExecutionsRequest
}

SearchRequest is request for Search

type SearchResponse

type SearchResponse = p.InternalListWorkflowExecutionsResponse

SearchResponse is a response to Search, SearchByQuery and ScanByQuery

type VisibilityQueryValidator

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

VisibilityQueryValidator for sql query validation

func NewPinotQueryValidator

func NewPinotQueryValidator(validSearchAttributes dynamicconfig.MapPropertyFn) *VisibilityQueryValidator

NewPinotQueryValidator create VisibilityQueryValidator

func (*VisibilityQueryValidator) IsValidSearchAttributes

func (qv *VisibilityQueryValidator) IsValidSearchAttributes(key string) bool

IsValidSearchAttributes return true if key is registered

func (*VisibilityQueryValidator) ValidateQuery

func (qv *VisibilityQueryValidator) ValidateQuery(whereClause string) (string, error)

ValidateQuery validates that search attributes in the query and returns modified query.

type VisibilityRecord

type VisibilityRecord struct {
	WorkflowID    string
	RunID         string
	WorkflowType  string
	DomainID      string
	StartTime     int64
	ExecutionTime int64
	CloseTime     int64
	CloseStatus   int
	HistoryLength int64
	TaskList      string
	IsCron        bool
	NumClusters   int16
	UpdateTime    int64
	ShardID       int16
}

VisibilityRecord is a struct of doc for deserialization this is different from InternalVisibilityWorkflowExecutionInfo use this to deserialize the systemKeyMap from Pinot response