Documentation
¶
Index ¶
- func NewBucketService(log *zap.Logger, bucketSvc influxdb.BucketService, deleter ReplicationDeleter) *bucketService
- func NewService(sqlStore *sqlite.SqlStore, bktSvc BucketService, ...) (*service, *metrics.ReplicationsMetrics)
- type BucketService
- type DurableQueueManager
- type ReplicationDeleter
- type ReplicationValidator
- type ServiceStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBucketService ¶
func NewBucketService(log *zap.Logger, bucketSvc influxdb.BucketService, deleter ReplicationDeleter) *bucketService
func NewService ¶
func NewService(sqlStore *sqlite.SqlStore, bktSvc BucketService, localWriter storage.PointsWriter, log *zap.Logger, enginePath string, instanceID string) (*service, *metrics.ReplicationsMetrics)
Types ¶
type BucketService ¶
type DurableQueueManager ¶
type DurableQueueManager interface {
InitializeQueue(replicationID platform.ID, maxQueueSizeBytes int64, orgID platform.ID, localBucketID platform.ID, maxAge int64) error
DeleteQueue(replicationID platform.ID) error
UpdateMaxQueueSize(replicationID platform.ID, maxQueueSizeBytes int64) error
CurrentQueueSizes(ids []platform.ID) (map[platform.ID]int64, error)
RemainingQueueSizes(ids []platform.ID) (map[platform.ID]int64, error)
StartReplicationQueues(trackedReplications map[platform.ID]*influxdb.TrackedReplication) error
CloseAll() error
EnqueueData(replicationID platform.ID, data []byte, numPoints int) error
GetReplications(orgId platform.ID, localBucketID platform.ID) []platform.ID
}
type ReplicationDeleter ¶
type ReplicationValidator ¶
type ReplicationValidator interface {
ValidateReplication(context.Context, *influxdb.ReplicationHTTPConfig) error
}
type ServiceStore ¶
type ServiceStore interface {
Lock()
Unlock()
ListReplications(context.Context, influxdb.ReplicationListFilter) (*influxdb.Replications, error)
CreateReplication(context.Context, platform.ID, influxdb.CreateReplicationRequest) (*influxdb.Replication, error)
GetReplication(context.Context, platform.ID) (*influxdb.Replication, error)
UpdateReplication(context.Context, platform.ID, influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)
DeleteReplication(context.Context, platform.ID) error
PopulateRemoteHTTPConfig(context.Context, platform.ID, *influxdb.ReplicationHTTPConfig) error
GetFullHTTPConfig(context.Context, platform.ID) (*influxdb.ReplicationHTTPConfig, error)
DeleteBucketReplications(context.Context, platform.ID) ([]platform.ID, error)
}
Click to show internal directories.
Click to hide internal directories.