inputs

Documentation

Index

• func FullName(input Input) string
• func Serve(ctx context.Context, input Input) error
• type Config
  • func LoadConfigFromPath(path string) (*Config, error)
• type Input
• type ScalingRequest
  • func (r *ScalingRequest) Validate() error

Functions

func FullName

func FullName(input Input) string

func Serve

func Serve(ctx context.Context, input Input) error

Types

type Config

type Config struct {
	// ExporterConfig Exporterの設定
	ExporterConfig *config.ExporterConfig `yaml:"exporter_config"`
}

Config Inputsのエクスポーター関連動作設定

func LoadConfigFromPath

func LoadConfigFromPath(path string) (*Config, error)

LoadConfigFromPath 指定のパスからConfigをロードする

type Input

type Input interface {
	Name() string
	Version() string
	ShouldAccept(req *http.Request) (bool, error) // true,nilを返した場合のみCoreへのリクエストを行う
	Destination() string
	ListenAddress() string
	ConfigPath() string
	GetLogger() *slog.Logger
}

Input Webhookを受け取りCoreへのリクエストを行うInputsが備えるべきインターフェース

type ScalingRequest

type ScalingRequest struct {
	Source           string `name:"source" validate:"omitempty,printascii,max=1024"`
	ResourceName     string `name:"resource-name" validate:"omitempty,printascii,max=1024"`
	RequestType      string `name:"request-type" validate:"required,oneof=up down"`
	DesiredStateName string `name:"desired-state-name" validate:"omitempty,printascii,max=1024"`
}

ScalingRequest Inputsからのリクエストを表す

func (*ScalingRequest) Validate

func (r *ScalingRequest) Validate() error