source

Documentation

Index

• func Read(ctx context.Context, scope beam.Scope, opt options.SourceOption, ...) (beam.PCollection, error)
• func ReadFromBigQuery(scope beam.Scope, opt options.BigQueryReadOption, elemType reflect.Type) beam.PCollection
• func ReadFromDatabase(ctx context.Context, scope beam.Scope, opt options.DatabaseReadOption, ...) (beam.PCollection, error)
• func ReadFromElasticsearch(ctx context.Context, scope beam.Scope, opt options.ElasticsearchReadOption, ...) (beam.PCollection, error)
• func ReadFromFile(scope beam.Scope, opt options.FileReadOption, elemType reflect.Type) (beam.PCollection, error)
• func ReadFromFirestore(scope beam.Scope, opt options.FirestoreReadOption, elemType reflect.Type) beam.PCollection
• func ReadFromMongoDB(ctx context.Context, scope beam.Scope, opt options.MongoDBReadOption, ...) (beam.PCollection, error)
• func ReadFromRedis(ctx context.Context, scope beam.Scope, opt options.RedisReadOption, ...) (beam.PCollection, error)

Functions

func Read

func Read(
	ctx context.Context,
	scope beam.Scope,
	opt options.SourceOption,
	secretReader *gcp.SecretReader,
	elemType reflect.Type,
) (beam.PCollection, error)

func ReadFromBigQuery

func ReadFromBigQuery(
	scope beam.Scope,
	opt options.BigQueryReadOption,
	elemType reflect.Type,
) beam.PCollection

func ReadFromDatabase

func ReadFromDatabase(
	ctx context.Context,
	scope beam.Scope,
	opt options.DatabaseReadOption,
	secretReader *gcp.SecretReader,
	elemType reflect.Type,
) (beam.PCollection, error)

func ReadFromElasticsearch

func ReadFromElasticsearch(
	ctx context.Context,
	scope beam.Scope,
	opt options.ElasticsearchReadOption,
	secretReader *gcp.SecretReader,
	elemType reflect.Type,
) (beam.PCollection, error)

func ReadFromFile

func ReadFromFile(
	scope beam.Scope,
	opt options.FileReadOption,
	elemType reflect.Type,
) (beam.PCollection, error)

func ReadFromFirestore

func ReadFromFirestore(
	scope beam.Scope,
	opt options.FirestoreReadOption,
	elemType reflect.Type,
) beam.PCollection

func ReadFromMongoDB

func ReadFromMongoDB(
	ctx context.Context,
	scope beam.Scope,
	opt options.MongoDBReadOption,
	secretReader *gcp.SecretReader,
	elemType reflect.Type,
) (beam.PCollection, error)

func ReadFromRedis

func ReadFromRedis(
	ctx context.Context,
	scope beam.Scope,
	opt options.RedisReadOption,
	secretReader *gcp.SecretReader,
	elemType reflect.Type,
) (beam.PCollection, error)