29
logger log.Logger,
30
tracer trace.Tracer,
32
>
return &TelemetryDataStoreFactory{
33
>
baseFactory: baseFactory,
34
>
logger: logger,
35
>
tracer: tracer,
36
>
}
37
>
}
38
40
>
d.baseFactory.Close()
41
>
}
42
43
>
func (d *TelemetryDataStoreFactory) NewTaskStore() (persistence.TaskStore, error) {
data_store_factory.go
44
>
if d.taskStore == nil {
45
>
baseStore, err := d.baseFactory.NewTaskStore()
46
>
if err != nil {
47
return nil, err
48
}
50
}
52
}
53
54
>
func (d *TelemetryDataStoreFactory) NewFairTaskStore() (persistence.TaskStore, error) {
data_store_factory.go
55
>
if d.fairTaskStore == nil {
56
>
baseStore, err := d.baseFactory.NewFairTaskStore()
57
>
if err != nil {
58
return nil, err
59
}
61
}
63
}
64
65
>
func (d *TelemetryDataStoreFactory) NewShardStore() (persistence.ShardStore, error) {
data_store_factory.go
66
>
if d.shardStore == nil {
67
>
baseStore, err := d.baseFactory.NewShardStore()
68
>
if err != nil {
69
return nil, err
70
}
72
}
74
}
75
76
>
func (d *TelemetryDataStoreFactory) NewMetadataStore() (persistence.MetadataStore, error) {
data_store_factory.go
77
>
if d.metadataStore == nil {
78
>
baseStore, err := d.baseFactory.NewMetadataStore()
79
>
if err != nil {
80
return nil, err
81
}
83
}
85
}
86
87
>
func (d *TelemetryDataStoreFactory) NewExecutionStore() (persistence.ExecutionStore, error) {
data_store_factory.go
88
>
if d.executionStore == nil {
89
>
baseStore, err := d.baseFactory.NewExecutionStore()
90
>
if err != nil {
91
return nil, err
92
}
94
}
96
}
97
98
>
func (d *TelemetryDataStoreFactory) NewQueue(queueType persistence.QueueType) (persistence.Queue, error) {
data_store_factory.go
99
>
if d.queue == nil {
100
>
baseQueue, err := d.baseFactory.NewQueue(queueType)
101
>
if err != nil {
102
return baseQueue, err
103
}
105
}
107
}
108
109
>
func (d *TelemetryDataStoreFactory) NewQueueV2() (persistence.QueueV2, error) {
data_store_factory.go
110
>
if d.queueV2 == nil {
111
>
baseQueue, err := d.baseFactory.NewQueueV2()
112
>
if err != nil {
113
return baseQueue, err
114
}
116
}
118
}
119
120
>
func (d *TelemetryDataStoreFactory) NewClusterMetadataStore() (persistence.ClusterMetadataStore, error) {
data_store_factory.go
121
>
if d.clusterMDStore == nil {
122
>
baseStore, err := d.baseFactory.NewClusterMetadataStore()
123
>
if err != nil {
124
return nil, err
125
}
126
>
d.clusterMDStore = newTelemetryClusterMetadataStore(baseStore, d.logger, d.tracer)
data_store_factory.go
127
}
129
}
130
131
>
func (d *TelemetryDataStoreFactory) NewNexusEndpointStore() (persistence.NexusEndpointStore, error) {
data_store_factory.go
132
>
if d.nexusEndpointStore == nil {
133
>
baseStore, err := d.baseFactory.NewNexusEndpointStore()
134
>
if err != nil {
135
return nil, err
136
}
137
>
d.nexusEndpointStore = newTelemetryNexusEndpointStore(baseStore, d.logger, d.tracer)
data_store_factory.go
138
}
140
}