type watchEmbeddedEncoder … func newWatchEmbeddedEncoder(ctx context.Context, encoder runtime.Encoder, target *schema.GroupVersionKind, tableOptions *metav1.TableOptions, scope *RequestScope) *watchEmbeddedEncoder { … } // Encode implements runtime.Encoder interface. func (e *watchEmbeddedEncoder) Encode(obj runtime.Object, w io.Writer) error { … } func (e *watchEmbeddedEncoder) doEncode(obj runtime.Object, w io.Writer) error { … } // Identifier implements runtime.Encoder interface. func (e *watchEmbeddedEncoder) Identifier() runtime.Identifier { … } type watchEmbeddedEncoderIdentifier … func (e *watchEmbeddedEncoder) embeddedIdentifier() runtime.Identifier { … } type watchEncoder … func newWatchEncoder(ctx context.Context, kind schema.GroupVersionKind, embeddedEncoder runtime.Encoder, encoder runtime.Encoder, framer io.Writer, watchListTransformerFn watchListTransformerFunction) *watchEncoder { … } // Encode encodes a given watch event. // NOTE: if events object is implementing the CacheableObject interface, // // the serialized version is cached in that object [not the event itself]. func (e *watchEncoder) Encode(event watch.Event) error { … } func (e *watchEncoder) doEncode(obj runtime.Object, event watch.Event, w io.Writer) error { … } type watchEncoderIdentifier … func (e *watchEncoder) identifier(eventType watch.EventType) runtime.Identifier { … } func (e *watchEncoder) typeIdentifier(eventType watch.EventType) runtime.Identifier { … } // doTransformResponseObject is used for handling all requests, including watch. func doTransformObject(ctx context.Context, obj runtime.Object, opts interface{ … } // optionsForTransform will load and validate any additional query parameter options for // a conversion or return an error. func optionsForTransform(mediaType negotiation.MediaTypeOptions, req *http.Request) (interface{ … } // targetEncodingForTransform returns the appropriate serializer for the input media type func targetEncodingForTransform(scope *RequestScope, mediaType negotiation.MediaTypeOptions, req *http.Request) (schema.GroupVersionKind, runtime.NegotiatedSerializer, bool) { … } // transformResponseObject takes an object loaded from storage and performs any necessary transformations. // Will write the complete response object. // transformResponseObject is used only for handling non-streaming requests. func transformResponseObject(ctx context.Context, scope *RequestScope, req *http.Request, w http.ResponseWriter, statusCode int, mediaType negotiation.MediaTypeOptions, result runtime.Object) { … } type errNotAcceptable … func newNotAcceptableError(message string) error { … } func (e errNotAcceptable) Error() string { … } func (e errNotAcceptable) Status() metav1.Status { … } func asTable(ctx context.Context, result runtime.Object, opts *metav1.TableOptions, scope *RequestScope, groupVersion schema.GroupVersion) (runtime.Object, error) { … } func asPartialObjectMetadata(result runtime.Object, groupVersion schema.GroupVersion) (runtime.Object, error) { … } func asPartialObjectMetadataList(result runtime.Object, groupVersion schema.GroupVersion) (runtime.Object, error) { … } type watchListTransformerFunction … type watchListTransformer … // createWatchListTransformerIfRequested returns a transformer function for watchlist bookmark event. func newWatchListTransformer(initialEventsListBlueprint runtime.Object, targetGVK *schema.GroupVersionKind, negotiatedEncoder runtime.Encoder) *watchListTransformer { … } func (e *watchListTransformer) transform(event watch.Event) watch.Event { … } func (e *watchListTransformer) encodeInitialEventsListBlueprint(object runtime.Object) error { … } func (e *watchListTransformer) transformInitialEventsListBlueprint() (runtime.Object, error) { … } func newWatchEventErrorFor(err error) watch.Event { … }
Codebase Browser
kubernetes