connection

Documentation

Overview

The Lenses API has two groups of endpoints to manage connections: a "generic" one and several "specific" ones. The generic one accepts all possible connection objects. Such an object has a "templateName" which is the type of the object, e.g.: PostgreSQL, Elasticsearch, etc. There are also a few specific endpoints that accept one connection "flavour". Examples are Kafka, KafkaConnect, etc. The generic API is a superset of the specific ones: every specific connection can be administered via the generic API, only a handful specific connections exist.

The generic endpoint is: /api/v1/connection/connections; An example of a specific endpoint is: /api/v1/connection/connection-templates/KafkaConnect.

Index

• func NewAWSGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewConnectionGroupCommand() *cobra.Command
• func NewDataDogGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewElasticsearchGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewFlagMapper(cmd *cobra.Command, onto any, uploadFile uploadFunc, opts FlagMapperOpts) *flagMapper
• func NewGenericConnectionCreateCommand() *cobra.Command
• func NewGenericConnectionDeleteCommand() *cobra.Command
• func NewGenericConnectionGetCommand() *cobra.Command
• func NewGenericConnectionGroupCommand() *cobra.Command
• func NewGenericConnectionListCommand() *cobra.Command
• func NewGenericConnectionUpdateCommand() *cobra.Command
• func NewGlueGroupCommand(gen genericConnectionClientV2, up uploadFunc) *cobra.Command
• func NewKafkaConnectGroupCommand(up uploadFunc) *cobra.Command
• func NewKafkaGroupCommand(cl kafkaClient, up uploadFunc) *cobra.Command
• func NewKerberosGroupCommand(up uploadFunc) *cobra.Command
• func NewPagerDutyGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewPostgreSQLGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewPrometheusAlertmanagerGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewSchemaRegistryGroupCommand(up uploadFunc) *cobra.Command
• func NewSlackGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewSplunkGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewWebhookGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command
• func NewZookeeperGroupCommand(up uploadFunc) *cobra.Command
• type FlagMapperOpts

Functions

func NewAWSGroupCommand

func NewAWSGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewConnectionGroupCommand

func NewConnectionGroupCommand() *cobra.Command

NewConnectionGroupCommand creates `connection` command

func NewDataDogGroupCommand

func NewDataDogGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewElasticsearchGroupCommand

func NewElasticsearchGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewFlagMapper

func NewFlagMapper(cmd *cobra.Command, onto any, uploadFile uploadFunc, opts FlagMapperOpts) *flagMapper

func NewGenericConnectionCreateCommand

func NewGenericConnectionCreateCommand() *cobra.Command

NewGenericConnectionCreateCommand creates `connections create` group command

func NewGenericConnectionDeleteCommand

func NewGenericConnectionDeleteCommand() *cobra.Command

NewGenericConnectionDeleteCommand creates `connections delete` group command

func NewGenericConnectionGetCommand

func NewGenericConnectionGetCommand() *cobra.Command

NewConnectionGetCommand creates `connections get` group command

func NewGenericConnectionGroupCommand

func NewGenericConnectionGroupCommand() *cobra.Command

func NewGenericConnectionListCommand

func NewGenericConnectionListCommand() *cobra.Command

func NewGenericConnectionUpdateCommand

func NewGenericConnectionUpdateCommand() *cobra.Command

NewGenericConnectionUpdateCommand creates `connections update` group command

func NewGlueGroupCommand

func NewGlueGroupCommand(gen genericConnectionClientV2, up uploadFunc) *cobra.Command

func NewKafkaConnectGroupCommand

func NewKafkaConnectGroupCommand(up uploadFunc) *cobra.Command

func NewKafkaGroupCommand

func NewKafkaGroupCommand(cl kafkaClient, up uploadFunc) *cobra.Command

func NewKerberosGroupCommand

func NewKerberosGroupCommand(up uploadFunc) *cobra.Command

func NewPagerDutyGroupCommand

func NewPagerDutyGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewPostgreSQLGroupCommand

func NewPostgreSQLGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewPrometheusAlertmanagerGroupCommand

func NewPrometheusAlertmanagerGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewSchemaRegistryGroupCommand

func NewSchemaRegistryGroupCommand(up uploadFunc) *cobra.Command

func NewSlackGroupCommand

func NewSlackGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewSplunkGroupCommand

func NewSplunkGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewWebhookGroupCommand

func NewWebhookGroupCommand(gen genericConnectionClient, up uploadFunc) *cobra.Command

func NewZookeeperGroupCommand

func NewZookeeperGroupCommand(up uploadFunc) *cobra.Command

Types

type FlagMapperOpts

type FlagMapperOpts struct {
	Descriptions map[string]string // Field name to description.
	Defaults     map[string]string // Field name to default, only for strings.
	Rename       map[string]string // Field name to flag name.
	Hide         []string          // Ignore those fields names.
	// contains filtered or unexported fields
}