aiven_services

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Mar 20, 2025 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var OpenSearchAccesses = []string{"read", "write", "readwrite", "admin"}
View Source
var Services = map[string]Service{}

Functions

This section is empty.

Types

type Kafka

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

func (*Kafka) Apply

func (k *Kafka) Apply(aivenApplicationSpec *aiven_nais_io_v1.AivenApplicationSpec, _ string)

func (*Kafka) Generate

func (k *Kafka) Generate(generator SecretGenerator) error

func (*Kafka) Is

func (k *Kafka) Is(other Service) bool

func (*Kafka) Name

func (k *Kafka) Name() string

func (*Kafka) Setup

func (k *Kafka) Setup(setup *ServiceSetup)

type KafkaPool

type KafkaPool string

func KafkaPoolFromString

func KafkaPoolFromString(pool string) (KafkaPool, error)

func (KafkaPool) String

func (p KafkaPool) String() string

type OpenSearch

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

func (*OpenSearch) Apply

func (o *OpenSearch) Apply(aivenApplicationSpec *aiven_nais_io_v1.AivenApplicationSpec, namespace string)

func (*OpenSearch) Generate

func (o *OpenSearch) Generate(generator SecretGenerator) error

func (*OpenSearch) Is

func (o *OpenSearch) Is(other Service) bool

func (*OpenSearch) Name

func (o *OpenSearch) Name() string

func (*OpenSearch) Setup

func (o *OpenSearch) Setup(setup *ServiceSetup)

type OpenSearchAccess

type OpenSearchAccess int64
const (
	Read OpenSearchAccess = iota
	Write
	ReadWrite
	Admin
)

func OpenSearchAccessFromString

func OpenSearchAccessFromString(access string) (OpenSearchAccess, error)

func (OpenSearchAccess) String

func (p OpenSearchAccess) String() string

type SecretGenerator

type SecretGenerator interface {
	CreateKafkaConfigs() error
	CreateOpenSearchConfigs() error
}

type Service

type Service interface {
	Name() string
	Setup(setup *ServiceSetup)
	Apply(aivenApplicationSpec *aiven_nais_io_v1.AivenApplicationSpec, namespace string)
	Generate(generator SecretGenerator) error
	Is(other Service) bool
}

func FromString

func FromString(service string) (Service, error)

type ServiceSetup

type ServiceSetup struct {
	Instance string
	Pool     KafkaPool
	Access   OpenSearchAccess
}

Jump to

Keyboard shortcuts

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