genbenthosconfigs_activity

package
v0.4.77 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2024 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activity

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

func (*Activity) GenerateBenthosConfigs

func (a *Activity) GenerateBenthosConfigs(
	ctx context.Context,
	req *GenerateBenthosConfigsRequest,
) (*GenerateBenthosConfigsResponse, error)

type BenthosConfigResponse

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
	ColumnDefaultProperties map[string]*neosync_benthos.ColumnDefaultProperties
	SourceConnectionType    string // used for logging

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

type BenthosRedisConfig

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

type GenerateBenthosConfigsRequest

type GenerateBenthosConfigsRequest struct {
	JobId string
}

type GenerateBenthosConfigsResponse

type GenerateBenthosConfigsResponse struct {
	BenthosConfigs []*BenthosConfigResponse
	AccountId      string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL