Documentation ¶
Index ¶
- Constants
- func ValidateConnectionKeyVal(values ConnectionMap) error
- type Config
- type ConnectionMap
- type Zipkin
- func (controller *Zipkin) AfterConsumeSpan(message *types.Message)
- func (controller *Zipkin) AfterPublishSpan(message *types.Message)
- func (controller *Zipkin) BeforeConsume(next middleware.BeforeConsumeHandlerFunc) middleware.BeforeConsumeHandlerFunc
- func (controller *Zipkin) BeforeProduce(next middleware.BeforeProduceHandlerFunc) middleware.BeforeProduceHandlerFunc
- func (controller *Zipkin) Close() error
- func (controller *Zipkin) NewConsumeSpan(message *types.Message)
- func (controller *Zipkin) NewProduceSpan(message *types.Message)
Constants ¶
const ( ZipkinHost = "host" ServiceName = "name" )
These const's contain the connection string keys to different values
const ( ActionTag = "commander.message.action" VersionTag = "commander.message.version" )
Zipkin span tags
Variables ¶
This section is empty.
Functions ¶
func ValidateConnectionKeyVal ¶
func ValidateConnectionKeyVal(values ConnectionMap) error
ValidateConnectionKeyVal validates if all required valyues are set in the given connectionmap
Types ¶
type Config ¶
Config contains all the plausible configuration options
func NewConfig ¶
func NewConfig(values ConnectionMap) (Config, error)
NewConfig constructs a Config from the given connection map
type ConnectionMap ¶
ConnectionMap contains the connectionstring as a key/value map
func ParseConnectionstring ¶
func ParseConnectionstring(connectionstring string) ConnectionMap
ParseConnectionstring parses the given connectionstring and returns a map with all key/values
type Zipkin ¶
Zipkin represents a Zipkin middleware instance
func (*Zipkin) AfterConsumeSpan ¶ added in v0.6.0
AfterConsumeSpan finishes the stored span in the message context
func (*Zipkin) AfterPublishSpan ¶ added in v0.6.0
AfterPublishSpan closes the producing span
func (*Zipkin) BeforeConsume ¶
func (controller *Zipkin) BeforeConsume(next middleware.BeforeConsumeHandlerFunc) middleware.BeforeConsumeHandlerFunc
BeforeConsume middleware controller
func (*Zipkin) BeforeProduce ¶ added in v0.6.0
func (controller *Zipkin) BeforeProduce(next middleware.BeforeProduceHandlerFunc) middleware.BeforeProduceHandlerFunc
BeforeProduce middleware controller
func (*Zipkin) NewConsumeSpan ¶ added in v0.6.0
NewConsumeSpan starts a new span and stores it in the message context
func (*Zipkin) NewProduceSpan ¶ added in v0.6.0
NewProduceSpan prepares the given message span headers