Documentation
¶
Index ¶
- func GetConnectorForServiceConfig(currCtx *servicecontext.ServiceConfig, conn *connection.Connection, ...) (*connectormgmtclient.Connector, error)
- func GetContext(svcContext *servicecontext.Context, localizer localize.Localizer, ...) (*servicecontext.ServiceConfig, error)
- func GetCurrentConnectorInstance(conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.Connector, error)
- func GetCurrentContext(svcContext *servicecontext.Context, localizer localize.Localizer) (*servicecontext.ServiceConfig, error)
- func GetCurrentKafkaInstance(f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error)
- func GetCurrentRegistryInstance(f *factory.Factory) (*registrymgmtclient.Registry, error)
- func GetKafkaForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error)
- func GetRegistryForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*registrymgmtclient.Registry, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetConnectorForServiceConfig ¶ added in v0.46.0
func GetConnectorForServiceConfig(currCtx *servicecontext.ServiceConfig, conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.Connector, error)
func GetContext ¶
func GetContext(svcContext *servicecontext.Context, localizer localize.Localizer, ctxName string) (*servicecontext.ServiceConfig, error)
GetContext returns the services associated with the context
func GetCurrentConnectorInstance ¶ added in v0.46.0
func GetCurrentConnectorInstance(conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.Connector, error)
GetCurrentConnectorInstance returns the connector instance set in the currently selected context
func GetCurrentContext ¶
func GetCurrentContext(svcContext *servicecontext.Context, localizer localize.Localizer) (*servicecontext.ServiceConfig, error)
GetCurrentContext returns the name of the currently selected context
func GetCurrentKafkaInstance ¶
func GetCurrentKafkaInstance(f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error)
GetCurrentKafkaInstance returns the Kafka instance set in the currently selected context
func GetCurrentRegistryInstance ¶
func GetCurrentRegistryInstance(f *factory.Factory) (*registrymgmtclient.Registry, error)
GetCurrentRegistryInstance returns the Service Registry instance set in the currently selected context
func GetKafkaForServiceConfig ¶
func GetKafkaForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error)
func GetRegistryForServiceConfig ¶
func GetRegistryForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*registrymgmtclient.Registry, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.