temporal

Documentation

Index

• type MetricCollector
  • func NewMetricCollector(name string) *MetricCollector
  • func (c *MetricCollector) Close() error
  • func (c *MetricCollector) CollectMetric(ctx context.Context, app string) (float64, error)
  • func (c *MetricCollector) Name() string
  • func (c *MetricCollector) Open() (err error)

Types

type MetricCollector

type MetricCollector struct {

	// Host & port of the Temporal server. Must be set before calling Open().
	Address string

	// Namespace to connect to. Must be set before calling Open().
	Namespace string

	// Certificate & key data. Optional. Must be set before calling Open().
	Cert []byte
	Key  []byte

	// Query string used to filter running workflows.
	Query string
	// contains filtered or unexported fields
}

func NewMetricCollector

func NewMetricCollector(name string) *MetricCollector

func (*MetricCollector) Close

func (c *MetricCollector) Close() error

func (*MetricCollector) CollectMetric

func (c *MetricCollector) CollectMetric(ctx context.Context, app string) (float64, error)

func (*MetricCollector) Name

func (c *MetricCollector) Name() string

func (*MetricCollector) Open

func (c *MetricCollector) Open() (err error)