genbenthosconfigs_activity

Documentation

Index

• type Activity
  • func New(jobclient mgmtv1alpha1connect.JobServiceClient, ...) *Activity
  • func (a *Activity) GenerateBenthosConfigs(ctx context.Context, req *GenerateBenthosConfigsRequest) (*GenerateBenthosConfigsResponse, error)
• type BenthosConfigResponse
• type BenthosRedisConfig
• type GenerateBenthosConfigsRequest
• type GenerateBenthosConfigsResponse

Types

type Activity

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

func New

func New(
	jobclient mgmtv1alpha1connect.JobServiceClient,
	connclient mgmtv1alpha1connect.ConnectionServiceClient,
	transformerclient mgmtv1alpha1connect.TransformersServiceClient,
	sqlmanager sql_manager.SqlManagerClient,
	redisConfig *shared.RedisConfig,
	metricsEnabled bool,
) *Activity

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

	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
	WorkflowId string
}

type GenerateBenthosConfigsResponse

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