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

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"
)

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
}