theila

Documentation

Overview

Package theila implements the internal service runtime.

Index

• Variables
• type Runtime
  • func New() (*Runtime, error)
  • func (r *Runtime) AddContext(id string, data []byte) error
  • func (r *Runtime) Create(ctx context.Context, resource cosiresource.Resource, ...) error
  • func (r *Runtime) Delete(ctx context.Context, setters ...runtime.QueryOption) error
  • func (r *Runtime) Get(ctx context.Context, setters ...runtime.QueryOption) (interface{}, error)
  • func (r *Runtime) GetContext(ctx context.Context, context *common.Context, cluster *common.Cluster) ([]byte, error)
  • func (r *Runtime) List(ctx context.Context, setters ...runtime.QueryOption) ([]interface{}, error)
  • func (r *Runtime) Run(ctx context.Context)
  • func (r *Runtime) Shutdown() error
  • func (r *Runtime) Update(ctx context.Context, resource cosiresource.Resource, ...) error
  • func (r *Runtime) Watch(ctx context.Context, request *message.WatchSpec, events chan runtime.Event) error
• type Watch

Variables

var Name = common.Runtime_Theila.String()

Name is the runtime time.

Types

type Runtime

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

Runtime implements Theila internal runtime.

func New

func New() (*Runtime, error)

New creates a new Theila runtime.

func (*Runtime) AddContext

func (r *Runtime) AddContext(id string, data []byte) error

AddContext implements runtime.Runtime.

func (*Runtime) Create

func (r *Runtime) Create(ctx context.Context, resource cosiresource.Resource, setters ...runtime.QueryOption) error

Create implements runtime.Runtime.

func (*Runtime) Delete

func (r *Runtime) Delete(ctx context.Context, setters ...runtime.QueryOption) error

Delete implements runtime.Runtime.

func (*Runtime) Get

func (r *Runtime) Get(ctx context.Context, setters ...runtime.QueryOption) (interface{}, error)

Get implements runtime.Runtime.

func (*Runtime) GetContext

func (r *Runtime) GetContext(ctx context.Context, context *common.Context, cluster *common.Cluster) ([]byte, error)

GetContext implements runtime.Runtime.

func (*Runtime) List

func (r *Runtime) List(ctx context.Context, setters ...runtime.QueryOption) ([]interface{}, error)

List implements runtime.Runtime.

func (*Runtime) Run

func (r *Runtime) Run(ctx context.Context)

Run starts underlying COSI controller runtime.

func (*Runtime) Shutdown

func (r *Runtime) Shutdown() error

Shutdown stops the controller runtime.

func (*Runtime) Update

func (r *Runtime) Update(ctx context.Context, resource cosiresource.Resource, setters ...runtime.QueryOption) error

Update implements runtime.Runtime.

func (*Runtime) Watch

func (r *Runtime) Watch(ctx context.Context, request *message.WatchSpec, events chan runtime.Event) error

Watch implements runtime.Runtime.

type Watch

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

Watch watches Theila resources.