output

Documentation

Index

• Variables
• func UploadFlows(flows []schema.FlowModel, config KinesisStreamConfig) error
• type KinesisStreamConfig

Variables

var (
	MaxUploadSize       = 5 * 1024 * 1024
	MaxRecordsPerUpload = 500
)

Functions

func UploadFlows

func UploadFlows(flows []schema.FlowModel, config KinesisStreamConfig) error

Types

type KinesisStreamConfig

type KinesisStreamConfig struct {
	StreamName    string
	KinesisClient *kinesis.Client
}