zipkin

Documentation

Index

• Constants
• func ValidateConnectionKeyVal(values ConnectionMap) error
• type Config
  • func NewConfig(values ConnectionMap) (Config, error)
• type ConnectionMap
  • func ParseConnectionstring(connectionstring string) ConnectionMap
• type Zipkin
  • func New(connectionstring string) (*Zipkin, error)
  • 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

Functions

func ValidateConnectionKeyVal

func ValidateConnectionKeyVal(values ConnectionMap) error

ValidateConnectionKeyVal validates if all required valyues are set in the given connectionmap

Types

type Config

type Config struct {
	ZipkinHost  string
	ServiceName string
}

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

type ConnectionMap map[string]string

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

type Zipkin struct {
	Reporter reporter.Reporter
	Tracer   *zipkin.Tracer
	Config   Config
}

Zipkin represents a Zipkin middleware instance

func New

func New(connectionstring string) (*Zipkin, error)

New initializes a new Zipkin commander middleware reporter

func (*Zipkin) AfterConsumeSpan

func (controller *Zipkin) AfterConsumeSpan(message *types.Message)

AfterConsumeSpan finishes the stored span in the message context

func (*Zipkin) AfterPublishSpan

func (controller *Zipkin) AfterPublishSpan(message *types.Message)

AfterPublishSpan closes the producing span

func (*Zipkin) BeforeConsume

func (controller *Zipkin) BeforeConsume(next middleware.BeforeConsumeHandlerFunc) middleware.BeforeConsumeHandlerFunc

BeforeConsume middleware controller

func (*Zipkin) BeforeProduce

func (controller *Zipkin) BeforeProduce(next middleware.BeforeProduceHandlerFunc) middleware.BeforeProduceHandlerFunc

BeforeProduce middleware controller

func (*Zipkin) Close

func (controller *Zipkin) Close() error

Close closes the Zipkin reporter

func (*Zipkin) NewConsumeSpan

func (controller *Zipkin) NewConsumeSpan(message *types.Message)

NewConsumeSpan starts a new span and stores it in the message context

func (*Zipkin) NewProduceSpan

func (controller *Zipkin) NewProduceSpan(message *types.Message)

NewProduceSpan prepares the given message span headers