sdk

Documentation

Index

• Variables
• func ConsumePublish(eventTypeFrom string, amqpUrl string, postUrl, postPort string, ...) error
• func PublishRabbitmqNextStep(amqpUrl string, myName string, event cloudevents.Event) error
• type AcknowledgeValues
• type CleanupFcnType
• type RejectValues

Variables

var CleanupArg interface{}

var RequesterName string = "UKNOWN"

var RunWithDebug bool = false

var AmqpUrl = "amqp://guest:guest@localhost:5672/" var PostUrl = "http://localhost"

Functions

func ConsumePublish

func ConsumePublish(eventTypeFrom string, amqpUrl string, postUrl, postPort string, listenerPort string) error

func PublishRabbitmqNextStep

func PublishRabbitmqNextStep(amqpUrl string, myName string, event cloudevents.Event) error

Types

type AcknowledgeValues

type AcknowledgeValues struct {
	Identifier string
}

type CleanupFcnType

type CleanupFcnType func(f interface{}) error

var CleanupFcn CleanupFcnType

type RejectValues

type RejectValues struct {
	Identifier string
}