Documentation ¶
Index ¶
- Constants
- type BaseEvent
- func (baseEvent *BaseEvent) GetCreated() string
- func (baseEvent *BaseEvent) GetError() string
- func (baseEvent *BaseEvent) GetEventID() string
- func (baseEvent *BaseEvent) GetHeaderData(key string) string
- func (baseEvent *BaseEvent) GetHeaders() map[string]interface{}
- func (baseEvent *BaseEvent) GetPayload() []byte
- func (baseEvent *BaseEvent) GetPayloadAsObject() interface{}
- func (baseEvent *BaseEvent) GetPayloadAsString() string
- func (baseEvent *BaseEvent) GetRequestID() string
- func (baseEvent *BaseEvent) GetStatuscode() int
- func (baseEvent *BaseEvent) ParsePayloadAsObject(payloadObject interface{}) error
- type Context
- type Messenger
- func (messenger *Messenger) Close()
- func (messenger *Messenger) Init() error
- func (messenger *Messenger) Publish(eventID string, payload interface{}, requestHeaders map[string]interface{}, ...) (string, error)
- func (messenger *Messenger) PublishBlocking(eventID string, payload interface{}, requestHeaders map[string]interface{}, ...) (string, error)
- func (messenger *Messenger) ReleseQueue(routingKey string)
- func (messenger *Messenger) ReplyError(requestBaseEvent BaseEvent, errMessage string, statuscode int) error
- func (messenger *Messenger) ReplySuccess(requestBaseEvent BaseEvent, replyPayload interface{}, statuscode int) error
- func (messenger *Messenger) Subscribe(eventID string, requestHandler func(baseEvent BaseEvent), consumerName string) error
- func (messenger *Messenger) WaitInit(wait time.Duration) error
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 ¶
GetCreated get created
func (*BaseEvent) GetEventID ¶
GetEventID get eventID
func (*BaseEvent) GetHeaderData ¶
GetHeaderData get requestHeaders
func (*BaseEvent) GetHeaders ¶ added in v0.1.3
GetHeaders get all headers
func (*BaseEvent) GetPayload ¶
GetPayload get payload []byte
func (*BaseEvent) GetPayloadAsObject ¶
func (baseEvent *BaseEvent) GetPayloadAsObject() interface{}
GetPayloadAsObject get payloadObject as a perticular object
func (*BaseEvent) GetPayloadAsString ¶
GetPayloadAsString get payload string
func (*BaseEvent) GetRequestID ¶
GetRequestID get requestID
func (*BaseEvent) GetStatuscode ¶
GetStatuscode get requestHeaders
func (*BaseEvent) ParsePayloadAsObject ¶
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) 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 ¶
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
Click to show internal directories.
Click to hide internal directories.