hsdp

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2022 License: MIT Imports: 26 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCartelClientConnector 

func NewCartelClientConnector() connectors.Connector

func NewCartelRawConnector 

func NewCartelRawConnector() connectors.Connector

func NewDynamoDBClientConnector 

func NewDynamoDBClientConnector() connectors.Connector

func NewDynamoDBRawConnector 

func NewDynamoDBRawConnector() connectors.Connector

func NewIronClientConnector 

func NewIronClientConnector() connectors.Connector

func NewIronRawConnector 

func NewIronRawConnector() connectors.Connector

func NewKafkaClientConnector added in v0.6.0 

func NewKafkaClientConnector() connectors.Connector

func NewKafkaRawConnector added in v0.3.0 

func NewKafkaRawConnector() connectors.Connector

func NewPostgresSQLClientConnector 

func NewPostgresSQLClientConnector() connectors.Connector

func NewPostgresSQLRawConnector 

func NewPostgresSQLRawConnector() connectors.Connector

func NewRedisConnector added in v0.7.0 

func NewRedisConnector() connectors.Connector

func NewRedshiftConnector 

func NewRedshiftConnector() connectors.Connector

func NewRedshiftRawConnector 

func NewRedshiftRawConnector() connectors.Connector

func NewS3ClientConnector 

func NewS3ClientConnector() connectors.Connector

func NewS3MinioClientConnector added in v0.3.0 

func NewS3MinioClientConnector() connectors.Connector

func NewS3RawConnector 

func NewS3RawConnector() connectors.Connector

func NewTwilioClientConnector 

func NewTwilioClientConnector() connectors.Connector

func NewTwilioRawConnector 

func NewTwilioRawConnector() connectors.Connector

func NewVaultClientConnector 

func NewVaultClientConnector() connectors.Connector

func NewVaultRawConnector 

func NewVaultRawConnector() connectors.Connector

Types

type CartelClient 

type CartelClient struct {
	cartel.Config
	*cartel.Client
}

type CartelClientConnector 

type CartelClientConnector struct {
	// contains filtered or unexported fields
}

func (CartelClientConnector) Id 

func (c CartelClientConnector) Id() string

func (CartelClientConnector) Load 

func (c CartelClientConnector) Load(schema interface{}) (interface{}, error)

func (CartelClientConnector) Name 

func (c CartelClientConnector) Name() string

func (CartelClientConnector) Schema 

func (c CartelClientConnector) Schema() interface{}

func (CartelClientConnector) Tags 

func (c CartelClientConnector) Tags() []string

type CartelConfig 

type CartelConfig cartel.Config

type CartelRawConnector 

type CartelRawConnector struct {
}

func (CartelRawConnector) Id 

func (c CartelRawConnector) Id() string

func (CartelRawConnector) Load 

func (c CartelRawConnector) Load(schema interface{}) (interface{}, error)

func (CartelRawConnector) Name 

func (c CartelRawConnector) Name() string

func (CartelRawConnector) Schema 

func (c CartelRawConnector) Schema() interface{}

func (CartelRawConnector) Tags 

func (c CartelRawConnector) Tags() []string

type DynamoDBClient 

type DynamoDBClient struct {
	*dynamodb.DynamoDB
	TableName string
}

type DynamoDBClientConnector 

type DynamoDBClientConnector struct {
	// contains filtered or unexported fields
}

func (DynamoDBClientConnector) Id 

func (c DynamoDBClientConnector) Id() string

func (DynamoDBClientConnector) Load 

func (c DynamoDBClientConnector) Load(schema interface{}) (interface{}, error)

func (DynamoDBClientConnector) Name 

func (c DynamoDBClientConnector) Name() string

func (DynamoDBClientConnector) Schema 

func (c DynamoDBClientConnector) Schema() interface{}

func (DynamoDBClientConnector) Tags 

func (c DynamoDBClientConnector) Tags() []string

type DynamoDBRawConnector 

type DynamoDBRawConnector struct{}

func (DynamoDBRawConnector) Id 

func (c DynamoDBRawConnector) Id() string

func (DynamoDBRawConnector) Load 

func (c DynamoDBRawConnector) Load(schema interface{}) (interface{}, error)

func (DynamoDBRawConnector) Name 

func (c DynamoDBRawConnector) Name() string

func (DynamoDBRawConnector) Schema 

func (c DynamoDBRawConnector) Schema() interface{}

func (DynamoDBRawConnector) Tags 

func (c DynamoDBRawConnector) Tags() []string

type DynamoDBSchema 

type DynamoDBSchema struct {
	AWSKey    string `cloud:"aws_key"`
	AWSRegion string `cloud:"aws_region"`
	AWSSecret string `cloud:"aws_secret"`
	TableName string `cloud:"table_name"`
}

type IronClient 

type IronClient struct {
	iron.Config
	*iron.Client
}

type IronClientConnector 

type IronClientConnector struct {
	// contains filtered or unexported fields
}

func (IronClientConnector) Id 

func (i IronClientConnector) Id() string

func (IronClientConnector) Load 

func (i IronClientConnector) Load(schema interface{}) (interface{}, error)

func (IronClientConnector) Name 

func (i IronClientConnector) Name() string

func (IronClientConnector) Schema 

func (i IronClientConnector) Schema() interface{}

func (IronClientConnector) Tags 

func (i IronClientConnector) Tags() []string

type IronPlan 

type IronPlan iron.Config

type IronRawConnector 

type IronRawConnector struct{}

func (IronRawConnector) Id 

func (i IronRawConnector) Id() string

func (IronRawConnector) Load 

func (i IronRawConnector) Load(schema interface{}) (interface{}, error)

func (IronRawConnector) Name 

func (i IronRawConnector) Name() string

func (IronRawConnector) Schema 

func (i IronRawConnector) Schema() interface{}

func (IronRawConnector) Tags 

func (i IronRawConnector) Tags() []string

type KafkaCredentials added in v0.3.0 

type KafkaCredentials KafkaSchema

func (KafkaCredentials) CACertificate added in v0.6.0 

func (k KafkaCredentials) CACertificate() (*x509.Certificate, error)

func (KafkaCredentials) PEMData added in v0.6.0 

func (k KafkaCredentials) PEMData() ([]byte, error)

type KafkaDialer added in v0.6.0 

type KafkaDialer struct {
	*kafka.Dialer
	KafkaCredentials
}

type KafkaDialerConnector added in v0.6.0 

type KafkaDialerConnector struct {
	// contains filtered or unexported fields
}

func (KafkaDialerConnector) Id added in v0.6.0 

func (k KafkaDialerConnector) Id() string

func (KafkaDialerConnector) Load added in v0.6.0 

func (k KafkaDialerConnector) Load(schema interface{}) (interface{}, error)

func (KafkaDialerConnector) Name added in v0.6.0 

func (k KafkaDialerConnector) Name() string

func (KafkaDialerConnector) Schema added in v0.6.0 

func (k KafkaDialerConnector) Schema() interface{}

func (KafkaDialerConnector) Tags added in v0.6.0 

func (k KafkaDialerConnector) Tags() []string

type KafkaRawConnector added in v0.3.0 

type KafkaRawConnector struct{}

func (KafkaRawConnector) Id added in v0.3.0 

func (r KafkaRawConnector) Id() string

func (KafkaRawConnector) Load added in v0.3.0 

func (r KafkaRawConnector) Load(schema interface{}) (interface{}, error)

func (KafkaRawConnector) Name added in v0.3.0 

func (r KafkaRawConnector) Name() string

func (KafkaRawConnector) Schema added in v0.3.0 

func (r KafkaRawConnector) Schema() interface{}

func (KafkaRawConnector) Tags added in v0.3.0 

func (r KafkaRawConnector) Tags() []string

type KafkaSchema added in v0.3.0 

type KafkaSchema struct {
	Username  string   `json:"username,omitempty"`
	Password  string   `json:"password,omitempty"`
	Hostname  string   `json:"hostname,omitempty"`
	Port      int      `json:"port,omitempty"`
	Hostnames []string `json:"hostnames"`
	URI       string   `json:"uri"`
	CACert    string   `json:"ca_cert,omitempty"`
}

type PostgreSQLClient 

type PostgreSQLClient struct {
	*sql.DB
}

type PostgreSQLClientConnector 

type PostgreSQLClientConnector struct {
	// contains filtered or unexported fields
}

func (PostgreSQLClientConnector) GetConnString 

func (c PostgreSQLClientConnector) GetConnString(schema PostgresSQLSchema) string

func (PostgreSQLClientConnector) Id 

func (c PostgreSQLClientConnector) Id() string

func (PostgreSQLClientConnector) Load 

func (c PostgreSQLClientConnector) Load(schema interface{}) (interface{}, error)

func (PostgreSQLClientConnector) Name 

func (c PostgreSQLClientConnector) Name() string

func (PostgreSQLClientConnector) Schema 

func (c PostgreSQLClientConnector) Schema() interface{}

func (PostgreSQLClientConnector) Tags 

func (c PostgreSQLClientConnector) Tags() []string

type PostgresSQLRawConnector 

type PostgresSQLRawConnector struct{}

func (PostgresSQLRawConnector) Id 

func (c PostgresSQLRawConnector) Id() string

func (PostgresSQLRawConnector) Load 

func (c PostgresSQLRawConnector) Load(schema interface{}) (interface{}, error)

func (PostgresSQLRawConnector) Name 

func (c PostgresSQLRawConnector) Name() string

func (PostgresSQLRawConnector) Schema 

func (c PostgresSQLRawConnector) Schema() interface{}

func (PostgresSQLRawConnector) Tags 

func (c PostgresSQLRawConnector) Tags() []string

type PostgresSQLSchema 

type PostgresSQLSchema struct {
	AutomatedSnapshotsPassword string `cloud:"automated_snapshots_password"`
	DBName                     string `cloud:"db_name"`
	Hostname                   string `cloud:"hostname"`
	Password                   string `cloud:"password"`
	Port                       int    `cloud:"port"`
	URI                        string `cloud:"uri"`
	Username                   string `cloud:"username"`
	Options                    string
}

type RedisConnector added in v0.7.0 

type RedisConnector struct {
}

func (RedisConnector) Id added in v0.7.0 

func (r RedisConnector) Id() string

func (RedisConnector) Load added in v0.7.0 

func (r RedisConnector) Load(schema interface{}) (interface{}, error)

func (RedisConnector) Name added in v0.7.0 

func (r RedisConnector) Name() string

func (RedisConnector) Schema added in v0.7.0 

func (r RedisConnector) Schema() interface{}

func (RedisConnector) Tags added in v0.7.0 

func (r RedisConnector) Tags() []string

type RedisCredentials added in v0.7.0 

type RedisCredentials struct {
	Hostname     string `json:"hostname"`
	MasterName   string `json:"master_name"`
	Password     string `json:"password"`
	Port         int    `json:"port"`
	SentinelPort int    `json:"sentinel_port"`
}

type RedisSchema added in v0.7.0 

type RedisSchema RedisCredentials

type RedshiftConnector 

type RedshiftConnector struct {
	// contains filtered or unexported fields
}

func (RedshiftConnector) GetConnString 

func (r RedshiftConnector) GetConnString(creds RedshiftCredentials) string

func (RedshiftConnector) Id 

func (r RedshiftConnector) Id() string

func (RedshiftConnector) Load 

func (r RedshiftConnector) Load(schema interface{}) (interface{}, error)

func (RedshiftConnector) Name 

func (r RedshiftConnector) Name() string

func (RedshiftConnector) Schema 

func (r RedshiftConnector) Schema() interface{}

func (RedshiftConnector) Tags 

func (r RedshiftConnector) Tags() []string

type RedshiftCredentials 

type RedshiftCredentials RedshiftSchema

type RedshiftRawConnector 

type RedshiftRawConnector struct{}

func (RedshiftRawConnector) Id 

func (r RedshiftRawConnector) Id() string

func (RedshiftRawConnector) Load 

func (r RedshiftRawConnector) Load(schema interface{}) (interface{}, error)

func (RedshiftRawConnector) Name 

func (r RedshiftRawConnector) Name() string

func (RedshiftRawConnector) Schema 

func (r RedshiftRawConnector) Schema() interface{}

func (RedshiftRawConnector) Tags 

func (r RedshiftRawConnector) Tags() []string

type RedshiftSchema 

type RedshiftSchema struct {
	DatabaseName string `cloud:"db_name"`
	Hostname     string `cloud:"hostname"`
	Username     string `cloud:"username"`
	Password     string `cloud:"password"`
	Port         int    `cloud:"port"`
	URI          string `cloud:"uri"`
	Options      string
}

type S3Client 

type S3Client struct {
	*s3.S3
	S3Credentials
}

type S3ClientConnector 

type S3ClientConnector struct {
	// contains filtered or unexported fields
}

func (S3ClientConnector) Id 

func (v S3ClientConnector) Id() string

func (S3ClientConnector) Load 

func (v S3ClientConnector) Load(schema interface{}) (interface{}, error)

func (S3ClientConnector) Name 

func (v S3ClientConnector) Name() string

func (S3ClientConnector) Schema 

func (v S3ClientConnector) Schema() interface{}

func (S3ClientConnector) Tags 

func (v S3ClientConnector) Tags() []string

type S3Credentials 

type S3Credentials S3Schema

type S3MinioClient added in v0.3.0 

type S3MinioClient struct {
	*minio.Client
	S3Credentials
}

type S3MinioClientConnector added in v0.3.0 

type S3MinioClientConnector struct {
	// contains filtered or unexported fields
}

func (S3MinioClientConnector) Id added in v0.3.0 

func (v S3MinioClientConnector) Id() string

func (S3MinioClientConnector) Load added in v0.3.0 

func (v S3MinioClientConnector) Load(schema interface{}) (interface{}, error)

func (S3MinioClientConnector) Name added in v0.3.0 

func (v S3MinioClientConnector) Name() string

func (S3MinioClientConnector) Schema added in v0.3.0 

func (v S3MinioClientConnector) Schema() interface{}

func (S3MinioClientConnector) Tags added in v0.3.0 

func (v S3MinioClientConnector) Tags() []string

type S3RawConnector 

type S3RawConnector struct{}

func (S3RawConnector) Id 

func (r S3RawConnector) Id() string

func (S3RawConnector) Load 

func (r S3RawConnector) Load(schema interface{}) (interface{}, error)

func (S3RawConnector) Name 

func (r S3RawConnector) Name() string

func (S3RawConnector) Schema 

func (r S3RawConnector) Schema() interface{}

func (S3RawConnector) Tags 

func (r S3RawConnector) Tags() []string

type S3Schema 

type S3Schema struct {
	APIKey             string      `json:"api_key"`
	Bucket             string      `json:"bucket"`
	Endpoint           string      `json:"endpoint"`
	LocationConstraint interface{} `json:"location_constraint"`
	SecretKey          string      `json:"secret_key"`
	URI                string      `json:"uri"`
}

type TwilioClientConnector 

type TwilioClientConnector struct {
	// contains filtered or unexported fields
}

func (TwilioClientConnector) Id 

func (c TwilioClientConnector) Id() string

func (TwilioClientConnector) Load 

func (c TwilioClientConnector) Load(schema interface{}) (interface{}, error)

func (TwilioClientConnector) Name 

func (c TwilioClientConnector) Name() string

func (TwilioClientConnector) Schema 

func (c TwilioClientConnector) Schema() interface{}

func (TwilioClientConnector) Tags 

func (c TwilioClientConnector) Tags() []string

type TwilioRawConnector 

type TwilioRawConnector struct{}

func (TwilioRawConnector) Id 

func (c TwilioRawConnector) Id() string

func (TwilioRawConnector) Load 

func (c TwilioRawConnector) Load(schema interface{}) (interface{}, error)

func (TwilioRawConnector) Name 

func (c TwilioRawConnector) Name() string

func (TwilioRawConnector) Schema 

func (c TwilioRawConnector) Schema() interface{}

func (TwilioRawConnector) Tags 

func (c TwilioRawConnector) Tags() []string

type TwilioSchema 

type TwilioSchema struct {
	TwilioAuthToken string `cloud:"twilio_auth_token"`
	TwilioSID       string `cloud:"twilio_sid"`
}

type TwilioSubAccount 

type TwilioSubAccount struct {
	SID       string
	AuthToken string
}

type VaultClient 

type VaultClient struct {
	*vault.Client
	VaultCredentials
}

func (*VaultClient) ReadServiceSecret 

func (v *VaultClient) ReadServiceSecret(path string) (*vault.Secret, error)

func (*VaultClient) ReadServiceTransit 

func (v *VaultClient) ReadServiceTransit(path string) (*vault.Secret, error)

func (*VaultClient) ReadSpaceSecret 

func (v *VaultClient) ReadSpaceSecret(path string) (*vault.Secret, error)

func (*VaultClient) WriteServiceSecret 

func (v *VaultClient) WriteServiceSecret(path string, data map[string]interface{}) (*vault.Secret, error)

func (*VaultClient) WriteServiceTransit 

func (v *VaultClient) WriteServiceTransit(path string, data map[string]interface{}) (*vault.Secret, error)

func (*VaultClient) WriteSpaceSecret 

func (v *VaultClient) WriteSpaceSecret(path string, data map[string]interface{}) (*vault.Secret, error)

type VaultClientConnector 

type VaultClientConnector struct {
	// contains filtered or unexported fields
}

func (VaultClientConnector) Id 

func (v VaultClientConnector) Id() string

func (VaultClientConnector) Load 

func (v VaultClientConnector) Load(schema interface{}) (interface{}, error)

func (VaultClientConnector) Name 

func (v VaultClientConnector) Name() string

func (VaultClientConnector) Schema 

func (v VaultClientConnector) Schema() interface{}

func (VaultClientConnector) Tags 

func (v VaultClientConnector) Tags() []string

type VaultCredentials 

type VaultCredentials VaultSchema

type VaultRawConnector 

type VaultRawConnector struct{}

func (VaultRawConnector) Id 

func (v VaultRawConnector) Id() string

func (VaultRawConnector) Load 

func (v VaultRawConnector) Load(schema interface{}) (interface{}, error)

func (VaultRawConnector) Name 

func (v VaultRawConnector) Name() string

func (VaultRawConnector) Schema 

func (v VaultRawConnector) Schema() interface{}

func (VaultRawConnector) Tags 

func (v VaultRawConnector) Tags() []string

type VaultSchema 

type VaultSchema struct {
	Endpoint           string `json:"endpoint"`
	OrgSecretPath      string `json:"org_secret_path"`
	RoleID             string `json:"role_id"`
	SecretID           string `json:"secret_id"`
	ServiceSecretPath  string `json:"service_secret_path"`
	ServiceTransitPath string `json:"service_transit_path"`
	SpaceSecretPath    string `json:"space_secret_path"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.