sink

package
v0.11.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 17, 2022 License: AGPL-3.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AMPLITUDE_STANDARD_ENDPOINT string = "https://api2.amplitude.com/2/httpapi"
	AMPLITUDE_EU_ENDPOINT       string = "https://api.eu.amplitude.com/2/httpapi"
	AMPLITUDE_STANDARD          string = "standard"
	AMPLITUDE_EU                string = "eu"
)
View Source 
const (
	DEFAULT_PARTITIONS         int32 = 3
	DEFAULT_REPLICATION_FACTOR int16 = 1 // NOTE! Really not a good default.
)
View Source 
const (
	PUBNUB_PUBLISH_URL   string = "ps.pndsn.com/publish"
	PUBNUB_HTTP_PROTOCOL string = "https"
)
View Source 
const (
	PUBSUB           string = "pubsub"
	REDPANDA         string = "redpanda"
	KAFKA            string = "kafka"
	KINESIS          string = "kinesis"
	KINESIS_FIREHOSE string = "kinesis-firehose"
	STDOUT           string = "stdout"
	HTTP             string = "http"
	HTTPS            string = "https"
	BLACKHOLE        string = "blackhole"
	FILE             string = "file"
	PUBNUB           string = "pubnub"
	NATS             string = "nats"
	NATS_JETSTREAM   string = "nats-jetstream"
	INDICATIVE       string = "indicative"
	AMPLITUDE        string = "amplitude"
)
View Source 
const INDICATIVE_BATCH_ENDPOINT string = "https://api.indicative.com/service/event/batch"
View Source 
const INIT_TIMEOUT_SECONDS = 10

Variables

View Source 
var (
	Info = Teal
	Warn = Yellow
	Fata = Red
)
View Source 
var (
	Black   = Colorize("\033[1;30m%s\033[0m")
	Red     = Colorize("\033[1;31m%s\033[0m")
	Green   = Colorize("\033[1;32m%s\033[0m")
	Yellow  = Colorize("\033[1;33m%s\033[0m")
	Purple  = Colorize("\033[1;34m%s\033[0m")
	Magenta = Colorize("\033[1;35m%s\033[0m")
	Teal    = Colorize("\033[1;36m%s\033[0m")
	White   = Colorize("\033[1;37m%s\033[0m")
)

Functions

func Colorize added in v0.1.24 

func Colorize(colorString string) func(...interface{}) string

func InitializeSink added in v0.1.24 

func InitializeSink(conf config.Sink, s Sink) error

Types

type AmplitudeSink added in v0.11.0 

type AmplitudeSink struct {
	// contains filtered or unexported fields
}

func (*AmplitudeSink) BatchPublishInvalid added in v0.11.0 

func (s *AmplitudeSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*AmplitudeSink) BatchPublishValid added in v0.11.0 

func (s *AmplitudeSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*AmplitudeSink) Close added in v0.11.0 

func (s *AmplitudeSink) Close()

func (*AmplitudeSink) DeliveryRequired added in v0.11.0 

func (s *AmplitudeSink) DeliveryRequired() bool

func (*AmplitudeSink) Id added in v0.11.0 

func (s *AmplitudeSink) Id() *uuid.UUID

func (*AmplitudeSink) Initialize added in v0.11.0 

func (s *AmplitudeSink) Initialize(conf config.Sink) error

func (*AmplitudeSink) Name added in v0.11.0 

func (s *AmplitudeSink) Name() string

func (*AmplitudeSink) Type added in v0.11.0 

func (s *AmplitudeSink) Type() string

type BlackholeSink added in v0.1.29 

type BlackholeSink struct {
	// contains filtered or unexported fields
}

func (*BlackholeSink) BatchPublishInvalid added in v0.1.29 

func (s *BlackholeSink) BatchPublishInvalid(ctx context.Context, invalidEnvelopes []envelope.Envelope) error

func (*BlackholeSink) BatchPublishValid added in v0.1.29 

func (s *BlackholeSink) BatchPublishValid(ctx context.Context, validEnvelopes []envelope.Envelope) error

func (*BlackholeSink) Close added in v0.1.29 

func (s *BlackholeSink) Close()

func (*BlackholeSink) DeliveryRequired added in v0.5.2 

func (s *BlackholeSink) DeliveryRequired() bool

func (*BlackholeSink) Id added in v0.1.31 

func (s *BlackholeSink) Id() *uuid.UUID

func (*BlackholeSink) Initialize added in v0.1.29 

func (s *BlackholeSink) Initialize(conf config.Sink) error

func (*BlackholeSink) Name added in v0.1.31 

func (s *BlackholeSink) Name() string

func (*BlackholeSink) Type added in v0.5.3 

func (s *BlackholeSink) Type() string

type ClickhouseSink added in v0.5.0 

type ClickhouseSink struct {
	// contains filtered or unexported fields
}

func (*ClickhouseSink) BatchPublishInvalid added in v0.5.0 

func (s *ClickhouseSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*ClickhouseSink) BatchPublishValid added in v0.5.0 

func (s *ClickhouseSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*ClickhouseSink) Close added in v0.5.0 

func (s *ClickhouseSink) Close()

func (*ClickhouseSink) DeliveryRequired added in v0.5.2 

func (s *ClickhouseSink) DeliveryRequired() bool

func (*ClickhouseSink) Id added in v0.5.0 

func (s *ClickhouseSink) Id() *uuid.UUID

func (*ClickhouseSink) Initialize added in v0.5.0 

func (s *ClickhouseSink) Initialize(conf config.Sink) error

func (*ClickhouseSink) Name added in v0.5.0 

func (s *ClickhouseSink) Name() string

func (*ClickhouseSink) Type added in v0.5.3 

func (s *ClickhouseSink) Type() string

type ElasticsearchSink added in v0.1.28 

type ElasticsearchSink struct {
	// contains filtered or unexported fields
}

func (*ElasticsearchSink) BatchPublishInvalid added in v0.1.28 

func (s *ElasticsearchSink) BatchPublishInvalid(ctx context.Context, invalidEnvelopes []envelope.Envelope) error

func (*ElasticsearchSink) BatchPublishValid added in v0.1.28 

func (s *ElasticsearchSink) BatchPublishValid(ctx context.Context, validEnvelopes []envelope.Envelope) error

func (*ElasticsearchSink) Close added in v0.1.28 

func (s *ElasticsearchSink) Close()

func (*ElasticsearchSink) DeliveryRequired added in v0.5.2 

func (s *ElasticsearchSink) DeliveryRequired() bool

func (*ElasticsearchSink) Id added in v0.1.31 

func (s *ElasticsearchSink) Id() *uuid.UUID

func (*ElasticsearchSink) Initialize added in v0.1.28 

func (s *ElasticsearchSink) Initialize(conf config.Sink) error

func (*ElasticsearchSink) Name added in v0.1.31 

func (s *ElasticsearchSink) Name() string

func (*ElasticsearchSink) Type added in v0.5.3 

func (s *ElasticsearchSink) Type() string

type FileSink added in v0.1.30 

type FileSink struct {
	// contains filtered or unexported fields
}

func (*FileSink) BatchPublishInvalid added in v0.1.30 

func (s *FileSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*FileSink) BatchPublishValid added in v0.1.30 

func (s *FileSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*FileSink) Close added in v0.1.30 

func (s *FileSink) Close()

func (*FileSink) DeliveryRequired added in v0.5.2 

func (s *FileSink) DeliveryRequired() bool

func (*FileSink) Id added in v0.1.31 

func (s *FileSink) Id() *uuid.UUID

func (*FileSink) Initialize added in v0.1.30 

func (s *FileSink) Initialize(conf config.Sink) error

func (*FileSink) Name added in v0.1.31 

func (s *FileSink) Name() string

func (*FileSink) Type added in v0.5.3 

func (s *FileSink) Type() string

type HttpSink added in v0.1.27 

type HttpSink struct {
	// contains filtered or unexported fields
}

func (*HttpSink) BatchPublishInvalid added in v0.1.27 

func (s *HttpSink) BatchPublishInvalid(ctx context.Context, invalidEnvelopes []envelope.Envelope) error

func (*HttpSink) BatchPublishValid added in v0.1.27 

func (s *HttpSink) BatchPublishValid(ctx context.Context, validEnvelopes []envelope.Envelope) error

func (*HttpSink) Close added in v0.1.27 

func (s *HttpSink) Close()

func (*HttpSink) DeliveryRequired added in v0.5.2 

func (s *HttpSink) DeliveryRequired() bool

func (*HttpSink) Id added in v0.1.31 

func (s *HttpSink) Id() *uuid.UUID

func (*HttpSink) Initialize added in v0.1.27 

func (s *HttpSink) Initialize(conf config.Sink) error

func (*HttpSink) Name added in v0.1.31 

func (s *HttpSink) Name() string

func (*HttpSink) Type added in v0.5.3 

func (s *HttpSink) Type() string

type IndicativeSink added in v0.11.0 

type IndicativeSink struct {
	// contains filtered or unexported fields
}

func (*IndicativeSink) BatchPublishInvalid added in v0.11.0 

func (s *IndicativeSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*IndicativeSink) BatchPublishValid added in v0.11.0 

func (s *IndicativeSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*IndicativeSink) Close added in v0.11.0 

func (s *IndicativeSink) Close()

func (*IndicativeSink) DeliveryRequired added in v0.11.0 

func (s *IndicativeSink) DeliveryRequired() bool

func (*IndicativeSink) Id added in v0.11.0 

func (s *IndicativeSink) Id() *uuid.UUID

func (*IndicativeSink) Initialize added in v0.11.0 

func (s *IndicativeSink) Initialize(conf config.Sink) error

func (*IndicativeSink) Name added in v0.11.0 

func (s *IndicativeSink) Name() string

func (*IndicativeSink) Type added in v0.11.0 

func (s *IndicativeSink) Type() string

type KafkaSink 

type KafkaSink struct {
	// contains filtered or unexported fields
}

func (*KafkaSink) BatchPublishInvalid added in v0.1.26 

func (s *KafkaSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KafkaSink) BatchPublishValid added in v0.1.26 

func (s *KafkaSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KafkaSink) Close 

func (s *KafkaSink) Close()

func (*KafkaSink) DeliveryRequired added in v0.5.2 

func (s *KafkaSink) DeliveryRequired() bool

func (*KafkaSink) Id added in v0.1.31 

func (s *KafkaSink) Id() *uuid.UUID

func (*KafkaSink) Initialize 

func (s *KafkaSink) Initialize(conf config.Sink) error

func (*KafkaSink) Name added in v0.1.31 

func (s *KafkaSink) Name() string

func (*KafkaSink) Type added in v0.5.3 

func (s *KafkaSink) Type() string

type KinesisFirehoseSink 

type KinesisFirehoseSink struct {
	// contains filtered or unexported fields
}

func (*KinesisFirehoseSink) BatchPublishInvalid added in v0.1.26 

func (s *KinesisFirehoseSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KinesisFirehoseSink) BatchPublishValid added in v0.1.26 

func (s *KinesisFirehoseSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KinesisFirehoseSink) Close 

func (s *KinesisFirehoseSink) Close()

func (*KinesisFirehoseSink) DeliveryRequired added in v0.5.2 

func (s *KinesisFirehoseSink) DeliveryRequired() bool

func (*KinesisFirehoseSink) Id added in v0.1.31 

func (s *KinesisFirehoseSink) Id() *uuid.UUID

func (*KinesisFirehoseSink) Initialize 

func (s *KinesisFirehoseSink) Initialize(conf config.Sink) error

func (*KinesisFirehoseSink) Name added in v0.1.31 

func (s *KinesisFirehoseSink) Name() string

func (*KinesisFirehoseSink) Type added in v0.5.3 

func (s *KinesisFirehoseSink) Type() string

type KinesisSink 

type KinesisSink struct {
	// contains filtered or unexported fields
}

func (*KinesisSink) BatchPublishInvalid added in v0.1.26 

func (s *KinesisSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KinesisSink) BatchPublishValid added in v0.1.26 

func (s *KinesisSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*KinesisSink) Close 

func (s *KinesisSink) Close()

func (*KinesisSink) DeliveryRequired added in v0.5.2 

func (s *KinesisSink) DeliveryRequired() bool

func (*KinesisSink) Id added in v0.1.31 

func (s *KinesisSink) Id() *uuid.UUID

func (*KinesisSink) Initialize 

func (s *KinesisSink) Initialize(conf config.Sink) error

func (*KinesisSink) Name added in v0.1.31 

func (s *KinesisSink) Name() string

func (*KinesisSink) Type added in v0.5.3 

func (s *KinesisSink) Type() string

type MaterializeSink added in v0.5.0 

type MaterializeSink struct {
	// contains filtered or unexported fields
}

func (*MaterializeSink) BatchPublishInvalid added in v0.5.0 

func (s *MaterializeSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MaterializeSink) BatchPublishValid added in v0.5.0 

func (s *MaterializeSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MaterializeSink) Close added in v0.5.0 

func (s *MaterializeSink) Close()

func (*MaterializeSink) DeliveryRequired added in v0.5.2 

func (s *MaterializeSink) DeliveryRequired() bool

func (*MaterializeSink) Id added in v0.5.0 

func (s *MaterializeSink) Id() *uuid.UUID

func (*MaterializeSink) Initialize added in v0.5.0 

func (s *MaterializeSink) Initialize(conf config.Sink) error

func (*MaterializeSink) Name added in v0.5.0 

func (s *MaterializeSink) Name() string

func (*MaterializeSink) Type added in v0.5.3 

func (s *MaterializeSink) Type() string

type MongodbSink added in v0.1.35 

type MongodbSink struct {
	// contains filtered or unexported fields
}

func (*MongodbSink) BatchPublishInvalid added in v0.1.35 

func (s *MongodbSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MongodbSink) BatchPublishValid added in v0.1.35 

func (s *MongodbSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MongodbSink) Close added in v0.1.35 

func (s *MongodbSink) Close()

func (*MongodbSink) DeliveryRequired added in v0.5.2 

func (s *MongodbSink) DeliveryRequired() bool

func (*MongodbSink) Id added in v0.1.35 

func (s *MongodbSink) Id() *uuid.UUID

func (*MongodbSink) Initialize added in v0.1.35 

func (s *MongodbSink) Initialize(conf config.Sink) error

func (*MongodbSink) Name added in v0.1.35 

func (s *MongodbSink) Name() string

func (*MongodbSink) Type added in v0.5.3 

func (s *MongodbSink) Type() string

type MysqlSink added in v0.5.0 

type MysqlSink struct {
	// contains filtered or unexported fields
}

func (*MysqlSink) BatchPublishInvalid added in v0.5.0 

func (s *MysqlSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MysqlSink) BatchPublishValid added in v0.5.0 

func (s *MysqlSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*MysqlSink) Close added in v0.5.0 

func (s *MysqlSink) Close()

func (*MysqlSink) DeliveryRequired added in v0.5.2 

func (s *MysqlSink) DeliveryRequired() bool

func (*MysqlSink) Id added in v0.5.0 

func (s *MysqlSink) Id() *uuid.UUID

func (*MysqlSink) Initialize added in v0.5.0 

func (s *MysqlSink) Initialize(conf config.Sink) error

func (*MysqlSink) Name added in v0.5.0 

func (s *MysqlSink) Name() string

func (*MysqlSink) Type added in v0.5.3 

func (s *MysqlSink) Type() string

type NatsJetstreamSink added in v0.10.2 

type NatsJetstreamSink struct {
	// contains filtered or unexported fields
}

func (*NatsJetstreamSink) BatchPublishInvalid added in v0.10.2 

func (s *NatsJetstreamSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*NatsJetstreamSink) BatchPublishValid added in v0.10.2 

func (s *NatsJetstreamSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*NatsJetstreamSink) Close added in v0.10.2 

func (s *NatsJetstreamSink) Close()

func (*NatsJetstreamSink) DeliveryRequired added in v0.10.2 

func (s *NatsJetstreamSink) DeliveryRequired() bool

func (*NatsJetstreamSink) Id added in v0.10.2 

func (s *NatsJetstreamSink) Id() *uuid.UUID

func (*NatsJetstreamSink) Initialize added in v0.10.2 

func (s *NatsJetstreamSink) Initialize(conf config.Sink) error

func (*NatsJetstreamSink) Name added in v0.10.2 

func (s *NatsJetstreamSink) Name() string

func (*NatsJetstreamSink) Type added in v0.10.2 

func (s *NatsJetstreamSink) Type() string

type NatsSink added in v0.10.2 

type NatsSink struct {
	// contains filtered or unexported fields
}

func (*NatsSink) BatchPublishInvalid added in v0.10.2 

func (s *NatsSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*NatsSink) BatchPublishValid added in v0.10.2 

func (s *NatsSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*NatsSink) Close added in v0.10.2 

func (s *NatsSink) Close()

func (*NatsSink) DeliveryRequired added in v0.10.2 

func (s *NatsSink) DeliveryRequired() bool

func (*NatsSink) Id added in v0.10.2 

func (s *NatsSink) Id() *uuid.UUID

func (*NatsSink) Initialize added in v0.10.2 

func (s *NatsSink) Initialize(conf config.Sink) error

func (*NatsSink) Name added in v0.10.2 

func (s *NatsSink) Name() string

func (*NatsSink) Type added in v0.10.2 

func (s *NatsSink) Type() string

type PostgresSink added in v0.1.30 

type PostgresSink struct {
	// contains filtered or unexported fields
}

func (*PostgresSink) BatchPublishInvalid added in v0.1.30 

func (s *PostgresSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PostgresSink) BatchPublishValid added in v0.1.30 

func (s *PostgresSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PostgresSink) Close added in v0.1.30 

func (s *PostgresSink) Close()

func (*PostgresSink) DeliveryRequired added in v0.5.2 

func (s *PostgresSink) DeliveryRequired() bool

func (*PostgresSink) Id added in v0.1.31 

func (s *PostgresSink) Id() *uuid.UUID

func (*PostgresSink) Initialize added in v0.1.30 

func (s *PostgresSink) Initialize(conf config.Sink) error

func (*PostgresSink) Name added in v0.1.31 

func (s *PostgresSink) Name() string

func (*PostgresSink) Type added in v0.5.3 

func (s *PostgresSink) Type() string

type PubnubSink added in v0.1.30 

type PubnubSink struct {
	// contains filtered or unexported fields
}

func (*PubnubSink) BatchPublishInvalid added in v0.1.30 

func (s *PubnubSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PubnubSink) BatchPublishValid added in v0.1.30 

func (s *PubnubSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PubnubSink) Close added in v0.1.30 

func (s *PubnubSink) Close()

func (*PubnubSink) DeliveryRequired added in v0.5.2 

func (s *PubnubSink) DeliveryRequired() bool

func (*PubnubSink) Id added in v0.1.31 

func (s *PubnubSink) Id() *uuid.UUID

func (*PubnubSink) Initialize added in v0.1.30 

func (s *PubnubSink) Initialize(conf config.Sink) error

func (*PubnubSink) Name added in v0.1.31 

func (s *PubnubSink) Name() string

func (*PubnubSink) Type added in v0.5.3 

func (s *PubnubSink) Type() string

type PubsubSink 

type PubsubSink struct {
	// contains filtered or unexported fields
}

func (*PubsubSink) BatchPublishInvalid added in v0.1.26 

func (s *PubsubSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PubsubSink) BatchPublishValid added in v0.1.26 

func (s *PubsubSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*PubsubSink) Close 

func (s *PubsubSink) Close()

func (*PubsubSink) DeliveryRequired added in v0.5.2 

func (s *PubsubSink) DeliveryRequired() bool

func (*PubsubSink) Id added in v0.1.31 

func (s *PubsubSink) Id() *uuid.UUID

func (*PubsubSink) Initialize 

func (s *PubsubSink) Initialize(conf config.Sink) error

func (*PubsubSink) Name added in v0.1.31 

func (s *PubsubSink) Name() string

func (*PubsubSink) Type added in v0.5.3 

func (s *PubsubSink) Type() string

type Sink 

type Sink interface {
	Id() *uuid.UUID
	Name() string
	Type() string
	DeliveryRequired() bool
	Initialize(conf config.Sink) error
	BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error
	BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error
	Close()
}

func BuildAndInitializeSinks added in v0.1.31 

func BuildAndInitializeSinks(conf []config.Sink) ([]Sink, error)

func BuildSink 

func BuildSink(conf config.Sink) (sink Sink, err error)

type StdoutSink added in v0.1.16 

type StdoutSink struct {
	// contains filtered or unexported fields
}

func (*StdoutSink) BatchPublishInvalid added in v0.1.26 

func (s *StdoutSink) BatchPublishInvalid(ctx context.Context, invalidEnvelopes []envelope.Envelope) error

func (*StdoutSink) BatchPublishValid added in v0.1.26 

func (s *StdoutSink) BatchPublishValid(ctx context.Context, validEnvelopes []envelope.Envelope) error

func (*StdoutSink) Close added in v0.1.16 

func (s *StdoutSink) Close()

func (*StdoutSink) DeliveryRequired added in v0.5.2 

func (s *StdoutSink) DeliveryRequired() bool

func (*StdoutSink) Id added in v0.1.31 

func (s *StdoutSink) Id() *uuid.UUID

func (*StdoutSink) Initialize added in v0.1.16 

func (s *StdoutSink) Initialize(conf config.Sink) error

func (*StdoutSink) Name added in v0.1.31 

func (s *StdoutSink) Name() string

func (*StdoutSink) Type added in v0.5.3 

func (s *StdoutSink) Type() string

type TimescaleSink added in v0.10.2 

type TimescaleSink struct {
	// contains filtered or unexported fields
}

func (*TimescaleSink) BatchPublishInvalid added in v0.10.2 

func (s *TimescaleSink) BatchPublishInvalid(ctx context.Context, envelopes []envelope.Envelope) error

func (*TimescaleSink) BatchPublishValid added in v0.10.2 

func (s *TimescaleSink) BatchPublishValid(ctx context.Context, envelopes []envelope.Envelope) error

func (*TimescaleSink) Close added in v0.10.2 

func (s *TimescaleSink) Close()

func (*TimescaleSink) DeliveryRequired added in v0.10.2 

func (s *TimescaleSink) DeliveryRequired() bool

func (*TimescaleSink) Id added in v0.10.2 

func (s *TimescaleSink) Id() *uuid.UUID

func (*TimescaleSink) Initialize added in v0.10.2 

func (s *TimescaleSink) Initialize(conf config.Sink) error

func (*TimescaleSink) Name added in v0.10.2 

func (s *TimescaleSink) Name() string

func (*TimescaleSink) Type added in v0.10.2 

func (s *TimescaleSink) Type() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.