encoders

Documentation

Index

• Constants
• func GenerateK8sEvents(owner ObjHandler, addElemts int64)
• func GenerateK8sEventsWithDependent(owner, dependent ObjHandler, addElemts int64)
• func WatchOrListResponder(lister lister, params *WatchOrListResponderCfg, getResponder getResponder) middleware.Responder
• func WatchOrListResponderWithEvents(lister streamLister, params *WatchOrListResponderCfg, ...) middleware.Responder
• type ObjHandler
• type ObjHandlerNoOp
  • func (*ObjHandlerNoOp) AddElements(int64) int64
  • func (*ObjHandlerNoOp) GenObjs(_, _ int64) <-chan k8sRuntime.Object
  • func (*ObjHandlerNoOp) Log() *logrus.Logger
  • func (*ObjHandlerNoOp) Stream() chan k8sRuntime.Object
• type WatchOrListResponderCfg

Constants

const (
	ProtobufHeader = "application/vnd.kubernetes.protobuf"
	JSONHeader     = "application/json"
)

Functions

func GenerateK8sEvents

func GenerateK8sEvents(owner ObjHandler, addElemts int64)

func GenerateK8sEventsWithDependent

func GenerateK8sEventsWithDependent(owner, dependent ObjHandler, addElemts int64)

func WatchOrListResponder

func WatchOrListResponder(lister lister, params *WatchOrListResponderCfg, getResponder getResponder) middleware.Responder

func WatchOrListResponderWithEvents

func WatchOrListResponderWithEvents(lister streamLister, params *WatchOrListResponderCfg, getResponder getResponder, enc k8sRuntime.Encoder) middleware.Responder

Types

type ObjHandler

type ObjHandler interface {
	AddElements(elem int64) int64
	GenObjs(start, maxElemts int64) <-chan k8sRuntime.Object
	Stream() chan k8sRuntime.Object
	Log() *logrus.Logger
}

type ObjHandlerNoOp

type ObjHandlerNoOp struct{}

func (*ObjHandlerNoOp) AddElements

func (*ObjHandlerNoOp) AddElements(int64) int64

func (*ObjHandlerNoOp) GenObjs

func (*ObjHandlerNoOp) GenObjs(_, _ int64) <-chan k8sRuntime.Object

func (*ObjHandlerNoOp) Log

func (*ObjHandlerNoOp) Log() *logrus.Logger

func (*ObjHandlerNoOp) Stream

func (*ObjHandlerNoOp) Stream() chan k8sRuntime.Object

type WatchOrListResponderCfg

type WatchOrListResponderCfg struct {
	Watch          *bool
	TimeoutSeconds *int64
	Limit          *int64
	Cont           *string
	FieldSelector  *string
	LabelSelector  *string
	Matcher        func(label k8sLabels.Selector, field k8sFields.Selector) k8sStorage.SelectionPredicate
}