aiven

Documentation

Index

• Constants
• func Create(source Source, ast *resource.Ast, config Config) error
• func CreateStream(source resource.Source, kafka *nais_io_v1.Kafka) *kafka_nais_io_v1.Stream
• func Influx(ast *resource.Ast, influx *nais_io_v1.Influx, ...) (bool, error)
• func Kafka(source resource.Source, ast *resource.Ast, config Config, ...) []corev1.KeyToPath
• func OpenSearch(ast *resource.Ast, openSearch *nais_io_v1.OpenSearch, ...) (bool, error)
• func Redis(ast *resource.Ast, config Config, source Source, ...) (bool, error)
• type Config
• type Source

Constants

const DefaultPlan = "startup-4"

Functions

func Create

func Create(source Source, ast *resource.Ast, config Config) error

func CreateStream

func CreateStream(source resource.Source, kafka *nais_io_v1.Kafka) *kafka_nais_io_v1.Stream

func Influx

func Influx(ast *resource.Ast, influx *nais_io_v1.Influx, aivenApp *aiven_nais_io_v1.AivenApplication, credentialsEnabled bool) (bool, error)

func Kafka

func Kafka(source resource.Source, ast *resource.Ast, config Config, naisKafka *nais_io_v1.Kafka, aivenApp *aiven_nais_io_v1.AivenApplication) []corev1.KeyToPath

func OpenSearch

func OpenSearch(ast *resource.Ast, openSearch *nais_io_v1.OpenSearch, aivenApp *aiven_nais_io_v1.AivenApplication) (bool, error)

func Redis

func Redis(ast *resource.Ast, config Config, source Source, aivenApp *aiven_nais_io_v1.AivenApplication) (bool, error)

Types

type Config

type Config interface {
	IsKafkaratorEnabled() bool
	IsInfluxCredentialsEnabled() bool
	GetAivenProject() string
	GetAivenGeneration() int
}

type Source

type Source interface {
	resource.Source
	GetInflux() *nais_io_v1.Influx
	GetKafka() *nais_io_v1.Kafka
	GetOpenSearch() *nais_io_v1.OpenSearch
	GetRedis() []nais_io_v1.Redis
}