server

Documentation

Overview

Package server provides a wrapper around controller.Runtime over gRPC.

Index

• type Runtime
  • func NewRuntime(engine controller.Engine) *Runtime
  • func (runtime *Runtime) AddFinalizer(ctx context.Context, req *v1alpha1.RuntimeAddFinalizerRequest) (*v1alpha1.RuntimeAddFinalizerResponse, error)
  • func (runtime *Runtime) Create(ctx context.Context, req *v1alpha1.RuntimeCreateRequest) (*v1alpha1.RuntimeCreateResponse, error)
  • func (runtime *Runtime) Destroy(ctx context.Context, req *v1alpha1.RuntimeDestroyRequest) (*v1alpha1.RuntimeDestroyResponse, error)
  • func (runtime *Runtime) Get(ctx context.Context, req *v1alpha1.RuntimeGetRequest) (*v1alpha1.RuntimeGetResponse, error)
  • func (runtime *Runtime) List(req *v1alpha1.RuntimeListRequest, srv v1alpha1.ControllerAdapter_ListServer) error
  • func (runtime *Runtime) QueueReconcile(ctx context.Context, req *v1alpha1.QueueReconcileRequest) (*v1alpha1.QueueReconcileResponse, error)
  • func (runtime *Runtime) ReconcileEvents(req *v1alpha1.ReconcileEventsRequest, ...) error
  • func (runtime *Runtime) RegisterController(ctx context.Context, req *v1alpha1.RegisterControllerRequest) (*v1alpha1.RegisterControllerResponse, error)
  • func (runtime *Runtime) RemoveFinalizer(ctx context.Context, req *v1alpha1.RuntimeRemoveFinalizerRequest) (*v1alpha1.RuntimeRemoveFinalizerResponse, error)
  • func (runtime *Runtime) Start(ctx context.Context, req *v1alpha1.StartRequest) (*v1alpha1.StartResponse, error)
  • func (runtime *Runtime) Stop(ctx context.Context, req *v1alpha1.StopRequest) (*v1alpha1.StopResponse, error)
  • func (runtime *Runtime) Teardown(ctx context.Context, req *v1alpha1.RuntimeTeardownRequest) (*v1alpha1.RuntimeTeardownResponse, error)
  • func (runtime *Runtime) Update(ctx context.Context, req *v1alpha1.RuntimeUpdateRequest) (*v1alpha1.RuntimeUpdateResponse, error)
  • func (runtime *Runtime) UpdateInputs(ctx context.Context, req *v1alpha1.UpdateInputsRequest) (*v1alpha1.UpdateInputsResponse, error)
  • func (runtime *Runtime) WatchFor(ctx context.Context, req *v1alpha1.RuntimeWatchForRequest) (*v1alpha1.RuntimeWatchForResponse, error)

Types

type Runtime

type Runtime struct {
	v1alpha1.UnimplementedControllerRuntimeServer
	v1alpha1.UnimplementedControllerAdapterServer
	// contains filtered or unexported fields
}

Runtime implements controller.Runtime over gRPC.

func NewRuntime

func NewRuntime(engine controller.Engine) *Runtime

NewRuntime initializes new gRPC wrapper around controller.Engine.

func (*Runtime) AddFinalizer

func (runtime *Runtime) AddFinalizer(ctx context.Context, req *v1alpha1.RuntimeAddFinalizerRequest) (*v1alpha1.RuntimeAddFinalizerResponse, error)

AddFinalizer to a resource.

func (*Runtime) Create

func (runtime *Runtime) Create(ctx context.Context, req *v1alpha1.RuntimeCreateRequest) (*v1alpha1.RuntimeCreateResponse, error)

Create a resource.

func (*Runtime) Destroy

func (runtime *Runtime) Destroy(ctx context.Context, req *v1alpha1.RuntimeDestroyRequest) (*v1alpha1.RuntimeDestroyResponse, error)

Destroy a resource.

func (*Runtime) Get

func (runtime *Runtime) Get(ctx context.Context, req *v1alpha1.RuntimeGetRequest) (*v1alpha1.RuntimeGetResponse, error)

Get a resource.

func (*Runtime) List

func (runtime *Runtime) List(req *v1alpha1.RuntimeListRequest, srv v1alpha1.ControllerAdapter_ListServer) error

List resources.

func (*Runtime) QueueReconcile

func (runtime *Runtime) QueueReconcile(ctx context.Context, req *v1alpha1.QueueReconcileRequest) (*v1alpha1.QueueReconcileResponse, error)

QueueReconcile queues another reconcile event.

func (*Runtime) ReconcileEvents

func (runtime *Runtime) ReconcileEvents(req *v1alpha1.ReconcileEventsRequest, srv v1alpha1.ControllerAdapter_ReconcileEventsServer) error

ReconcileEvents sends message on each reconcile event for the controller.

func (*Runtime) RegisterController

func (runtime *Runtime) RegisterController(ctx context.Context, req *v1alpha1.RegisterControllerRequest) (*v1alpha1.RegisterControllerResponse, error)

RegisterController registers controller and establishes token for ControllerAdapter calls.

func (*Runtime) RemoveFinalizer

func (runtime *Runtime) RemoveFinalizer(ctx context.Context, req *v1alpha1.RuntimeRemoveFinalizerRequest) (*v1alpha1.RuntimeRemoveFinalizerResponse, error)

RemoveFinalizer from a resource.

func (*Runtime) Start

func (runtime *Runtime) Start(ctx context.Context, req *v1alpha1.StartRequest) (*v1alpha1.StartResponse, error)

Start the controller runtime.

func (*Runtime) Stop

func (runtime *Runtime) Stop(ctx context.Context, req *v1alpha1.StopRequest) (*v1alpha1.StopResponse, error)

Stop the controller runtime.

func (*Runtime) Teardown

func (runtime *Runtime) Teardown(ctx context.Context, req *v1alpha1.RuntimeTeardownRequest) (*v1alpha1.RuntimeTeardownResponse, error)

Teardown a resource.

func (*Runtime) Update

func (runtime *Runtime) Update(ctx context.Context, req *v1alpha1.RuntimeUpdateRequest) (*v1alpha1.RuntimeUpdateResponse, error)

Update a resource.

func (*Runtime) UpdateInputs

func (runtime *Runtime) UpdateInputs(ctx context.Context, req *v1alpha1.UpdateInputsRequest) (*v1alpha1.UpdateInputsResponse, error)

UpdateInputs updates the list of controller inputs.

func (*Runtime) WatchFor

func (runtime *Runtime) WatchFor(ctx context.Context, req *v1alpha1.RuntimeWatchForRequest) (*v1alpha1.RuntimeWatchForResponse, error)

WatchFor specific resource changes.