messenger

package

v0.1.4 Latest Latest Go to latest Published: Nov 11, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/quebic-source/quebic

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const Exchange = "quebic-faas-eventbus"

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BaseEvent ¶

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

BaseEvent type

func (*BaseEvent) GetCreated ¶

func (baseEvent *BaseEvent) GetCreated() string

GetCreated get created

func (*BaseEvent) GetError ¶

func (baseEvent *BaseEvent) GetError() string

GetError get requestHeaders

func (*BaseEvent) GetEventID ¶

func (baseEvent *BaseEvent) GetEventID() string

GetEventID get eventID

func (*BaseEvent) GetHeaderData ¶

func (baseEvent *BaseEvent) GetHeaderData(key string) string

GetHeaderData get requestHeaders

func (*BaseEvent) GetHeaders ¶ added in v0.1.3

func (baseEvent *BaseEvent) GetHeaders() map[string]interface{}

GetHeaders get all headers

func (*BaseEvent) GetPayload ¶

func (baseEvent *BaseEvent) GetPayload() []byte

GetPayload get payload []byte

func (*BaseEvent) GetPayloadAsObject ¶

func (baseEvent *BaseEvent) GetPayloadAsObject() interface{}

GetPayloadAsObject get payloadObject as a perticular object

func (*BaseEvent) GetPayloadAsString ¶

func (baseEvent *BaseEvent) GetPayloadAsString() string

GetPayloadAsString get payload string

func (*BaseEvent) GetRequestID ¶

func (baseEvent *BaseEvent) GetRequestID() string

GetRequestID get requestID

func (*BaseEvent) GetStatuscode ¶

func (baseEvent *BaseEvent) GetStatuscode() int

GetStatuscode get requestHeaders

func (*BaseEvent) ParsePayloadAsObject ¶

func (baseEvent *BaseEvent) ParsePayloadAsObject(payloadObject interface{}) error

ParsePayloadAsObject parse to object you provided

type Context ¶ added in v0.1.2

type Context struct {
	RequestID string //self reuest-id
}

Context publish handler current context

type Messenger ¶

type Messenger struct {
	AppID          string
	EventBusConfig config.EventBusConfig
	// contains filtered or unexported fields
}

Messenger interface

func (*Messenger) Close ¶

func (messenger *Messenger) Close()

Close close connection

func (*Messenger) Init ¶

func (messenger *Messenger) Init() error

Init create connection

func (*Messenger) Publish ¶

func (messenger *Messenger) Publish(
	eventID string,
	payload interface{},
	requestHeaders map[string]interface{},
	successHandler func(message BaseEvent, statuscode int, context Context),
	errHandler func(err string, statuscode int, context Context),
	requestTimeout time.Duration) (string, error)

Publish publish

func (*Messenger) PublishBlocking ¶

func (messenger *Messenger) PublishBlocking(
	eventID string,
	payload interface{},
	requestHeaders map[string]interface{},
	successHandler func(message BaseEvent, statuscode int, context Context),
	errHandler func(err string, statuscode int, context Context),
	requestTimeout time.Duration) (string, error)

PublishBlocking publish and wait caller thread until responce came

func (*Messenger) ReleseQueue ¶

func (messenger *Messenger) ReleseQueue(routingKey string)

ReleseQueue release queue

func (*Messenger) ReplyError ¶

func (messenger *Messenger) ReplyError(requestBaseEvent BaseEvent, errMessage string, statuscode int) error

ReplyError reply error response

func (*Messenger) ReplySuccess ¶

func (messenger *Messenger) ReplySuccess(requestBaseEvent BaseEvent, replyPayload interface{}, statuscode int) error

ReplySuccess reply success response

func (messenger *Messenger) Subscribe(eventID string, requestHandler func(baseEvent BaseEvent), consumerName string) error

Subscribe subscribe

func (*Messenger) WaitInit ¶

func (messenger *Messenger) WaitInit(wait time.Duration) error

WaitInit create connection

Source Files ¶

View all Source files

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