replications

Apr 5, 2023

Changes in this version

type DurableQueueManager

+ RemainingQueueSizes func(ids []platform.ID) (map[platform.ID]int64, error)

Mar 29, 2022

Changes in this version

+ func NewBucketService(log *zap.Logger, bucketSvc influxdb.BucketService, deleter ReplicationDeleter) *bucketService

+ func NewService(sqlStore *sqlite.SqlStore, bktSvc BucketService, ...) (*service, *metrics.ReplicationsMetrics)

+ type BucketService interface

+ FindBucketByID func(ctx context.Context, id platform.ID) (*influxdb.Bucket, error)

+ RLock func()

+ RUnlock func()

+ type DurableQueueManager interface

+ CloseAll func() error

+ CurrentQueueSizes func(ids []platform.ID) (map[platform.ID]int64, error)

+ DeleteQueue func(replicationID platform.ID) error

+ EnqueueData func(replicationID platform.ID, data []byte, numPoints int) error

+ GetReplications func(orgId platform.ID, localBucketID platform.ID) []platform.ID

+ InitializeQueue func(replicationID platform.ID, maxQueueSizeBytes int64, orgID platform.ID, ...) error

+ StartReplicationQueues func(trackedReplications map[platform.ID]*influxdb.TrackedReplication) error

+ UpdateMaxQueueSize func(replicationID platform.ID, maxQueueSizeBytes int64) error

+ type ReplicationDeleter interface

+ DeleteBucketReplications func(context.Context, platform.ID) error

+ type ReplicationValidator interface

+ ValidateReplication func(context.Context, *influxdb.ReplicationHTTPConfig) error

+ type ServiceStore interface

+ CreateReplication func(context.Context, platform.ID, influxdb.CreateReplicationRequest) (*influxdb.Replication, error)

+ DeleteBucketReplications func(context.Context, platform.ID) ([]platform.ID, error)

+ DeleteReplication func(context.Context, platform.ID) error

+ GetFullHTTPConfig func(context.Context, platform.ID) (*influxdb.ReplicationHTTPConfig, error)

+ GetReplication func(context.Context, platform.ID) (*influxdb.Replication, error)

+ ListReplications func(context.Context, influxdb.ReplicationListFilter) (*influxdb.Replications, error)

+ Lock func()

+ PopulateRemoteHTTPConfig func(context.Context, platform.ID, *influxdb.ReplicationHTTPConfig) error

+ Unlock func()

+ UpdateReplication func(context.Context, platform.ID, influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)