handlers

type Config ¶ added in v0.1.0

type Config struct {
	ExporterConfig *config.ExporterConfig `yaml:"exporter_config"`
}

Config .

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

type CustomHandler ¶ added in v0.1.0

type CustomHandler interface {
	HandlerMeta
	Listener
}

CustomHandler カスタムハンドラーが実装すべきインターフェース

type Handler ¶

type Handler interface {
	Handle(context.Context, *handler.HandleRequest, ResponseSender) error
}

Handler CoreからのHandleリクエストを処理するためのインターフェース

type HandlerContext ¶ added in v0.1.0

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

func NewHandlerContext(ctx context.Context, scalingJobID string, sender ResponseSender) *HandlerContext

func (c *HandlerContext) Deadline() (deadline time.Time, ok bool)

func (c *HandlerContext) Done() <-chan struct{}

func (c *HandlerContext) Err() error

func (c *HandlerContext) Report(status handler.HandleResponse_Status, formatAndArgs ...interface{}) error

func (c *HandlerContext) Value(key interface{}) interface{}

type HandlerLogger ¶

type HandlerLogger struct {
	Logger *slog.Logger
}

func (l *HandlerLogger) GetLogger() *slog.Logger

func (l *HandlerLogger) SetLogger(logger *slog.Logger)

type HandlerMeta ¶

type HandlerMeta interface {
	// Name プレフィックスなしの短い名前を返す
	Name() string
	// Version バージョン情報を返す
	Version() string

	Logger
}

HandlerMeta ハンドラーのメタ情報

ビルトイン/カスタム問わず全てのハンドラーが実装すべきインターフェース

type Listener ¶

type Listener interface {
	ListenAddress() string
	ConfigPath() string
}

Listener gRPCサーバとしてリッスンするためのインターフェース

type Logger ¶

type Logger interface {
	GetLogger() *slog.Logger
	SetLogger(logger *slog.Logger)
}

Logger ログ出力のためのインターフェース

type PostHandler ¶

type PostHandler interface {
	PostHandle(context.Context, *handler.PostHandleRequest, ResponseSender) error
}

PostHandler CoreからのPostHandleリクエストを処理するためのインターフェース

type PreHandler ¶

type PreHandler interface {
	PreHandle(context.Context, *handler.HandleRequest, ResponseSender) error
}

PreHandler CoreからのPreHandleリクエストを処理するためのインターフェース

type ResponseSender ¶

type ResponseSender interface {
	Send(*handler.HandleResponse) error
}

ResponseSender gRPCのサーバストリームのレスポンスをラップするインターフェース