tests

package

v0.4.0 Latest Latest Go to latest Published: Aug 18, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Details

This section is empty.

View Source

var ErrCantStartCloudEventsServer = errors.New("can't start cloutevents server")

ErrCantStartCloudEventsServer if test cloud event server can't start.

View Source

var ErrCantUnmarshalData = errors.New("can't unmarshal data")

ErrCantUnmarshalData if given bytes can't be unmarshalled as JSON.

func UnmarshalCloudEventData(bytes []byte) (map[string]interface{}, error)

UnmarshalCloudEventData will take bytes and unmarshall it as JSON to map structure.

func WithCloudEventsServer(test func(serverURL url.URL) error) (*cloudevents.Event, error)

WithCloudEventsServer is a testing utility that help by starting a CloudEvents HTTP server which can catch a sent event.

func WithEnviron(env map[string]string, body func() error) error

WithEnviron will execute a block of code with temporal environment set.

type FakeClients struct {
	testing.TB
	Objects []runtime.Object
	// contains filtered or unexported fields
}

FakeClients creates K8s clients from a list of objects using fake packages.

func (c *FakeClients) Context() context.Context

func (c *FakeClients) Dynamic() dynamic.Interface

func (c *FakeClients) Eventing() eventingv1client.EventingV1Interface

func (c *FakeClients) Messaging() messagingv1client.MessagingV1Interface

func (c *FakeClients) Namespace() string

func (c *FakeClients) Serving() servingv1client.ServingV1Interface

func (c *FakeClients) Typed() kubernetes.Interface

type Sender struct {
	Sent []cloudevents.Event
}

Sender is a mock sender that will record sent events for testing.

func (m *Sender) Send(ce cloudevents.Event) error

Send will send event to specified target.