context

Documentation

Index

• type Context
  • func New(client *kommons.Client, kubernetes kubernetes.Interface, db *gorm.DB, ...) *Context
  • func (ctx *Context) DB() *gorm.DB
  • func (ctx *Context) Debugf(format string, args ...interface{})
  • func (ctx Context) GetAuthValues(auth v1.Authentication) (v1.Authentication, error)
  • func (ctx *Context) GetConnection(conn v1.Connection) (*models.Connection, error)
  • func (ctx *Context) GetEnvValueFromCache(env types.EnvVar) (string, error)
  • func (ctx *Context) HydrateConnectionByURL(connectionName string) (*models.Connection, error)
  • func (ctx *Context) IsDebug() bool
  • func (ctx *Context) IsTrace() bool
  • func (ctx *Context) New(environment map[string]interface{}) *Context
  • func (ctx *Context) String() string
  • func (ctx *Context) Tracef(format string, args ...interface{})
  • func (ctx *Context) WithDeadline(deadline time.Time) (*Context, gocontext.CancelFunc)
  • func (ctx *Context) WithTimeout(timeout time.Duration) (*Context, gocontext.CancelFunc)
• type KubernetesContext
  • func NewKubernetesContext(client *kommons.Client, kubernetes kubernetes.Interface, namespace string) *KubernetesContext
  • func (ctx *KubernetesContext) Clone() *KubernetesContext

Types

type Context

type Context struct {
	gocontext.Context
	Kubernetes  kubernetes.Interface
	Kommons     *kommons.Client
	Namespace   string
	Canary      v1.Canary
	Environment map[string]interface{}
	logger.Logger
	// contains filtered or unexported fields
}

func New

func New(client *kommons.Client, kubernetes kubernetes.Interface, db *gorm.DB, canary v1.Canary) *Context

func (*Context) DB

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

func (*Context) Debugf

func (ctx *Context) Debugf(format string, args ...interface{})

func (Context) GetAuthValues

func (ctx Context) GetAuthValues(auth v1.Authentication) (v1.Authentication, error)

func (*Context) GetConnection

func (ctx *Context) GetConnection(conn v1.Connection) (*models.Connection, error)

func (*Context) GetEnvValueFromCache

func (ctx *Context) GetEnvValueFromCache(env types.EnvVar) (string, error)

func (*Context) HydrateConnectionByURL

func (ctx *Context) HydrateConnectionByURL(connectionName string) (*models.Connection, error)

func (*Context) IsDebug

func (ctx *Context) IsDebug() bool

func (*Context) IsTrace

func (ctx *Context) IsTrace() bool

func (*Context) New

func (ctx *Context) New(environment map[string]interface{}) *Context

func (*Context) String

func (ctx *Context) String() string

func (*Context) Tracef

func (ctx *Context) Tracef(format string, args ...interface{})

func (*Context) WithDeadline

func (ctx *Context) WithDeadline(deadline time.Time) (*Context, gocontext.CancelFunc)

func (*Context) WithTimeout

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

type KubernetesContext

type KubernetesContext struct {
	gocontext.Context
	Kommons     *kommons.Client
	Kubernetes  kubernetes.Interface
	Namespace   string
	Environment map[string]interface{}
	logger.Logger
}

func NewKubernetesContext

func NewKubernetesContext(client *kommons.Client, kubernetes kubernetes.Interface, namespace string) *KubernetesContext

func (*KubernetesContext) Clone

func (ctx *KubernetesContext) Clone() *KubernetesContext