middleware

Documentation

Index

• Constants
• Variables
• func NewDispatcher(auditReqChan chan *cmdWithTimestamp, closeChan chan struct{}) *dispatcher
• type Auditor
  • func NewAuditor(bdl *bundle.Bundle) *Auditor
  • func (a *Auditor) AuditMiddleWare(next http.Handler) http.Handler
• type Authenticator
  • func NewAuthenticator(bdl *bundle.Bundle) *Authenticator
  • func (a *Authenticator) AuthMiddleware(next http.Handler) http.Handler
• type Chain
  • func (c Chain) Handler(handler http.Handler) http.Handler
• type Queue
• type ShellHandler
  • func NewShellHandler(ctx context.Context) *ShellHandler
  • func (s *ShellHandler) HandleShell(next http.Handler) http.Handler

Constants

const (
	// audit template name
	AuditCordonNode      = "cordonNode"
	AuditUncordonNode    = "uncordonNode"
	AuditLabelNode       = "labelNode"
	AuditUnLabelNode     = "unLabelNode"
	AuditDrainNode       = "drainNode"
	AuditOfflineNode     = "offlineNode"
	AuditOnlineNode      = "onlineNode"
	AuditUpdateResource  = "updateK8SResource"
	AuditCreateResource  = "createK8SResource"
	AuditDeleteResource  = "deleteK8SResource"
	AuditKubectlShell    = "kubectlShell"
	AuditRestartWorkload = "restartWorkload"

	// audit template params
	AuditClusterName  = "clusterName"
	AuditNamespace    = "namespace"
	AuditResourceType = "resourceType"
	AuditResourceName = "name"
	AuditTargetLabel  = "targetLabel"
	AuditCommands     = "commands"
)

Variables

var (
	OutOfLengthSize = errors.New("cmd length out of buffer limit")
)

Functions

func NewDispatcher

func NewDispatcher(auditReqChan chan *cmdWithTimestamp, closeChan chan struct{}) *dispatcher

Types

type Auditor

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

func NewAuditor

func NewAuditor(bdl *bundle.Bundle) *Auditor

NewAuditor return a steve Auditor with bundle. bdl needs withCoreServices to create audit events.

func (*Auditor) AuditMiddleWare

func (a *Auditor) AuditMiddleWare(next http.Handler) http.Handler

AuditMiddleWare audit for steve server by bundle.

type Authenticator

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

func NewAuthenticator

func NewAuthenticator(bdl *bundle.Bundle) *Authenticator

NewAuthenticator return a steve Authenticator with bundle. bdl need withCoreServices to check permission.

func (*Authenticator) AuthMiddleware

func (a *Authenticator) AuthMiddleware(next http.Handler) http.Handler

AuthMiddleware authenticate for steve server by bundle.

type Chain

type Chain []mux.MiddlewareFunc

func (Chain) Handler

func (c Chain) Handler(handler http.Handler) http.Handler

type Queue

type Queue interface {
	Front() string

	Back() string

	Size() int
	Get(i int) (string, error)
	Set(i int, str string) error
	Begin() int
	// contains filtered or unexported methods
}

type ShellHandler

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

func NewShellHandler

func NewShellHandler(ctx context.Context) *ShellHandler

NewShellHandler create a new ShellHandler

func (*ShellHandler) HandleShell

func (s *ShellHandler) HandleShell(next http.Handler) http.Handler

HandleShell forwards the request to cluster-agent pod