server

type AuthTokenRequest ¶

type AuthTokenRequest struct {
	Broker      string             `json:"broker"`
	Credentials broker.Credentials `json:"credentials"`
	Sandbox     bool               `json:"sandbox"`
}

AuthTokenRequest represents an auth token request

type BrokerWithExtras ¶

type BrokerWithExtras interface {
	broker.Broker
	// contains filtered or unexported methods
}

BrokerWithExtras is a test-oriented interface for server handlers.

type KISProxyCacheOptions ¶ added in v0.15.0

type KISProxyCacheOptions struct {
	Policy         KISProxyCachePolicy
	MaxEntries     int
	StaleRetention time.Duration
}

KISProxyCacheOptions configures the in-process KIS proxy cache.

type KISProxyCachePolicy ¶ added in v0.15.0

type KISProxyCachePolicy func(KISProxyCacheRequest) (time.Duration, bool)

KISProxyCachePolicy decides whether a KIS proxy request should be cached and returns its soft TTL when cacheable.

type KISProxyCacheRequest ¶ added in v0.15.0

type KISProxyCacheRequest struct {
	Method    string
	Path      string
	TRID      string
	AccountID string
	Params    map[string]string
}

KISProxyCacheRequest describes a normalized KIS proxy request for cache policy decisions. Params is a copy and can be inspected or modified by policy code.

type KISProxyRateLimitOptions ¶ added in v0.16.0

type KISProxyRateLimitOptions struct {
	Disabled          bool
	RequestsPerSecond float64
	Burst             int
	Overrides         []KISProxyRateLimitOverrideOptions
}

KISProxyRateLimitOptions configures outbound KIS upstream throttling.

type KISProxyRateLimitOverrideOptions ¶ added in v0.16.1

type KISProxyRateLimitOverrideOptions struct {
	Path              string
	TRID              string
	RequestsPerSecond float64
	Burst             int
}

type Response ¶

type Response struct {
	OK     bool        `json:"ok"`
	Data   interface{} `json:"data,omitempty"`
	Error  string      `json:"error,omitempty"`
	Broker string      `json:"broker,omitempty"`
}

Response represents a standard API response

type Server ¶

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

Server represents the HTTP server

func New(cfg *config.Config) *Server

func NewWithBrokers(host string, port int, accounts []config.AccountConfig, brokers map[string]broker.Broker) *Server

func NewWithBrokersOptions(
	host string,
	port int,
	accounts []config.AccountConfig,
	brokers map[string]broker.Broker,
	opts ServerOptions,
) *Server

func NewWithLogger(cfg *config.Config, logger *slog.Logger) *Server

func (s *Server) App() *fuego.Server

func (s *Server) Run() error

type ServerOptions ¶ added in v0.15.0

type ServerOptions struct {
	Logger            *slog.Logger
	KISProxyCache     KISProxyCacheOptions
	KISProxyRateLimit KISProxyRateLimitOptions
}