transport

type ReplicationHandler struct {
	chi.Router
	// contains filtered or unexported fields
}

type ReplicationService interface {
	// ListReplications returns all info about registered replications matching a filter.
	ListReplications(context.Context, influxdb.ReplicationListFilter) (*influxdb.Replications, error)

	// CreateReplication registers a new replication stream.
	CreateReplication(context.Context, influxdb.CreateReplicationRequest) (*influxdb.Replication, error)

	// ValidateNewReplication validates that the given settings for a replication are usable,
	// without persisting the configuration.
	ValidateNewReplication(context.Context, influxdb.CreateReplicationRequest) error

	// GetReplication returns metadata about the replication with the given ID.
	GetReplication(context.Context, platform.ID) (*influxdb.Replication, error)

	// UpdateReplication updates the settings for the replication with the given ID.
	UpdateReplication(context.Context, platform.ID, influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)

	// ValidateUpdatedReplication valdiates that a replication is still usable after applying the
	// given update, without persisting the new configuration.
	ValidateUpdatedReplication(context.Context, platform.ID, influxdb.UpdateReplicationRequest) error

	// DeleteReplication deletes all info for the replication with the given ID.
	DeleteReplication(context.Context, platform.ID) error

	// ValidateReplication checks that the replication with the given ID is still usable with its
	// persisted settings.
	ValidateReplication(context.Context, platform.ID) error
}