Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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
NATSTLSFirst bool
Namespace string
CRDConnect bool
CleanupPeriod time.Duration
ReadOnly bool
Recorder record.EventRecorder
}
Source Files
Click to show internal directories.
Click to hide internal directories.