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"
	AcendingOrder     = "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"
	Encoding          = "Encoding"
	LikeStatement     = "%s LIKE '%%%s%%'"
	IsDeleted         = "IsDeleted"         // used for Pinot deletion/rolling upsert only, not visible to user
	SecondsSinceEpoch = "SecondsSinceEpoch" // used for Pinot deletion/rolling upsert only, not visible to user

)

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
}