msk

Documentation

Index

• Constants
• type Config
• type Source
  • func NewSource(api aws.MSKApi, log *slog.Logger, cfg *Config) (*Source, error)
  • func (s *Source) Load() ([]*software.Software, error)
  • func (s *Source) Name() string

Constants

const (
	MskCluster     software.SoftwareType = "msk cluster"
	DefaultTimeout time.Duration         = time.Second * 15

	// From version 3.7.0, AWS start using 3.7.x version with automated patch update manage by themselves.
	// See https://docs.aws.amazon.com/msk/latest/developerguide/supported-kafka-versions.html#3.7.kraft
	//
	// When a candidate with x appears, we replace them with a 0 version to be still able to process them.
	SemVerWithX = `(\d+|x)\.(\d+|x)\.(\d+|x)`
)

Types

type Config

type Config struct {
	Enabled        bool           `yaml:"enabled"`
	RequestTimeout string         `yaml:"request-timeout"`
	Filters        filters.Config `yaml:"filters"`
}

type Source

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

func NewSource

func NewSource(api aws.MSKApi, log *slog.Logger, cfg *Config) (*Source, error)

func (*Source) Load

func (s *Source) Load() ([]*software.Software, error)

func (*Source) Name

func (s *Source) Name() string