trace

Documentation

Index

• Variables
• func NewPipeToggleMatchers(request *trace_pb.TogglePipeTracesRequest) (*PipeToggleMatchers, *ToggleResult)
• type Channel2PeekHandler
  • func NewChannel2PeekHandler(appId string, ch channel2.Channel, controller Controller, ...) *Channel2PeekHandler
  • func (handler *Channel2PeekHandler) Close(ch channel2.Channel)
  • func (*Channel2PeekHandler) Connect(ch channel2.Channel, remoteAddress string)
  • func (handler *Channel2PeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *Channel2PeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *Channel2PeekHandler) IsEnabled() bool
  • func (handler *Channel2PeekHandler) Rx(msg *channel2.Message, ch channel2.Channel)
  • func (handler *Channel2PeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, ...)
  • func (handler *Channel2PeekHandler) Tx(msg *channel2.Message, ch channel2.Channel)
• type ChannelPeekHandler
  • func NewChannelPeekHandler(appId string, ch channel.Channel, controller Controller, ...) *ChannelPeekHandler
  • func (handler *ChannelPeekHandler) Close(ch channel.Channel)
  • func (*ChannelPeekHandler) Connect(ch channel.Channel, remoteAddress string)
  • func (handler *ChannelPeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *ChannelPeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *ChannelPeekHandler) IsEnabled() bool
  • func (handler *ChannelPeekHandler) Rx(msg *channel.Message, ch channel.Channel)
  • func (handler *ChannelPeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, ...)
  • func (handler *ChannelPeekHandler) Tx(msg *channel.Message, ch channel.Channel)
• type Controller
  • func NewController(closeNotify <-chan struct{}) Controller
• type DispatchWrapper
  • func (dispatchWrapper *DispatchWrapper) Accept(event *trace_pb.ChannelMessage)
• type EventHandler
  • func NewChannel2Sink(ch channel2.Channel) EventHandler
  • func NewChannelSink(ch channel.Channel) EventHandler
  • func NewDispatchWrapper(delegate func(event event.Event)) EventHandler
• type Filter
  • func NewAllowAllFilter() Filter
  • func NewExcludeFilter(excludedContentTypes []int32) Filter
  • func NewIncludeFilter(includedContentTypes []int32) Filter
• type PipeToggleMatchers
• type Source
• type SourceMatcher
  • func NewSourceMatcher(regex *regexp.Regexp) SourceMatcher
• type SourceType
• type ToggleApplyResult
• type ToggleApplyResultImpl
  • func (applyResult *ToggleApplyResultImpl) Append(result *ToggleResult, verbosity ToggleVerbosity)
  • func (applyResult *ToggleApplyResultImpl) GetMessage() string
  • func (applyResult *ToggleApplyResultImpl) IsMatched() bool
• type ToggleResult
  • func (result *ToggleResult) Append(msg string)
• type ToggleVerbosity
  • func GetVerbosity(verbosity trace_pb.TraceToggleVerbosity) ToggleVerbosity
  • func (val ToggleVerbosity) Show(matched bool) bool
• type XgressPeekHandler
  • func NewXgressPeekHandler(appId *identity.TokenId, controller Controller, eventSink EventHandler) *XgressPeekHandler
  • func (handler *XgressPeekHandler) Close(x *xgress.Xgress)
  • func (handler *XgressPeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *XgressPeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, ...)
  • func (handler *XgressPeekHandler) IsEnabled() bool
  • func (handler *XgressPeekHandler) Rx(x *xgress.Xgress, payload *xgress.Payload)
  • func (handler *XgressPeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, ...)
  • func (handler *XgressPeekHandler) Tx(x *xgress.Xgress, payload *xgress.Payload)

Variables

var EventHandlerRegistry = cowslice.NewCowSlice(make([]EventHandler, 0))

Functions

func NewPipeToggleMatchers

func NewPipeToggleMatchers(request *trace_pb.TogglePipeTracesRequest) (*PipeToggleMatchers, *ToggleResult)

Types

type Channel2PeekHandler

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

func NewChannel2PeekHandler

func NewChannel2PeekHandler(appId string, ch channel2.Channel, controller Controller, eventSink EventHandler) *Channel2PeekHandler

func (*Channel2PeekHandler) Close

func (handler *Channel2PeekHandler) Close(ch channel2.Channel)

func (*Channel2PeekHandler) Connect

func (*Channel2PeekHandler) Connect(ch channel2.Channel, remoteAddress string)

func (*Channel2PeekHandler) DisableTracing

func (handler *Channel2PeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*Channel2PeekHandler) EnableTracing

func (handler *Channel2PeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*Channel2PeekHandler) IsEnabled

func (handler *Channel2PeekHandler) IsEnabled() bool

func (*Channel2PeekHandler) Rx

func (handler *Channel2PeekHandler) Rx(msg *channel2.Message, ch channel2.Channel)

func (*Channel2PeekHandler) ToggleTracing

func (handler *Channel2PeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, resultChan chan<- ToggleApplyResult)

func (*Channel2PeekHandler) Tx

func (handler *Channel2PeekHandler) Tx(msg *channel2.Message, ch channel2.Channel)

type ChannelPeekHandler

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

func NewChannelPeekHandler

func NewChannelPeekHandler(appId string, ch channel.Channel, controller Controller, eventSink EventHandler) *ChannelPeekHandler

func (*ChannelPeekHandler) Close

func (handler *ChannelPeekHandler) Close(ch channel.Channel)

func (*ChannelPeekHandler) Connect

func (*ChannelPeekHandler) Connect(ch channel.Channel, remoteAddress string)

func (*ChannelPeekHandler) DisableTracing

func (handler *ChannelPeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*ChannelPeekHandler) EnableTracing

func (handler *ChannelPeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*ChannelPeekHandler) IsEnabled

func (handler *ChannelPeekHandler) IsEnabled() bool

func (*ChannelPeekHandler) Rx

func (handler *ChannelPeekHandler) Rx(msg *channel.Message, ch channel.Channel)

func (*ChannelPeekHandler) ToggleTracing

func (handler *ChannelPeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, resultChan chan<- ToggleApplyResult)

func (*ChannelPeekHandler) Tx

func (handler *ChannelPeekHandler) Tx(msg *channel.Message, ch channel.Channel)

type Controller

type Controller interface {
	EnableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)
	DisableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)
	AddSource(source Source)
	RemoveSource(source Source)
}

func NewController

func NewController(closeNotify <-chan struct{}) Controller

type DispatchWrapper

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

func (*DispatchWrapper) Accept

func (dispatchWrapper *DispatchWrapper) Accept(event *trace_pb.ChannelMessage)

type EventHandler

type EventHandler interface {
	Accept(event *trace_pb.ChannelMessage)
}

EventHandler is for types wishing to receive trace messages

func NewChannel2Sink

func NewChannel2Sink(ch channel2.Channel) EventHandler

func NewChannelSink

func NewChannelSink(ch channel.Channel) EventHandler

func NewDispatchWrapper

func NewDispatchWrapper(delegate func(event event.Event)) EventHandler

type Filter

type Filter interface {
	Accept(event *tracepb.ChannelMessage) bool
}

func NewAllowAllFilter

func NewAllowAllFilter() Filter

func NewExcludeFilter

func NewExcludeFilter(excludedContentTypes []int32) Filter

func NewIncludeFilter

func NewIncludeFilter(includedContentTypes []int32) Filter

type PipeToggleMatchers

type PipeToggleMatchers struct {
	AppMatcher  SourceMatcher
	PipeMatcher SourceMatcher
}

type Source

type Source interface {
	EnableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)
	DisableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)
}

type SourceMatcher

type SourceMatcher interface {
	Matches(source string) bool
}

func NewSourceMatcher

func NewSourceMatcher(regex *regexp.Regexp) SourceMatcher

type SourceType

type SourceType int

const (
	SourceTypePipe SourceType = iota
)

type ToggleApplyResult

type ToggleApplyResult interface {
	IsMatched() bool
	GetMessage() string
	Append(result *ToggleResult, verbosity ToggleVerbosity)
}

type ToggleApplyResultImpl

type ToggleApplyResultImpl struct {
	Matched bool
	Message string
}

func (*ToggleApplyResultImpl) Append

func (applyResult *ToggleApplyResultImpl) Append(result *ToggleResult, verbosity ToggleVerbosity)

func (*ToggleApplyResultImpl) GetMessage

func (applyResult *ToggleApplyResultImpl) GetMessage() string

func (*ToggleApplyResultImpl) IsMatched

func (applyResult *ToggleApplyResultImpl) IsMatched() bool

type ToggleResult

type ToggleResult struct {
	Success bool
	Message *strings.Builder
}

func (*ToggleResult) Append

func (result *ToggleResult) Append(msg string)

type ToggleVerbosity

type ToggleVerbosity int

const (
	ToggleVerbosityNone ToggleVerbosity = iota
	ToggleVerbosityMatches
	ToggleVerbosityMisses
	ToggleVerbosityAll
)

func GetVerbosity

func GetVerbosity(verbosity trace_pb.TraceToggleVerbosity) ToggleVerbosity

func (ToggleVerbosity) Show

func (val ToggleVerbosity) Show(matched bool) bool

type XgressPeekHandler

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

func NewXgressPeekHandler

func NewXgressPeekHandler(appId *identity.TokenId, controller Controller, eventSink EventHandler) *XgressPeekHandler

func (*XgressPeekHandler) Close

func (handler *XgressPeekHandler) Close(x *xgress.Xgress)

func (*XgressPeekHandler) DisableTracing

func (handler *XgressPeekHandler) DisableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*XgressPeekHandler) EnableTracing

func (handler *XgressPeekHandler) EnableTracing(sourceType SourceType, matcher SourceMatcher, resultChan chan<- ToggleApplyResult)

func (*XgressPeekHandler) IsEnabled

func (handler *XgressPeekHandler) IsEnabled() bool

func (*XgressPeekHandler) Rx

func (handler *XgressPeekHandler) Rx(x *xgress.Xgress, payload *xgress.Payload)

func (*XgressPeekHandler) ToggleTracing

func (handler *XgressPeekHandler) ToggleTracing(sourceType SourceType, matcher SourceMatcher, enable bool, resultChan chan<- ToggleApplyResult)

func (*XgressPeekHandler) Tx

func (handler *XgressPeekHandler) Tx(x *xgress.Xgress, payload *xgress.Payload)