Documentation
¶
Index ¶
- Variables
- func FindConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)
- func FindConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)
- func GetConfigMapFromCache(ctx Context, namespace, name, key string) (string, error)
- func GetConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)
- func GetEnvStringFromCache(ctx Context, env string, namespace string) (string, error)
- func GetEnvValueFromCache(ctx Context, input types.EnvVar, namespace string) (string, error)
- func GetHelmValueFromCache(ctx Context, namespace, releaseName, key string) (string, error)
- func GetSecretFromCache(ctx Context, namespace, name, key string) (string, error)
- func GetServiceAccountTokenFromCache(ctx Context, namespace, serviceAccount string) (string, error)
- func HydrateConnection(ctx Context, connection *models.Connection) (*models.Connection, error)
- func HydrateConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)
- func IsValidConnectionURL(connectionString string) bool
- type Context
- func (k Context) DB() *gorm.DB
- func (k Context) GetAnnotations() map[string]string
- func (k Context) GetConfigMapFromCache(namespace, name, key string) (string, error)
- func (ctx Context) GetConnection(connectionType, name, namespace string) (*models.Connection, error)
- func (k Context) GetEnvStringFromCache(env string, namespace string) (string, error)
- func (k Context) GetEnvValueFromCache(input types.EnvVar, namespace ...string) (string, error)
- func (k Context) GetLabels() map[string]string
- func (k Context) GetName() string
- func (k Context) GetNamespace() string
- func (k Context) GetObjectMeta() metav1.ObjectMeta
- func (k Context) GetSecretFromCache(namespace, name, key string) (string, error)
- func (k Context) HydrateConnection(connection *models.Connection) (*models.Connection, error)
- func (k Context) HydrateConnectionByURL(connectionString string) (*models.Connection, error)
- func (k *Context) Kommons() *kommons.Client
- func (k *Context) Kubernetes() kubernetes.Interface
- func (k Context) Pool() *pgxpool.Pool
- func (k Context) StartSpan(name string) (Context, trace.Span)
- func (k Context) User() *models.Person
- func (k Context) WithDB(db *gorm.DB, pool *pgxpool.Pool) Context
- func (k Context) WithKommons(client *kommons.Client) Context
- func (k Context) WithKubernetes(client kubernetes.Interface) Context
- func (k Context) WithNamespace(namespace string) Context
- func (k Context) WithObject(object metav1.ObjectMeta) Context
- func (k Context) WithTimeout(timeout time.Duration) (Context, gocontext.CancelFunc)
- func (k Context) WithUser(user *models.Person) Context
- func (k Context) Wrap(ctx gocontext.Context) Context
- type Gormable
- type Poolable
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrNotFound = errors.New("NOT_FOUND")
)
Functions ¶
func FindConnection ¶ added in v1.0.207
func FindConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)
FindConnection returns the connection with the given type and name
func FindConnectionByURL ¶ added in v1.0.207
func FindConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)
FindConnectionByURL retrieves a connection from the given connection string. The connection string is expected to be of the form: connection://<type>/<name>
func GetConfigMapFromCache ¶ added in v1.0.207
func GetConnection ¶ added in v1.0.207
func GetConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)
func GetEnvStringFromCache ¶ added in v1.0.207
func GetEnvValueFromCache ¶ added in v1.0.207
func GetHelmValueFromCache ¶ added in v1.0.239
func GetSecretFromCache ¶ added in v1.0.207
func GetServiceAccountTokenFromCache ¶ added in v1.0.233
func HydrateConnection ¶ added in v1.0.207
func HydrateConnection(ctx Context, connection *models.Connection) (*models.Connection, error)
Create a cache with a default expiration time of 5 minutes, and which purges expired items every 10 minutes var connectionCache = cache.New(5*time.Minute, 10*time.Minute)
func HydrateConnectionByURL ¶ added in v1.0.216
func HydrateConnectionByURL(ctx Context, connectionString string) (*models.Connection, error)
HydrateConnectionByURL retrieves a connection from the given connection string. The connection string is expected to be in one of the following forms:
- connection://<type>/<name> or connection://<type>/<namespace>/<name>
- the UUID of the connection.
func IsValidConnectionURL ¶ added in v1.0.207
Types ¶
type Context ¶
func NewContext ¶
func NewContext(baseCtx gocontext.Context, opts ...commons.ContextOptions) Context
func (Context) GetAnnotations ¶
func (Context) GetConfigMapFromCache ¶
func (Context) GetConnection ¶ added in v1.0.207
func (ctx Context) GetConnection(connectionType, name, namespace string) (*models.Connection, error)
func (Context) GetEnvStringFromCache ¶
func (Context) GetEnvValueFromCache ¶
func (Context) GetNamespace ¶
func (Context) GetObjectMeta ¶
func (k Context) GetObjectMeta() metav1.ObjectMeta
func (Context) GetSecretFromCache ¶
func (Context) HydrateConnection ¶
func (k Context) HydrateConnection(connection *models.Connection) (*models.Connection, error)
func (Context) HydrateConnectionByURL ¶ added in v1.0.216
func (k Context) HydrateConnectionByURL(connectionString string) (*models.Connection, error)
func (*Context) Kubernetes ¶
func (k *Context) Kubernetes() kubernetes.Interface
func (Context) WithKommons ¶ added in v1.0.202
func (Context) WithKubernetes ¶
func (k Context) WithKubernetes(client kubernetes.Interface) Context
func (Context) WithNamespace ¶ added in v1.0.197
func (Context) WithObject ¶
func (k Context) WithObject(object metav1.ObjectMeta) Context
func (Context) WithTimeout ¶ added in v1.0.197
Source Files
Click to show internal directories.
Click to hide internal directories.