clients

Sep 12, 2022

Changes in this version

type StorageClient

+ func (sc *StorageClient) BasePath() string

+ func (sc *StorageClient) Rename(fromRelativePath, toAbsolutePath string) bool

type StorageClientInterface

+ BasePath func() string

+ Rename func(fromRelativePath, toAbsolutePath string) bool

Jul 7, 2022

Changes in this version

type PrometheusClient

+ func (c PrometheusClient) Query(ctx context.Context, query string, moment time.Time) (model.Value, error)

Feb 7, 2022

Changes in this version

+ type Authenticator interface

+ Authenticate func(vc *VaultClient) error

+ func NewK8sAuthenticator() Authenticator

+ func NewLocalAuthenticator(token string) Authenticator

+ type K8sAuthenticator struct

+ func (a *K8sAuthenticator) Authenticate(vc *VaultClient) error

+ type LocalAuthenticator struct

+ func (a *LocalAuthenticator) Authenticate(vc *VaultClient) error

type VaultClient

+ func (vc *VaultClient) Delete(path string) error

+ func (vc *VaultClient) Get(path string) (map[string]interface{}, error)

+ func (vc *VaultClient) List(path string) (interface{}, error)

+ func (vc *VaultClient) Patch(path string, data map[string]interface{}) error

+ func (vc *VaultClient) Put(path string, data map[string]interface{}) error

Jan 27, 2022

Changes in this version

type RedisConfiguration

+ InsecureSkipVerify bool

Jan 20, 2022

Changes in this version

type RedisClient

+ Ping func(ctx context.Context) *redis.StatusCmd

Jan 17, 2022

Changes in this version

type RedisClient

+ Get func(ctx context.Context, key string) *redis.StringCmd

+ Publish func(ctx context.Context, channel string, message interface{}) *redis.IntCmd

+ Set func(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

+ Subscribe func(ctx context.Context, channels ...string) *redis.PubSub

Jan 17, 2022

Changes in this version

type RedisConfiguration

+ Cert string

+ CertKey string

+ MasterName string

Jan 17, 2022

Changes in this version

type RedisConfiguration

+ CACert string

Jan 13, 2022

Changes in this version

+ type RedisClient struct

+ func NewRedisClient(config RedisConfiguration, logger logging.Logger) RedisClient

+ type RedisConfiguration struct

+ Address string

+ func (c *RedisConfiguration) LoadFromEnvVars() error

Nov 18, 2021

Changes in this version

type VaultClientConfiguration

+ VaultURL string

Nov 17, 2021

Changes in this version

+ type PrometheusClient struct

+ func NewPrometheusClient(config PrometheusConfiguration, logger logging.Logger) PrometheusClient

+ func (c PrometheusClient) QueryRange(ctx context.Context, query string, startAt, endAt time.Time, ...) (model.Value, error)

+ type PrometheusConfiguration struct

+ Address string

+ func (c *PrometheusConfiguration) LoadFromEnvVars() error

+ type StorageClient struct

+ func NewStorageClient(logger logging.Logger, configuration StorageClientConfiguration) StorageClient

+ func (sc *StorageClient) CheckIfExists(relativePath string) bool

+ func (sc *StorageClient) CreateDirectory(relativePath string) error

+ func (sc *StorageClient) RemoveDirectory(relativePath string) error

+ type StorageClientConfiguration struct

+ BasePath string

+ func (c *StorageClientConfiguration) LoadFromEnvVars() error

+ type StorageClientInterface interface

+ CheckIfExists func(relativePath string) bool

+ CreateDirectory func(relativePath string) error

+ RemoveDirectory func(relativePath string) error

+ type VaultClient struct

+ func NewVaultClient(configuration VaultClientConfiguration, logger logging.Logger) (*VaultClient, error)

+ func (vc *VaultClient) CheckIfEngineExists() bool

+ func (vc *VaultClient) DeleteCredentials(datasourceName string) error

+ func (vc *VaultClient) GetCredentials(datasourceName string) (*config.Credentials, error)

+ func (vc *VaultClient) StoreCredentials(datasourceName string, credentials map[string]string) error

+ type VaultClientConfiguration struct

+ func (vlc *VaultClientConfiguration) LoadFromEnvVars() error