Help us shape the future of Go! Take the 2026 Go Developer Survey

executor

package
v0.510.3 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ARNSecretMySQLSetup 

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

ARNSecretMySQLSetup is an executor that sets up a mysql database on an RDS instance. It uses the secret ARN to get the admin username and password for the database.

func NewARNSecretMySQLSetup 

func NewARNSecretMySQLSetup(secrets *secretsmanager.Client, username string) *ARNSecretMySQLSetup

func (*ARNSecretMySQLSetup) Execute 

func (e *ARNSecretMySQLSetup) Execute(ctx context.Context) ([]state.State, error)

func (*ARNSecretMySQLSetup) Prepare 

func (e *ARNSecretMySQLSetup) Prepare(_ context.Context, input state.State) error

type ARNSecretPostgresSetup 

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

ARNSecretPostgresSetup is an executor that sets up a postgres database on an RDS instance. It uses the secret ARN to get the admin username and password for the database.

func NewPostgresSetup 

func NewPostgresSetup(secrets *secretsmanager.Client, username string) *ARNSecretPostgresSetup

func (*ARNSecretPostgresSetup) Execute 

func (e *ARNSecretPostgresSetup) Execute(ctx context.Context) ([]state.State, error)

func (*ARNSecretPostgresSetup) Prepare 

func (e *ARNSecretPostgresSetup) Prepare(_ context.Context, input state.State) error

type KafkaTopicSetup added in v0.461.0 

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

KafkaTopicSetup is an executor that sets up a Kafka topic in an existing cluster.

func NewKafkaTopicSetup added in v0.461.0 

func NewKafkaTopicSetup() *KafkaTopicSetup

func (*KafkaTopicSetup) Execute added in v0.461.0 

func (e *KafkaTopicSetup) Execute(ctx context.Context) ([]state.State, error)

func (*KafkaTopicSetup) Prepare added in v0.461.0 

func (e *KafkaTopicSetup) Prepare(ctx context.Context, input state.State) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.