core

type Event struct {
	Kind          string
	ObjectMetaKey string
	Object        interface{}
}

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

type HTTPCodeError int

type HTTPMiddlewareOption func(*httpMiddleware)

type HTTPService struct {
	*mux.Router

	// Addr could be a TCP address like:
	//
	// - 0.0.0.0:8000 (any interface, port 8000)
	// - 127.0.0.1:8000 (loop-back interface only, port 8000)
	// - 0.0.0.0:0 (any interface, any free port)
	//
	// Addr could also be prefix with `unix://` (e.g.,
	// `unix:///tmp/test.sock`), which will make HTTPService listen to a
	// local unix domain socket instead of a network interface.
	Addr string

	// TLSCertFile and TLSKeyFile are passed to ServeTLS() to serve HTTPS.
	// By default, HTTPService serves plain HTTP.
	TLSCertFile, TLSKeyFile string

	// SocketPermission is only applicable when addr is a unix socket
	// path, e.g., 'unix:///tmp/test.sock'
	SocketPermission os.FileMode

	// ReadTimeout, WriteTimeout and IdleTimeout are timeout
	// configurations passed to go http.Server.
	ReadTimeout, WriteTimeout, IdleTimeout time.Duration

	// ShutDownGracePeriod is the grace period for
	// `http.Server:Shutdown`
	ShutDownGracePeriod time.Duration
}

type KubeClients struct {
	Config *rest.Config
	K8s    k8sclient.Interface
}

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

type KubeConfigurator interface {
	Start(ctx context.Context) <-chan *rest.Config
}

type ObjectUpdate struct {
	NewObj interface{}
	OldObj interface{}
}

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

type Queue chan *Event

type Rand struct {
	sync.Mutex
	*rand.Rand
}

type RecurrentEventSource struct {
	Kind     string
	Interval time.Duration
	Ticker   *time.Ticker
}

type RecurrentEventTicker struct {
	Sources []RecurrentEventSource
	C       Queue
}

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

type TokenFetcher interface {
	FetchToken(ctx context.Context) (string, error)
	RefreshClient()
}

type TokenKubeConfigurator struct {
	sync.Mutex
	// contains filtered or unexported fields
}