telemetry

Documentation

Index

• type TelemetryDataStoreFactory
  • func NewTelemetryDataStoreFactory(baseFactory persistence.DataStoreFactory, logger log.Logger, ...) *TelemetryDataStoreFactory
  • func (d *TelemetryDataStoreFactory) Close()
  • func (d *TelemetryDataStoreFactory) NewClusterMetadataStore() (persistence.ClusterMetadataStore, error)
  • func (d *TelemetryDataStoreFactory) NewExecutionStore() (persistence.ExecutionStore, error)
  • func (d *TelemetryDataStoreFactory) NewMetadataStore() (persistence.MetadataStore, error)
  • func (d *TelemetryDataStoreFactory) NewNexusEndpointStore() (persistence.NexusEndpointStore, error)
  • func (d *TelemetryDataStoreFactory) NewQueue(queueType persistence.QueueType) (persistence.Queue, error)
  • func (d *TelemetryDataStoreFactory) NewQueueV2() (persistence.QueueV2, error)
  • func (d *TelemetryDataStoreFactory) NewShardStore() (persistence.ShardStore, error)
  • func (d *TelemetryDataStoreFactory) NewTaskStore() (persistence.TaskStore, error)

Types

type TelemetryDataStoreFactory

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

func NewTelemetryDataStoreFactory

func NewTelemetryDataStoreFactory(
	baseFactory persistence.DataStoreFactory,
	logger log.Logger,
	tracer trace.Tracer,
) *TelemetryDataStoreFactory

func (*TelemetryDataStoreFactory) Close

func (d *TelemetryDataStoreFactory) Close()

func (*TelemetryDataStoreFactory) NewClusterMetadataStore

func (d *TelemetryDataStoreFactory) NewClusterMetadataStore() (persistence.ClusterMetadataStore, error)

func (*TelemetryDataStoreFactory) NewExecutionStore

func (d *TelemetryDataStoreFactory) NewExecutionStore() (persistence.ExecutionStore, error)

func (*TelemetryDataStoreFactory) NewMetadataStore

func (d *TelemetryDataStoreFactory) NewMetadataStore() (persistence.MetadataStore, error)

func (*TelemetryDataStoreFactory) NewNexusEndpointStore

func (d *TelemetryDataStoreFactory) NewNexusEndpointStore() (persistence.NexusEndpointStore, error)

func (*TelemetryDataStoreFactory) NewQueue

func (d *TelemetryDataStoreFactory) NewQueue(queueType persistence.QueueType) (persistence.Queue, error)

func (*TelemetryDataStoreFactory) NewQueueV2

func (d *TelemetryDataStoreFactory) NewQueueV2() (persistence.QueueV2, error)

func (*TelemetryDataStoreFactory) NewShardStore

func (d *TelemetryDataStoreFactory) NewShardStore() (persistence.ShardStore, error)

func (*TelemetryDataStoreFactory) NewTaskStore

func (d *TelemetryDataStoreFactory) NewTaskStore() (persistence.TaskStore, error)