Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(opt Options) *Controller
func (*Controller) RealJSMC ¶ added in v0.14.0
func (c *Controller) RealJSMC(cfg *natsContext) (jsmClient, error)
RealJSMC creates a new JSM client from pooled nats connections Providing a blank string for servers, defaults to c.opts.NATSServerUrls call deferred jsmC.Close() on returned instance to return the nats connection to pool
func (*Controller) Run ¶
func (c *Controller) Run() error
type Options ¶
type Options struct { Ctx context.Context KubeIface kubernetes.Interface JetstreamIface clientset.Interface NATSClientName string NATSCredentials string NATSNKey string NATSServerURL string NATSCA string NATSCertificate string NATSKey string Namespace string CRDConnect bool CleanupPeriod time.Duration ReadOnly bool Recorder record.EventRecorder }
Click to show internal directories.
Click to hide internal directories.