manager

Documentation

Index

• type BaseStreaming
• type Feature
• type Manager
  • func New(src client.ObjectKey, rm api.RuntimeManager, cfg *rest.Config, ...) (Manager, error)

Types

type BaseStreaming

type BaseStreaming struct {
	BrokerKind string `mapstructure:"kind"`
	Workers    int
	Schema     *url.URL
	// contains filtered or unexported fields
}

type Feature

type Feature struct {
	Schema   string   `json:"schema,omitempty"`
	Packages []string `json:"packages,omitempty"`
	*api.FeatureDescriptor
}

type Manager

type Manager interface {
	Start(context.Context) error
	Ready(context.Context) bool
}

func New

func New(src client.ObjectKey, rm api.RuntimeManager, cfg *rest.Config, logger logr.Logger) (Manager, error)