framework

Documentation

Index

• func GetDateString(t time.Time) string
• type Framework
  • func New(kubeClient kubernetes.Interface, messengerClient cs.Interface, ...) *Framework
  • func (f *Framework) CreateNamespace() error
  • func (f *Framework) DeleteNamespace() error
  • func (f *Framework) EventuallyAPIServerReady(name string) GomegaAsyncAssertion
  • func (f *Framework) Invoke() *Invocation
  • func (f *Framework) Namespace() string
  • func (f *Framework) NewMessengerOptions(kubeConfigPath string, extraOptions *server.ExtraOptions) *server.MessengerOptions
  • func (f *Framework) StartAPIServerAndOperator(kubeConfigPath string, extraOptions *server.ExtraOptions)
• type Invocation
  • func (f *Invocation) App() string
  • func (f *Invocation) CreateMessage(obj *api.Message) (*api.Message, error)
  • func (f *Invocation) CreateMessagingService(obj *api.MessagingService) (*api.MessagingService, error)
  • func (f *Invocation) CreateSecret(obj *core.Secret) (*core.Secret, error)
  • func (f *Invocation) DeleteAllCRDs() error
  • func (f *Invocation) DeleteAllSecrets() error
  • func (f *Invocation) EventuallyCheckMessage(msgBoby, timeBeforeSend, authTokenToSeeHistory string) GomegaAsyncAssertion
  • func (f *Invocation) NewMessage(genName, namespace string, labels map[string]string, ...) *api.Message
  • func (f *Invocation) NewMessagingService(name, namespace string, labels map[string]string, drive, secret string, ...) *api.MessagingService
  • func (f *Invocation) NewSecret(name, namespace, authTokenToSendMessage string, labels map[string]string) *core.Secret

Functions

func GetDateString

func GetDateString(t time.Time) string

Types

type Framework

type Framework struct {
	KubeClient      kubernetes.Interface
	MessengerClient cs.Interface
	CRDClient       crd_cs.ApiextensionsV1beta1Interface
	KAClient        ka.Interface

	WebhookEnabled bool

	ClientConfig *rest.Config
	// contains filtered or unexported fields
}

func New

func New(
	kubeClient kubernetes.Interface,
	messengerClient cs.Interface,
	crdClient crd_cs.ApiextensionsV1beta1Interface,
	kaClient ka.Interface,
	webhookEnabled bool,
	clientConfig *rest.Config) *Framework

func (*Framework) CreateNamespace

func (f *Framework) CreateNamespace() error

func (*Framework) DeleteNamespace

func (f *Framework) DeleteNamespace() error

func (*Framework) EventuallyAPIServerReady

func (f *Framework) EventuallyAPIServerReady(name string) GomegaAsyncAssertion

func (*Framework) Invoke

func (f *Framework) Invoke() *Invocation

func (*Framework) Namespace

func (f *Framework) Namespace() string

func (*Framework) NewMessengerOptions

func (f *Framework) NewMessengerOptions(kubeConfigPath string, extraOptions *server.ExtraOptions) *server.MessengerOptions

func (*Framework) StartAPIServerAndOperator

func (f *Framework) StartAPIServerAndOperator(kubeConfigPath string, extraOptions *server.ExtraOptions)

type Invocation

type Invocation struct {
	*Framework
	// contains filtered or unexported fields
}

func (*Invocation) App

func (f *Invocation) App() string

func (*Invocation) CreateMessage

func (f *Invocation) CreateMessage(obj *api.Message) (*api.Message, error)

func (*Invocation) CreateMessagingService

func (f *Invocation) CreateMessagingService(obj *api.MessagingService) (*api.MessagingService, error)

func (*Invocation) CreateSecret

func (f *Invocation) CreateSecret(obj *core.Secret) (*core.Secret, error)

func (*Invocation) DeleteAllCRDs

func (f *Invocation) DeleteAllCRDs() error

func (*Invocation) DeleteAllSecrets

func (f *Invocation) DeleteAllSecrets() error

func (*Invocation) EventuallyCheckMessage

func (f *Invocation) EventuallyCheckMessage(msgBoby, timeBeforeSend, authTokenToSeeHistory string) GomegaAsyncAssertion

func (*Invocation) NewMessage

func (f *Invocation) NewMessage(
	genName, namespace string, labels map[string]string,
	service, message, chat, email, sms string) *api.Message

func (*Invocation) NewMessagingService

func (f *Invocation) NewMessagingService(
	name, namespace string, labels map[string]string,
	drive, secret string, to []string) *api.MessagingService

func (*Invocation) NewSecret

func (f *Invocation) NewSecret(name, namespace, authTokenToSendMessage string, labels map[string]string) *core.Secret