test

package

v0.14.0 Latest Latest Go to latest Published: May 8, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kyma-incubator/knative-kafka

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CreateChannelReference(name string, namespace string) eventingChannel.ChannelReference
func CreateCloudEvent(cloudEventVersion string) *event.Event
func CreateKafkaChannel(name string, namespace string, ready corev1.ConditionStatus) *kafkav1alpha1.KafkaChannel
func ValidateKafkaMessageHeader(t *testing.T, headers []kafka.Header, headerKey string, headerValue string)
type MockKafkaChannelLister
- func NewMockKafkaChannelLister(name string, namespace string, exists bool, ready corev1.ConditionStatus, ...) MockKafkaChannelLister
- func (m MockKafkaChannelLister) KafkaChannels(namespace string) kafkalisters.KafkaChannelNamespaceLister
- func (m MockKafkaChannelLister) List(selector labels.Selector) (ret []*kafkav1alpha1.KafkaChannel, err error)
type MockKafkaChannelNamespaceLister
- func NewMockKafkaChannelNamespaceLister(name string, namespace string, exists bool, ready corev1.ConditionStatus, ...) MockKafkaChannelNamespaceLister
- func (m MockKafkaChannelNamespaceLister) Get(name string) (*kafkav1alpha1.KafkaChannel, error)
- func (m MockKafkaChannelNamespaceLister) List(selector labels.Selector) (ret []*kafkav1alpha1.KafkaChannel, err error)
type MockProducer
- func NewMockProducer(topicName string) *MockProducer

Constants ¶

View Source

const (
	ChannelName      = "TestChannelName"
	ChannelNamespace = "TestChannelNamespace"

	TopicName = "TestChannelNamespace.TestChannelName" // Match util.go TopicName() Implementation For Channel Name/Namespace Abovce

	PartitionKey         = "TestPartitionKey"
	EventVersion         = cloudevents.VersionV1
	EventId              = "TestEventId"
	EventType            = "com.cloudevents.readme.sent"
	EventSource          = "http://localhost:8080/"
	EventDataContentType = "application/json"
	EventSubject         = "TestEventSubject"
	EventDataSchema      = "TestEventDataSchema"
	EventDataKey         = "TestEventDataKey"
	EventDataValue       = "TestEventDataValue"
)

Test Data

Variables ¶

View Source

var EventDataJson, _ = json.Marshal(map[string]string{EventDataKey: EventDataValue})

Test Data

Functions ¶

func CreateChannelReference ¶

func CreateChannelReference(name string, namespace string) eventingChannel.ChannelReference

Utility Function For Creating A Test ChannelReference (Knative)

func CreateCloudEvent ¶

func CreateCloudEvent(cloudEventVersion string) *event.Event

Utility Function For Creating A Test CloudEvent

func CreateKafkaChannel ¶

func CreateKafkaChannel(name string, namespace string, ready corev1.ConditionStatus) *kafkav1alpha1.KafkaChannel

Utility Function For Creating A Test KafkaChannel (Knative-Kafka)

func ValidateKafkaMessageHeader ¶

func ValidateKafkaMessageHeader(t *testing.T, headers []kafka.Header, headerKey string, headerValue string)

Utility Function For Validating A Kafka Message Header

Types ¶

type MockKafkaChannelLister ¶

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

func NewMockKafkaChannelLister ¶

func NewMockKafkaChannelLister(name string, namespace string, exists bool, ready corev1.ConditionStatus, err bool) MockKafkaChannelLister

func (MockKafkaChannelLister) KafkaChannels ¶

func (m MockKafkaChannelLister) KafkaChannels(namespace string) kafkalisters.KafkaChannelNamespaceLister

func (MockKafkaChannelLister) List ¶

func (m MockKafkaChannelLister) List(selector labels.Selector) (ret []*kafkav1alpha1.KafkaChannel, err error)

type MockKafkaChannelNamespaceLister ¶

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

func NewMockKafkaChannelNamespaceLister ¶

func NewMockKafkaChannelNamespaceLister(name string, namespace string, exists bool, ready corev1.ConditionStatus, err bool) MockKafkaChannelNamespaceLister

func (MockKafkaChannelNamespaceLister) Get ¶

func (m MockKafkaChannelNamespaceLister) Get(name string) (*kafkav1alpha1.KafkaChannel, error)

func (MockKafkaChannelNamespaceLister) List ¶

func (m MockKafkaChannelNamespaceLister) List(selector labels.Selector) (ret []*kafkav1alpha1.KafkaChannel, err error)

type MockProducer ¶

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

func NewMockProducer ¶

func NewMockProducer(topicName string) *MockProducer

func (*MockProducer) Close ¶

func (p *MockProducer) Close()

func (*MockProducer) Closed ¶

func (p *MockProducer) Closed() bool

func (*MockProducer) Events ¶

func (p *MockProducer) Events() chan kafka.Event

func (*MockProducer) Flush ¶

func (p *MockProducer) Flush(timeoutMs int) int

func (*MockProducer) Len ¶

func (p *MockProducer) Len() int

func (*MockProducer) Produce ¶

func (p *MockProducer) Produce(msg *kafka.Message, deliveryChan chan kafka.Event) error

func (*MockProducer) ProduceChannel ¶

func (p *MockProducer) ProduceChannel() chan *kafka.Message

func (*MockProducer) String ¶

func (p *MockProducer) String() string

String returns a human readable name for a Producer instance

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL