genbenthosconfigs_activity

type Activity struct {
	// contains filtered or unexported fields
}

type BenthosConfigResponse struct {
	Name           string
	DependsOn      []*tabledependency.DependsOn
	RunType        tabledependency.RunType
	Config         *neosync_benthos.BenthosConfig
	TableSchema    string
	TableName      string
	Columns        []string
	RedisDependsOn map[string][]string

	Processors  []*neosync_benthos.ProcessorConfig
	BenthosDsns []*shared.BenthosDsn
	RedisConfig []*BenthosRedisConfig
	// contains filtered or unexported fields
}

type BenthosRedisConfig struct {
	Key    string
	Table  string // schema.table
	Column string
}

type GenerateBenthosConfigsRequest struct {
	JobId      string
	WorkflowId string
}

type GenerateBenthosConfigsResponse struct {
	BenthosConfigs []*BenthosConfigResponse
}

type SubsetColumnConstraint struct {
	Columns     []string
	NotNullable []bool
	ForeignKey  *SubsetReferenceKey
}

type SubsetReferenceKey struct {
	Table         string
	Columns       []string
	OriginalTable *string
}