remotewrite

Documentation

Index

• Constants
• func NewWriter(replicationID platform.ID, store HttpConfigStore, ...) *writer
• func PostWrite(ctx context.Context, config *influxdb.ReplicationHTTPConfig, data []byte, ...) (*http.Response, error)
• type HttpConfigStore

Constants

const (
	DefaultTimeout = 2 * time.Minute
)

Functions

func NewWriter

func NewWriter(replicationID platform.ID, store HttpConfigStore, metrics *metrics.ReplicationsMetrics, logger *zap.Logger, done chan struct{}) *writer

func PostWrite

func PostWrite(ctx context.Context, config *influxdb.ReplicationHTTPConfig, data []byte, timeout time.Duration) (*http.Response, error)

Types

type HttpConfigStore

type HttpConfigStore interface {
	GetFullHTTPConfig(context.Context, platform.ID) (*influxdb.ReplicationHTTPConfig, error)
	UpdateResponseInfo(context.Context, platform.ID, int, string) error
}