gatewayx

type AuthnMode string

type BindFunc[Req any] func(DispatchRequest, RouteMatch) (Req, error)

type DispatchRequest struct {
	Method  string
	Path    string
	Headers map[string]string
	Body    any
}

type DispatchResponse struct {
	Status  int
	Headers map[string]string
	Body    any
}

type Dispatcher struct {
	Registry RouteRegistry
	Hosts    StaticHosts
	Invoker  UpstreamInvoker
}

type EtcdRegistry struct {
	Store  KVStore
	Prefix string
}

type GatewayPolicy struct {
	Exposure             accessv1.Exposure
	AuthnMode            AuthnMode
	ForwardAuthorization bool
	Timeout              time.Duration
}

type GatewayRoute struct {
	ID       string
	Method   string
	Path     string
	Upstream UpstreamRef
	Gateway  GatewayPolicy
}

type HandlerFunc = httpx.HandlerFunc

type InternalClaims struct {
	Issuer          string          `json:"iss"`
	Audience        string          `json:"aud"`
	Subject         string          `json:"sub"`
	Actor           authn.Principal `json:"actor"`
	RequestID       string          `json:"request_id,omitempty"`
	AuthzDecisionID string          `json:"authz_decision_id,omitempty"`
	IssuedAt        int64           `json:"iat"`
	ExpiresAt       int64           `json:"exp"`
	JWTID           string          `json:"jti"`
}

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

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

type KVStore interface {
	Put(ctx context.Context, key string, value []byte) error
	DeletePrefix(ctx context.Context, prefix string) error
	ListPrefix(ctx context.Context, prefix string) (map[string][]byte, error)
}

type Manifest struct {
	Service   string
	Namespace string
	Routes    []GatewayRoute
}

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

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

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

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

type OperationInvoker interface {
	InvokeOperation(ctx context.Context, match RouteMatch, req DispatchRequest) (DispatchResponse, error)
}

type ProxyConfig struct {
	Target      string
	StripPrefix string
	AddPrefix   string
	Audience    string
	JWT         *InternalJWT
	Timeout     time.Duration
}

type Route struct {
	Method  string
	Path    string
	Handler HandlerFunc
	Filters []httpx.FilterFunc
	Name    string
}

type RouteMatch struct {
	Route  GatewayRoute
	Params map[string]string
}

type RouteRegistry interface {
	RegisterManifest(manifest Manifest) error
	ListRoutes() []GatewayRoute
}

type Service struct {
	Name    string
	Prefix  string
	Filters []httpx.FilterFunc
	Routes  []Route
}

type Session struct {
	ID           string
	Principal    authn.Principal
	AccessToken  string
	RefreshToken string
	IDToken      string
	CSRFToken    string
	CreatedAt    time.Time
	LastSeenAt   time.Time
	ExpiresAt    time.Time
	Attributes   map[string]any
}

type SessionConfig struct {
	Store      SessionStore
	CookieName string
	Required   bool
	Touch      bool
}

type SessionStore interface {
	Get(ctx context.Context, id string) (Session, error)
	Set(ctx context.Context, session Session) error
	Delete(ctx context.Context, id string) error
}

type StaticHosts map[string]string

type UnaryHandler[Req any, Reply any] func(context.Context, Req) (Reply, error)

type UnaryRPC[Req any, Reply any] func(context.Context, Req, ...grpc.CallOption) (Reply, error)

type UpstreamInvoker interface {
	Invoke(ctx context.Context, match RouteMatch, req DispatchRequest, target string) (DispatchResponse, error)
}

type UpstreamRef struct {
	Service   string
	Namespace string
	Port      int
	Protocol  string
	Operation string
}