redisio

Documentation

Index

• func Read(scope beam.Scope, cfg ReadConfig, elemType reflect.Type) beam.PCollection
• func ReadKV(scope beam.Scope, cfg ReadConfig) beam.PCollection
• func Write(scope beam.Scope, cfg WriteConfig, col beam.PCollection)
• func WriteKV(scope beam.Scope, cfg WriteKVConfig, col beam.PCollection)
• type ReadConfig
• type WriteConfig
• type WriteKVConfig

Functions

func Read

func Read(
	scope beam.Scope,
	cfg ReadConfig,
	elemType reflect.Type,
) beam.PCollection

func ReadKV

func ReadKV(
	scope beam.Scope,
	cfg ReadConfig,
) beam.PCollection

func Write

func Write(
	scope beam.Scope,
	cfg WriteConfig,
	col beam.PCollection,
)

func WriteKV

func WriteKV(
	scope beam.Scope,
	cfg WriteKVConfig,
	col beam.PCollection,
)

Types

type ReadConfig

type ReadConfig struct {
	URL         string
	KeyPatterns []string
	BatchSize   int
}

type WriteConfig

type WriteConfig struct {
	URL        string
	Expiration time.Duration
	BatchSize  int
	KeyField   string
}

type WriteKVConfig

type WriteKVConfig struct {
	URL        string
	Expiration time.Duration
	BatchSize  int
}