server

package
v18.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 14, 2025 License: MIT Imports: 68 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_internal_module_kubernetes_api_server_server_proto protoreflect.FileDescriptor

Functions

func ApplyDefaults

func ApplyDefaults(config *kascfg.ConfigurationFile)

Types

type Factory

type Factory struct {
	WebSocketTokenJWTSecretFile string
}

func (*Factory) Name

func (f *Factory) Name() string

func (*Factory) New

func (f *Factory) New(config *modserver.Config) (modserver.Module, error)

type K8sAPIProxyRequestsEvent

type K8sAPIProxyRequestsEvent struct {
	UserID    int64 `json:"user_id"`
	ProjectID int64 `json:"project_id"`
}

func (K8sAPIProxyRequestsEvent) DeduplicateKey

func (e K8sAPIProxyRequestsEvent) DeduplicateKey() string

type ValidatingWebSocketTokenClaims

type ValidatingWebSocketTokenClaims struct {
	WebSocketTokenClaims

	Validator        protovalidate.Validator
	ValidForEndpoint string
}

func (*ValidatingWebSocketTokenClaims) Validate

func (v *ValidatingWebSocketTokenClaims) Validate() error

type WebSocketTokenClaims

type WebSocketTokenClaims struct {
	RegisteredClaimIssuer    string                              `protobuf:"bytes,1,opt,name=registered_claim_issuer,json=iss,proto3" json:"registered_claim_issuer,omitempty"`
	RegisteredClaimSubject   string                              `protobuf:"bytes,2,opt,name=registered_claim_subject,json=sub,proto3" json:"registered_claim_subject,omitempty"`
	RegisteredClaimAudience  []string                            `protobuf:"bytes,3,rep,name=registered_claim_audience,json=aud,proto3" json:"registered_claim_audience,omitempty"`
	RegisteredClaimExpiresAt int64                               `protobuf:"varint,4,opt,name=registered_claim_expires_at,json=exp,proto3" json:"registered_claim_expires_at,omitempty"`
	RegisteredClaimNotBefore int64                               `protobuf:"varint,5,opt,name=registered_claim_not_before,json=nbf,proto3" json:"registered_claim_not_before,omitempty"`
	RegisteredClaimIssuedAt  int64                               `protobuf:"varint,6,opt,name=registered_claim_issued_at,json=iat,proto3" json:"registered_claim_issued_at,omitempty"`
	Endpoint                 string                              `protobuf:"bytes,7,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	AgentId                  int64                               `protobuf:"varint,8,opt,name=agent_id,proto3" json:"agent_id,omitempty"`
	ImpersonationConfig      *kubernetes_api.ImpersonationConfig `protobuf:"bytes,9,opt,name=impersonation_config,proto3" json:"impersonation_config,omitempty"`
	// contains filtered or unexported fields
}

func (*WebSocketTokenClaims) Descriptor deprecated

func (*WebSocketTokenClaims) Descriptor() ([]byte, []int)

Deprecated: Use WebSocketTokenClaims.ProtoReflect.Descriptor instead.

func (*WebSocketTokenClaims) GetAgentId

func (x *WebSocketTokenClaims) GetAgentId() int64

func (*WebSocketTokenClaims) GetAudience

func (c *WebSocketTokenClaims) GetAudience() (jwt.ClaimStrings, error)

func (*WebSocketTokenClaims) GetEndpoint

func (x *WebSocketTokenClaims) GetEndpoint() string

func (*WebSocketTokenClaims) GetExpirationTime

func (c *WebSocketTokenClaims) GetExpirationTime() (*jwt.NumericDate, error)

func (*WebSocketTokenClaims) GetImpersonationConfig

func (x *WebSocketTokenClaims) GetImpersonationConfig() *kubernetes_api.ImpersonationConfig

func (*WebSocketTokenClaims) GetIssuedAt

func (c *WebSocketTokenClaims) GetIssuedAt() (*jwt.NumericDate, error)

func (*WebSocketTokenClaims) GetIssuer

func (c *WebSocketTokenClaims) GetIssuer() (string, error)

func (*WebSocketTokenClaims) GetNotBefore

func (c *WebSocketTokenClaims) GetNotBefore() (*jwt.NumericDate, error)

func (*WebSocketTokenClaims) GetRegisteredClaimAudience

func (x *WebSocketTokenClaims) GetRegisteredClaimAudience() []string

func (*WebSocketTokenClaims) GetRegisteredClaimExpiresAt

func (x *WebSocketTokenClaims) GetRegisteredClaimExpiresAt() int64

func (*WebSocketTokenClaims) GetRegisteredClaimIssuedAt

func (x *WebSocketTokenClaims) GetRegisteredClaimIssuedAt() int64

func (*WebSocketTokenClaims) GetRegisteredClaimIssuer

func (x *WebSocketTokenClaims) GetRegisteredClaimIssuer() string

func (*WebSocketTokenClaims) GetRegisteredClaimNotBefore

func (x *WebSocketTokenClaims) GetRegisteredClaimNotBefore() int64

func (*WebSocketTokenClaims) GetRegisteredClaimSubject

func (x *WebSocketTokenClaims) GetRegisteredClaimSubject() string

func (*WebSocketTokenClaims) GetSubject

func (c *WebSocketTokenClaims) GetSubject() (string, error)

func (*WebSocketTokenClaims) MarshalJSON

func (c *WebSocketTokenClaims) MarshalJSON() ([]byte, error)

func (*WebSocketTokenClaims) ProtoMessage

func (*WebSocketTokenClaims) ProtoMessage()

func (*WebSocketTokenClaims) ProtoReflect

func (x *WebSocketTokenClaims) ProtoReflect() protoreflect.Message

func (*WebSocketTokenClaims) Reset

func (x *WebSocketTokenClaims) Reset()

func (*WebSocketTokenClaims) String

func (x *WebSocketTokenClaims) String() string

func (*WebSocketTokenClaims) UnmarshalJSON

func (c *WebSocketTokenClaims) UnmarshalJSON(b []byte) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL