Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChanLogger ¶
type ChanLogger struct {
// contains filtered or unexported fields
}
func NewChanLogger ¶
func NewChanLogger(rc chan<- Request) ChanLogger
func (ChanLogger) Record ¶
func (s ChanLogger) Record(r Request)
type RouteLogger ¶
type RouteLogger struct {
// contains filtered or unexported fields
}
RouteLogger is a struct to enable being notified when an request identified by a key has been received by the It satisfies the Logger interface
func NewRouteLogger ¶
func NewRouteLogger(key func(Request) string) *RouteLogger
NewRouteLogger takes a key function which can generate a string key based upon the given Request. This key will be used to notify goroutines blocked on RouteLogger.Wait.
func (*RouteLogger) Delete ¶
func (s *RouteLogger) Delete(key string)
Delete must be called after any successful call to Sent to free allocated resources. Not doing so results in a leak.
func (*RouteLogger) Record ¶
func (s *RouteLogger) Record(r Request)
func (*RouteLogger) Sent ¶
func (s *RouteLogger) Sent(key string) error
Sent prepares RouteLogger to be able to handle the incoming request Sent returns an error if the key already exists in the map. Keys must be unique
type Subscriber ¶
type Subscriber struct {
RouteLogger *RouteLogger
// contains filtered or unexported fields
}
Subscriber is a subscriber that listen events from a webhook set at the end of the pipeline.
func (*Subscriber) Subscribe ¶
func (s *Subscriber) Subscribe(keys ...string) error
Subscribe subscribes to the given keys. It satisfies the e2e.Subscriber interface. Keys should be an event messageId.
func (*Subscriber) Unsubscribe ¶
func (s *Subscriber) Unsubscribe(keys ...string)
Unsubscribe satisfies the e2e.Subscriber interface.
Source Files