workers

type ListWorkersParams struct {
	Query         string
	PageSize      int
	NextPageToken []byte // Opaque token from a previous response to resume pagination.
}

type ListWorkersResponse struct {
	Workers       []*workerpb.WorkerHeartbeat
	NextPageToken []byte // Opaque token for the next page; nil if no more results.
}

type Registry interface {
	RecordWorkerHeartbeats(nsID namespace.ID, nsName namespace.Name, workerHeartbeat []*workerpb.WorkerHeartbeat)
	ListWorkers(nsID namespace.ID, params ListWorkersParams) (ListWorkersResponse, error)
	DescribeWorker(nsID namespace.ID, workerInstanceKey string) (*workerpb.WorkerHeartbeat, error)
}

type RegistryParams struct {
	NumBuckets       dynamicconfig.IntPropertyFn
	TTL              dynamicconfig.DurationPropertyFn
	MinEvictAge      dynamicconfig.DurationPropertyFn
	MaxItems         dynamicconfig.IntPropertyFn
	EvictionInterval dynamicconfig.DurationPropertyFn
	MetricsHandler   metrics.Handler
	MetricsConfig    WorkerMetricsConfig
}

type WorkerHeartbeatPropertyFunc func(*workerpb.WorkerHeartbeat) string

type WorkerMetricsConfig struct {
	EnablePluginMetrics            dynamicconfig.BoolPropertyFn
	EnablePollerAutoscalingMetrics dynamicconfig.BoolPropertyFn
	BreakdownMetricsByTaskQueue    dynamicconfig.BoolPropertyFnWithTaskQueueFilter
	ExternalPayloadsEnabled        dynamicconfig.BoolPropertyFnWithNamespaceFilter
}