sink

Documentation

Index

• func Write(ctx context.Context, scope beam.Scope, opt options.SinkOption, ...) error
• func WriteToBigQuery(scope beam.Scope, opt options.BigQueryWriteOption, col beam.PCollection)
• func WriteToDatabase(ctx context.Context, scope beam.Scope, opt options.DatabaseWriteOption, ...) error
• func WriteToElasticsearch(ctx context.Context, scope beam.Scope, opt options.ElasticsearchWriteOption, ...) error
• func WriteToFile(scope beam.Scope, opt options.FileWriteOption, col beam.PCollection) error
• func WriteToFirestore(scope beam.Scope, opt options.FirestoreWriteOption, col beam.PCollection)
• func WriteToMongoDB(ctx context.Context, scope beam.Scope, opt options.MongoDBWriteOption, ...) error
• func WriteToRedis(ctx context.Context, scope beam.Scope, opt options.RedisWriteOption, ...) error

Functions

func Write

func Write(
	ctx context.Context,
	scope beam.Scope,
	opt options.SinkOption,
	secretReader *gcp.SecretReader,
	col beam.PCollection,
) error

func WriteToBigQuery

func WriteToBigQuery(scope beam.Scope, opt options.BigQueryWriteOption, col beam.PCollection)

func WriteToDatabase

func WriteToDatabase(
	ctx context.Context,
	scope beam.Scope,
	opt options.DatabaseWriteOption,
	secretReader *gcp.SecretReader,
	col beam.PCollection,
) error

func WriteToElasticsearch

func WriteToElasticsearch(
	ctx context.Context,
	scope beam.Scope,
	opt options.ElasticsearchWriteOption,
	secretReader *gcp.SecretReader,
	col beam.PCollection,
) error

func WriteToFile

func WriteToFile(scope beam.Scope, opt options.FileWriteOption, col beam.PCollection) error

func WriteToFirestore

func WriteToFirestore(scope beam.Scope, opt options.FirestoreWriteOption, col beam.PCollection)

func WriteToMongoDB

func WriteToMongoDB(
	ctx context.Context,
	scope beam.Scope,
	opt options.MongoDBWriteOption,
	secretReader *gcp.SecretReader,
	col beam.PCollection,
) error

func WriteToRedis

func WriteToRedis(
	ctx context.Context,
	scope beam.Scope,
	opt options.RedisWriteOption,
	secretReader *gcp.SecretReader,
	col beam.PCollection,
) error