Versions in this module Expand all Collapse all v0 v0.7.0 Sep 21, 2022 Changes in this version + func NewRedisConnector() connectors.Connector + type RedisConnector struct + func (r RedisConnector) Id() string + func (r RedisConnector) Load(schema interface{}) (interface{}, error) + func (r RedisConnector) Name() string + func (r RedisConnector) Schema() interface{} + func (r RedisConnector) Tags() []string + type RedisCredentials struct + Hostname string + MasterName string + Password string + Port int + SentinelPort int + type RedisSchema RedisCredentials v0.6.0 Aug 9, 2021 Changes in this version + func NewKafkaClientConnector() connectors.Connector type KafkaCredentials + func (k KafkaCredentials) CACertificate() (*x509.Certificate, error) + func (k KafkaCredentials) PEMData() ([]byte, error) + type KafkaDialer struct + type KafkaDialerConnector struct + func (k KafkaDialerConnector) Id() string + func (k KafkaDialerConnector) Load(schema interface{}) (interface{}, error) + func (k KafkaDialerConnector) Name() string + func (k KafkaDialerConnector) Schema() interface{} + func (k KafkaDialerConnector) Tags() []string type KafkaSchema + CACert string v0.5.0 Aug 9, 2021 v0.4.0 Sep 9, 2020 Changes in this version + func NewElastic6ClientConnector() connectors.Connector + func NewElastic7ClientConnector() connectors.Connector + func NewElasticRawConnector() connectors.Connector + type Elastic6Client struct + type Elastic6ClientConnector struct + func (v Elastic6ClientConnector) Id() string + func (v Elastic6ClientConnector) Load(schema interface{}) (interface{}, error) + func (v Elastic6ClientConnector) Name() string + func (v Elastic6ClientConnector) Schema() interface{} + func (v Elastic6ClientConnector) Tags() []string + type Elastic7Client struct + type Elastic7ClientConnector struct + func (v Elastic7ClientConnector) Id() string + func (v Elastic7ClientConnector) Load(schema interface{}) (interface{}, error) + func (v Elastic7ClientConnector) Name() string + func (v Elastic7ClientConnector) Schema() interface{} + func (v Elastic7ClientConnector) Tags() []string + type ElasticCredentials ElasticSchema + func (e ElasticCredentials) Server() string + type ElasticRawConnector struct + func (r ElasticRawConnector) Id() string + func (r ElasticRawConnector) Load(schema interface{}) (interface{}, error) + func (r ElasticRawConnector) Name() string + func (r ElasticRawConnector) Schema() interface{} + func (r ElasticRawConnector) Tags() []string + type ElasticSchema struct + Hostname string + Name string + Password string + Port int + SecretToken string + ServerUrls string + URI string + Username string v0.3.0 Sep 4, 2020 Changes in this version + func NewKafkaRawConnector() connectors.Connector + func NewS3MinioClientConnector() connectors.Connector + type KafkaCredentials KafkaSchema + type KafkaRawConnector struct + func (r KafkaRawConnector) Id() string + func (r KafkaRawConnector) Load(schema interface{}) (interface{}, error) + func (r KafkaRawConnector) Name() string + func (r KafkaRawConnector) Schema() interface{} + func (r KafkaRawConnector) Tags() []string + type KafkaSchema struct + Hostname string + Hostnames []string + Password string + Port int + URI string + Username string + type S3MinioClient struct + type S3MinioClientConnector struct + func (v S3MinioClientConnector) Id() string + func (v S3MinioClientConnector) Load(schema interface{}) (interface{}, error) + func (v S3MinioClientConnector) Name() string + func (v S3MinioClientConnector) Schema() interface{} + func (v S3MinioClientConnector) Tags() []string v0.2.0 Jul 2, 2020 v0.1.0 Jun 29, 2020 Changes in this version + func NewCartelClientConnector() connectors.Connector + func NewCartelRawConnector() connectors.Connector + func NewDynamoDBClientConnector() connectors.Connector + func NewDynamoDBRawConnector() connectors.Connector + func NewIronClientConnector() connectors.Connector + func NewIronRawConnector() connectors.Connector + func NewPostgresSQLClientConnector() connectors.Connector + func NewPostgresSQLRawConnector() connectors.Connector + func NewRedshiftConnector() connectors.Connector + func NewRedshiftRawConnector() connectors.Connector + func NewS3ClientConnector() connectors.Connector + func NewS3RawConnector() connectors.Connector + func NewTwilioClientConnector() connectors.Connector + func NewTwilioRawConnector() connectors.Connector + func NewVaultClientConnector() connectors.Connector + func NewVaultRawConnector() connectors.Connector + type CartelClient struct + type CartelClientConnector struct + func (c CartelClientConnector) Id() string + func (c CartelClientConnector) Load(schema interface{}) (interface{}, error) + func (c CartelClientConnector) Name() string + func (c CartelClientConnector) Schema() interface{} + func (c CartelClientConnector) Tags() []string + type CartelConfig cartel.Config + type CartelRawConnector struct + func (c CartelRawConnector) Id() string + func (c CartelRawConnector) Load(schema interface{}) (interface{}, error) + func (c CartelRawConnector) Name() string + func (c CartelRawConnector) Schema() interface{} + func (c CartelRawConnector) Tags() []string + type DynamoDBClient struct + TableName string + type DynamoDBClientConnector struct + func (c DynamoDBClientConnector) Id() string + func (c DynamoDBClientConnector) Load(schema interface{}) (interface{}, error) + func (c DynamoDBClientConnector) Name() string + func (c DynamoDBClientConnector) Schema() interface{} + func (c DynamoDBClientConnector) Tags() []string + type DynamoDBRawConnector struct + func (c DynamoDBRawConnector) Id() string + func (c DynamoDBRawConnector) Load(schema interface{}) (interface{}, error) + func (c DynamoDBRawConnector) Name() string + func (c DynamoDBRawConnector) Schema() interface{} + func (c DynamoDBRawConnector) Tags() []string + type DynamoDBSchema struct + AWSKey string + AWSRegion string + AWSSecret string + TableName string + type IronClient struct + type IronClientConnector struct + func (i IronClientConnector) Id() string + func (i IronClientConnector) Load(schema interface{}) (interface{}, error) + func (i IronClientConnector) Name() string + func (i IronClientConnector) Schema() interface{} + func (i IronClientConnector) Tags() []string + type IronPlan iron.Config + type IronRawConnector struct + func (i IronRawConnector) Id() string + func (i IronRawConnector) Load(schema interface{}) (interface{}, error) + func (i IronRawConnector) Name() string + func (i IronRawConnector) Schema() interface{} + func (i IronRawConnector) Tags() []string + type PostgreSQLClient struct + type PostgreSQLClientConnector struct + func (c PostgreSQLClientConnector) GetConnString(schema PostgresSQLSchema) string + func (c PostgreSQLClientConnector) Id() string + func (c PostgreSQLClientConnector) Load(schema interface{}) (interface{}, error) + func (c PostgreSQLClientConnector) Name() string + func (c PostgreSQLClientConnector) Schema() interface{} + func (c PostgreSQLClientConnector) Tags() []string + type PostgresSQLRawConnector struct + func (c PostgresSQLRawConnector) Id() string + func (c PostgresSQLRawConnector) Load(schema interface{}) (interface{}, error) + func (c PostgresSQLRawConnector) Name() string + func (c PostgresSQLRawConnector) Schema() interface{} + func (c PostgresSQLRawConnector) Tags() []string + type PostgresSQLSchema struct + AutomatedSnapshotsPassword string + DBName string + Hostname string + Options string + Password string + Port int + URI string + Username string + type RedshiftConnector struct + func (r RedshiftConnector) GetConnString(creds RedshiftCredentials) string + func (r RedshiftConnector) Id() string + func (r RedshiftConnector) Load(schema interface{}) (interface{}, error) + func (r RedshiftConnector) Name() string + func (r RedshiftConnector) Schema() interface{} + func (r RedshiftConnector) Tags() []string + type RedshiftCredentials RedshiftSchema + type RedshiftRawConnector struct + func (r RedshiftRawConnector) Id() string + func (r RedshiftRawConnector) Load(schema interface{}) (interface{}, error) + func (r RedshiftRawConnector) Name() string + func (r RedshiftRawConnector) Schema() interface{} + func (r RedshiftRawConnector) Tags() []string + type RedshiftSchema struct + DatabaseName string + Hostname string + Options string + Password string + Port int + URI string + Username string + type S3Client struct + type S3ClientConnector struct + func (v S3ClientConnector) Id() string + func (v S3ClientConnector) Load(schema interface{}) (interface{}, error) + func (v S3ClientConnector) Name() string + func (v S3ClientConnector) Schema() interface{} + func (v S3ClientConnector) Tags() []string + type S3Credentials S3Schema + type S3RawConnector struct + func (r S3RawConnector) Id() string + func (r S3RawConnector) Load(schema interface{}) (interface{}, error) + func (r S3RawConnector) Name() string + func (r S3RawConnector) Schema() interface{} + func (r S3RawConnector) Tags() []string + type S3Schema struct + APIKey string + Bucket string + Endpoint string + LocationConstraint interface{} + SecretKey string + URI string + type TwilioClientConnector struct + func (c TwilioClientConnector) Id() string + func (c TwilioClientConnector) Load(schema interface{}) (interface{}, error) + func (c TwilioClientConnector) Name() string + func (c TwilioClientConnector) Schema() interface{} + func (c TwilioClientConnector) Tags() []string + type TwilioRawConnector struct + func (c TwilioRawConnector) Id() string + func (c TwilioRawConnector) Load(schema interface{}) (interface{}, error) + func (c TwilioRawConnector) Name() string + func (c TwilioRawConnector) Schema() interface{} + func (c TwilioRawConnector) Tags() []string + type TwilioSchema struct + TwilioAuthToken string + TwilioSID string + type TwilioSubAccount struct + AuthToken string + SID string + type VaultClient struct + func (v *VaultClient) ReadServiceSecret(path string) (*vault.Secret, error) + func (v *VaultClient) ReadServiceTransit(path string) (*vault.Secret, error) + func (v *VaultClient) ReadSpaceSecret(path string) (*vault.Secret, error) + func (v *VaultClient) WriteServiceSecret(path string, data map[string]interface{}) (*vault.Secret, error) + func (v *VaultClient) WriteServiceTransit(path string, data map[string]interface{}) (*vault.Secret, error) + func (v *VaultClient) WriteSpaceSecret(path string, data map[string]interface{}) (*vault.Secret, error) + type VaultClientConnector struct + func (v VaultClientConnector) Id() string + func (v VaultClientConnector) Load(schema interface{}) (interface{}, error) + func (v VaultClientConnector) Name() string + func (v VaultClientConnector) Schema() interface{} + func (v VaultClientConnector) Tags() []string + type VaultCredentials VaultSchema + type VaultRawConnector struct + func (v VaultRawConnector) Id() string + func (v VaultRawConnector) Load(schema interface{}) (interface{}, error) + func (v VaultRawConnector) Name() string + func (v VaultRawConnector) Schema() interface{} + func (v VaultRawConnector) Tags() []string + type VaultSchema struct + Endpoint string + OrgSecretPath string + RoleID string + SecretID string + ServiceSecretPath string + ServiceTransitPath string + SpaceSecretPath string
Go to main page