redisio

package

v0.0.0-...-223fbb0 Latest Latest Go to latest Published: Mar 7, 2023 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

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 struct {
	URL         string
	KeyPatterns []string
	BatchSize   int
}

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

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