cetransformer

Documentation

Index

• func CompareErrors(t *testing.T, message string, actualError, wantedError error) bool
• func CompareEvents(t *testing.T, message string, actualEvent, wantedEvent cloudevents.Event) bool
• func CompareResponses(t *testing.T, message string, actualResponse, wantedResponse http.Response) bool
• func EventToMap(event *cloudevents.Event) map[string]interface{}
• func NewEventWithJSONStringData(jsonData string, st ...string) cloudevents.Event
• func NewEventWithMapData(payload map[string]interface{}, st ...string) cloudevents.Event
• func NewGETRequest(url string) *http.Request
• func NewReq(method string, header http.Header, url, body string) *http.Request
• func TransformBytesToEvent(eventMarshalled []byte, context cloudevents.EventContext) (*cloudevents.Event, error)
• func Unmarshal(source []byte, event *cloudevents.Event) error
• type CeClientMock
  • func (mm *CeClientMock) Request(ctx context.Context, event cloudevents.Event) (*cloudevents.Event, protocol.Result)
  • func (mm *CeClientMock) Send(ctx context.Context, event cloudevents.Event) protocol.Result
  • func (mm *CeClientMock) StartReceiver(ctx context.Context, fn interface{}) error
• type CloudEventTransformer
  • func NewCloudEventTransformer(ceTemplate, resultSource, resultType string, debug bool) (*CloudEventTransformer, error)
  • func (ct *CloudEventTransformer) CreateEvent(input interface{}) (*cloudevents.Event, error)
  • func (ct *CloudEventTransformer) PredicateEvent(sourceEvent *cloudevents.Event) (bool, error)
  • func (ct *CloudEventTransformer) TransformEvent(sourceEvent *cloudevents.Event) (*cloudevents.Event, error)

Functions

func CompareErrors

func CompareErrors(t *testing.T, message string, actualError, wantedError error) bool

CompareErrors true if events are "equal"

func CompareEvents

func CompareEvents(t *testing.T, message string, actualEvent, wantedEvent cloudevents.Event) bool

CompareEvents true if events are "equal"

func CompareResponses

func CompareResponses(t *testing.T, message string, actualResponse, wantedResponse http.Response) bool

CompareResponses true if events are "equal"

func EventToMap

func EventToMap(event *cloudevents.Event) map[string]interface{}

EventToMap Transform a cloudevent to input data

func NewEventWithJSONStringData

func NewEventWithJSONStringData(jsonData string, st ...string) cloudevents.Event

NewEventWithJSONStringData jsonDataString, source,type,id

func NewEventWithMapData

func NewEventWithMapData(payload map[string]interface{}, st ...string) cloudevents.Event

NewEventWithMapData payload, source,type,id

func NewGETRequest

func NewGETRequest(url string) *http.Request

NewGETRequest bla

func NewReq

func NewReq(method string, header http.Header, url, body string) *http.Request

NewReq bla

func TransformBytesToEvent

func TransformBytesToEvent(eventMarshalled []byte, context cloudevents.EventContext) (*cloudevents.Event, error)

TransformBytesToEvent bla

func Unmarshal

func Unmarshal(source []byte, event *cloudevents.Event) error

Unmarshal an json string to a cloudevent with data in a map

Types

type CeClientMock

type CeClientMock struct {
	T                       *testing.T
	WantSend                bool
	WantSendEvent           cloudevents.Event
	ShouldThrowErrorOnStart error
	ShouldThrowErrorOnSend  error
}

CeClientMock mock ce client

func (*CeClientMock) Request

func (mm *CeClientMock) Request(ctx context.Context, event cloudevents.Event) (*cloudevents.Event, protocol.Result)

Request bla

func (*CeClientMock) Send

func (mm *CeClientMock) Send(ctx context.Context, event cloudevents.Event) protocol.Result

Send bla

func (*CeClientMock) StartReceiver

func (mm *CeClientMock) StartReceiver(ctx context.Context, fn interface{}) error

StartReceiver bla

type CloudEventTransformer

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

CloudEventTransformer bla

func NewCloudEventTransformer

func NewCloudEventTransformer(ceTemplate, resultSource, resultType string, debug bool) (*CloudEventTransformer, error)

NewCloudEventTransformer new instance of CloudEventTransformer ceTemplate,source, type, debug

func (*CloudEventTransformer) CreateEvent

func (ct *CloudEventTransformer) CreateEvent(input interface{}) (*cloudevents.Event, error)

CreateEvent bla

func (*CloudEventTransformer) PredicateEvent

func (ct *CloudEventTransformer) PredicateEvent(sourceEvent *cloudevents.Event) (bool, error)

PredicateEvent bla

func (*CloudEventTransformer) TransformEvent

func (ct *CloudEventTransformer) TransformEvent(sourceEvent *cloudevents.Event) (*cloudevents.Event, error)

TransformEvent bla