Documentation
¶
Index ¶
- func NewDurableQueueManager(log *zap.Logger, queuePath string, metrics *metrics.ReplicationsMetrics, ...) *durableQueueManager
- func NewValidator() *noopWriteValidator
- type Store
- func (s *Store) CreateReplication(ctx context.Context, newID platform.ID, ...) (*influxdb.Replication, error)
- func (s *Store) DeleteBucketReplications(ctx context.Context, localBucketID platform.ID) ([]platform.ID, error)
- func (s *Store) DeleteReplication(ctx context.Context, id platform.ID) error
- func (s *Store) GetFullHTTPConfig(ctx context.Context, id platform.ID) (*influxdb.ReplicationHTTPConfig, error)
- func (s *Store) GetReplication(ctx context.Context, id platform.ID) (*influxdb.Replication, error)
- func (s *Store) ListReplications(ctx context.Context, filter influxdb.ReplicationListFilter) (*influxdb.Replications, error)
- func (s *Store) Lock()
- func (s *Store) PopulateRemoteHTTPConfig(ctx context.Context, id platform.ID, target *influxdb.ReplicationHTTPConfig) error
- func (s *Store) Unlock()
- func (s *Store) UpdateReplication(ctx context.Context, id platform.ID, request influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)
- func (s *Store) UpdateResponseInfo(ctx context.Context, id platform.ID, code int, message string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDurableQueueManager ¶
func NewDurableQueueManager(log *zap.Logger, queuePath string, metrics *metrics.ReplicationsMetrics, configStore remotewrite.HttpConfigStore) *durableQueueManager
NewDurableQueueManager creates a new durableQueueManager struct, for managing durable queues associated with replication streams.
func NewValidator ¶
func NewValidator() *noopWriteValidator
Types ¶
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) CreateReplication ¶
func (s *Store) CreateReplication(ctx context.Context, newID platform.ID, request influxdb.CreateReplicationRequest) (*influxdb.Replication, error)
CreateReplication persists a new replication in the database. Caller is responsible for managing locks.
func (*Store) DeleteBucketReplications ¶
func (s *Store) DeleteBucketReplications(ctx context.Context, localBucketID platform.ID) ([]platform.ID, error)
DeleteBucketReplications deletes the replications for the provided localBucketID from the database. Caller is responsible for managing locks. A list of deleted IDs is returned for further processing by the caller.
func (*Store) DeleteReplication ¶
DeleteReplication deletes a replication by ID from the database. Caller is responsible for managing locks.
func (*Store) GetFullHTTPConfig ¶
func (*Store) GetReplication ¶
GetReplication gets a replication by ID from the database.
func (*Store) ListReplications ¶
func (s *Store) ListReplications(ctx context.Context, filter influxdb.ReplicationListFilter) (*influxdb.Replications, error)
ListReplications returns a list of replications matching the provided filter.
func (*Store) PopulateRemoteHTTPConfig ¶
func (*Store) UpdateReplication ¶
func (s *Store) UpdateReplication(ctx context.Context, id platform.ID, request influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)
UpdateReplication updates a replication by ID. Caller is responsible for managing locks.
Source Files