context

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 GetSecretFromCache(ctx Context, namespace, name, key 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 NewContext(baseCtx gocontext.Context, opts ...commons.ContextOptions) 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

Variables

var (
	ErrNotFound = errors.New("NOT_FOUND")
)

Functions

func FindConnection

func FindConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)

FindConnection returns the connection with the given type and name

func FindConnectionByURL

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

func GetConfigMapFromCache(ctx Context, namespace, name, key string) (string, error)

func GetConnection

func GetConnection(ctx Context, connectionType, name, namespace string) (*models.Connection, error)

func GetEnvStringFromCache

func GetEnvStringFromCache(ctx Context, env string, namespace string) (string, error)

func GetEnvValueFromCache

func GetEnvValueFromCache(ctx Context, input types.EnvVar, namespace string) (string, error)

func GetSecretFromCache

func GetSecretFromCache(ctx Context, namespace, name, key string) (string, error)

func HydrateConnection

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

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

func IsValidConnectionURL(connectionString string) bool

Types

type Context

type Context struct {
	commons.Context
}

func NewContext

func NewContext(baseCtx gocontext.Context, opts ...commons.ContextOptions) Context

func (Context) DB

func (k Context) DB() *gorm.DB

func (Context) GetAnnotations

func (k Context) GetAnnotations() map[string]string

func (Context) GetConfigMapFromCache

func (k Context) GetConfigMapFromCache(namespace, name, key string) (string, error)

func (Context) GetConnection

func (ctx Context) GetConnection(connectionType, name, namespace string) (*models.Connection, error)

func (Context) GetEnvStringFromCache

func (k Context) GetEnvStringFromCache(env string, namespace string) (string, error)

func (Context) GetEnvValueFromCache

func (k Context) GetEnvValueFromCache(input types.EnvVar, namespace ...string) (string, error)

func (Context) GetLabels

func (k Context) GetLabels() map[string]string

func (Context) GetName

func (k Context) GetName() string

func (Context) GetNamespace

func (k Context) GetNamespace() string

func (Context) GetObjectMeta

func (k Context) GetObjectMeta() metav1.ObjectMeta

func (Context) GetSecretFromCache

func (k Context) GetSecretFromCache(namespace, name, key string) (string, error)

func (Context) HydrateConnection

func (k Context) HydrateConnection(connection *models.Connection) (*models.Connection, error)

func (Context) HydrateConnectionByURL

func (k Context) HydrateConnectionByURL(connectionString string) (*models.Connection, error)

func (*Context) Kommons

func (k *Context) Kommons() *kommons.Client

func (*Context) Kubernetes

func (k *Context) Kubernetes() kubernetes.Interface

func (Context) Pool

func (k Context) Pool() *pgxpool.Pool

func (Context) StartSpan

func (k Context) StartSpan(name string) (Context, trace.Span)

func (Context) User

func (k Context) User() *models.Person

func (Context) WithDB

func (k Context) WithDB(db *gorm.DB, pool *pgxpool.Pool) Context

func (Context) WithKommons

func (k Context) WithKommons(client *kommons.Client) Context

func (Context) WithKubernetes

func (k Context) WithKubernetes(client kubernetes.Interface) Context

func (Context) WithNamespace

func (k Context) WithNamespace(namespace string) Context

func (Context) WithObject

func (k Context) WithObject(object metav1.ObjectMeta) Context

func (Context) WithTimeout

func (k Context) WithTimeout(timeout time.Duration) (Context, gocontext.CancelFunc)

func (Context) WithUser

func (k Context) WithUser(user *models.Person) Context

func (Context) Wrap

func (k Context) Wrap(ctx gocontext.Context) Context

type Gormable

type Gormable interface {
	DB() *gorm.DB
}

type Poolable

type Poolable interface {
	Pool() *pgxpool.Pool
}