operator

Documentation

Index

• Constants
• Variables
• func EnsureCRD(clientset apiextensionsclient.Interface) error
• type Operator
  • func New(options Options) *Operator
  • func (op *Operator) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)
• type Options

Constants

const (
	TPR_RECHECK_INTERVAL = 5 * time.Minute
	CACHE_RESYNC_PERIOD  = 2 * time.Minute
)

Variables

var VERSION = "HEAD"

Functions

func EnsureCRD

func EnsureCRD(clientset apiextensionsclient.Interface) error

Types

type Operator

type Operator struct {
	Options
	// contains filtered or unexported fields
}

func New

func New(options Options) *Operator

func (*Operator) Run

func (op *Operator) Run(threadiness int, stopCh <-chan struct{}, wg *sync.WaitGroup)

type Options

type Options struct {
	KubeContext        string
	KubeConfig         string
	SentryEndpoint     string
	SentryToken        string
	SentryOrganization string
}