helpers

Documentation

Index

• Constants
• func AwaitResourceDeleted(check func() (interface{}, error), opts ...retry.Option) error
• func IsPodReady(pod coreApi.Pod) bool
• func LambdaInClusterEndpoint(name, namespace string, port int) string
• type CompassFixtures
  • func NewCompassFixtures() CompassFixtures
  • func (cf *CompassFixtures) FixDeleteRuntimeLabelRequest(runtimeID, labelKey string) *gcli.Request
  • func (cf *CompassFixtures) FixRegisterApplicationRequest(applicationInGQL string) *gcli.Request
  • func (cf *CompassFixtures) FixRequestOneTimeTokenForApplication(appID string) *gcli.Request
  • func (cf *CompassFixtures) FixRuntimeRequest(runtimeID string) *gcli.Request
  • func (cf *CompassFixtures) FixSetRuntimeLabelRequest(runtimeID, labelKey string, labelValue []string) *gcli.Request
  • func (cf *CompassFixtures) FixUnregisterApplicationRequest(applicationID string) *gcli.Request
• type DexSecret
• type LambdaHelper
  • func NewLambdaHelper(pods coreClient.PodInterface) *LambdaHelper
  • func (h *LambdaHelper) ListLambdaPods(name string) ([]coreApi.Pod, error)
• type SecretManager
• type SecretRepository
  • func NewSecretRepository(secretsManager SecretManager) SecretRepository

Constants

const (
	UserEmailKey    = "email"
	UserPasswordKey = "password"
)

Functions

func AwaitResourceDeleted

func AwaitResourceDeleted(check func() (interface{}, error), opts ...retry.Option) error

AwaitResourceDeleted retries until the resources cannot be found any more

func IsPodReady

func IsPodReady(pod coreApi.Pod) bool

IsPodReady checks whether the PodReady condition is true

func LambdaInClusterEndpoint

func LambdaInClusterEndpoint(name, namespace string, port int) string

Types

type CompassFixtures

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

func NewCompassFixtures

func NewCompassFixtures() CompassFixtures

func (*CompassFixtures) FixDeleteRuntimeLabelRequest

func (cf *CompassFixtures) FixDeleteRuntimeLabelRequest(runtimeID, labelKey string) *gcli.Request

func (*CompassFixtures) FixRegisterApplicationRequest

func (cf *CompassFixtures) FixRegisterApplicationRequest(applicationInGQL string) *gcli.Request

func (*CompassFixtures) FixRequestOneTimeTokenForApplication

func (cf *CompassFixtures) FixRequestOneTimeTokenForApplication(appID string) *gcli.Request

func (*CompassFixtures) FixRuntimeRequest

func (cf *CompassFixtures) FixRuntimeRequest(runtimeID string) *gcli.Request

func (*CompassFixtures) FixSetRuntimeLabelRequest

func (cf *CompassFixtures) FixSetRuntimeLabelRequest(runtimeID, labelKey string, labelValue []string) *gcli.Request

func (*CompassFixtures) FixUnregisterApplicationRequest

func (cf *CompassFixtures) FixUnregisterApplicationRequest(applicationID string) *gcli.Request

type DexSecret

type DexSecret struct {
	UserEmail    string
	UserPassword string
}

type LambdaHelper

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

LambdaHelper adds utilities to deal with lambdas

func NewLambdaHelper

func NewLambdaHelper(pods coreClient.PodInterface) *LambdaHelper

NewLambdaHelper returns new LambdaHelper

func (*LambdaHelper) ListLambdaPods

func (h *LambdaHelper) ListLambdaPods(name string) ([]coreApi.Pod, error)

ListLambdaPods returns all pods for lambda

type SecretManager

type SecretManager interface {
	Get(name string, options metav1.GetOptions) (*v1.Secret, error)
}

SecretManager contains operations for managing k8s secrets

type SecretRepository

type SecretRepository interface {
	Get(name string) (DexSecret, error)
}

SecretRepository contains operations for managing client credentials

func NewSecretRepository

func NewSecretRepository(secretsManager SecretManager) SecretRepository

NewSecretRepository creates a new secrets secretRepository