contextutil

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 GetCurrentNamespaceInstance(conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.ConnectorNamespace, error)
• func GetCurrentRegistryInstance(f *factory.Factory) (*registrymgmtclient.Registry, error)
• func GetKafkaForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*kafkamgmtclient.KafkaRequest, error)
• func GetNamespaceForServiceConfig(currCtx *servicecontext.ServiceConfig, conn *connection.Connection, ...) (*connectormgmtclient.ConnectorNamespace, error)
• func GetRegistryForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*registrymgmtclient.Registry, error)
• func SetCurrentConnectorInstance(connector *connectormgmtclient.Connector, conn *connection.Connection, ...) error
• func SetCurrentNamespaceInstance(namespace *connectormgmtclient.ConnectorNamespace, conn *connection.Connection, ...) error

Functions

func GetConnectorForServiceConfig

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

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 GetCurrentNamespaceInstance

func GetCurrentNamespaceInstance(conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.ConnectorNamespace, error)

GetCurrentNamespaceInstance returns the namespace 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 GetNamespaceForServiceConfig

func GetNamespaceForServiceConfig(currCtx *servicecontext.ServiceConfig, conn *connection.Connection, f *factory.Factory) (*connectormgmtclient.ConnectorNamespace, error)

func GetRegistryForServiceConfig

func GetRegistryForServiceConfig(currCtx *servicecontext.ServiceConfig, f *factory.Factory) (*registrymgmtclient.Registry, error)

func SetCurrentConnectorInstance

func SetCurrentConnectorInstance(connector *connectormgmtclient.Connector, conn *connection.Connection, f *factory.Factory) error

func SetCurrentNamespaceInstance

func SetCurrentNamespaceInstance(namespace *connectormgmtclient.ConnectorNamespace, conn *connection.Connection, f *factory.Factory) error