pinotvisibility

Documentation

Index

• Constants
• func NewPinotVisibilityMetricsClient(persistence p.VisibilityManager, metricClient metrics.Client, ...) p.VisibilityManager
• func NewPinotVisibilityStore(pinotClient pnt.GenericClient, config *service.Config, ...) p.VisibilityStore
• type PinotQuery
  • func NewPinotCountQuery(tableName string) PinotQuery
  • func NewPinotQuery(tableName string) PinotQuery
  • func (q *PinotQuery) String() string
• type PinotQueryFilter
• type PinotQuerySearchField

Constants

const (
	DescendingOrder  = "DESC"
	AscendingOrder   = "ASC"
	DomainID         = "DomainID"
	WorkflowID       = "WorkflowID"
	RunID            = "RunID"
	WorkflowType     = "WorkflowType"
	CloseStatus      = "CloseStatus"
	HistoryLength    = "HistoryLength"
	TaskList         = "TaskList"
	IsCron           = "IsCron"
	NumClusters      = "NumClusters"
	ShardID          = "ShardID"
	Attr             = "Attr"
	StartTime        = "StartTime"
	CloseTime        = "CloseTime"
	UpdateTime       = "UpdateTime"
	ExecutionTime    = "ExecutionTime"
	IsDeleted        = "IsDeleted"   // used for Pinot deletion/rolling upsert only, not visible to user
	EventTimeMs      = "EventTimeMs" // used for Pinot deletion/rolling upsert only, not visible to user
	Memo             = "Memo"
	WfIDTextSearch   = "WorkflowIDTextSearch"   // used for text search which can improve the partial match performance on WorkflowID/RunID/WorkflowType text search columns
	WfTypeTextSearch = "WorkflowTypeTextSearch" // used for text search which can improve the partial match performance on WorkflowID/RunID/WorkflowType text search columns
	RunIDTextSearch  = "RunIDTextSearch"        // used for text search which can improve the partial match performance on WorkflowID/RunID/WorkflowType text search columns

)

Functions

func NewPinotVisibilityMetricsClient

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

NewPinotVisibilityMetricsClient wrap visibility client with metrics client

func NewPinotVisibilityStore

func NewPinotVisibilityStore(
	pinotClient pnt.GenericClient,
	config *service.Config,
	producer messaging.Producer,
	logger log.Logger,
) p.VisibilityStore

Types

type PinotQuery

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

func NewPinotCountQuery

func NewPinotCountQuery(tableName string) PinotQuery

func NewPinotQuery

func NewPinotQuery(tableName string) PinotQuery

func (*PinotQuery) String

func (q *PinotQuery) String() string

type PinotQueryFilter

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

type PinotQuerySearchField

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