integration

Documentation

Index

• Variables
• type LocalResolver
  • func NewLocalResolver(manualEndpoints []pcap.AgentEndpoint) LocalResolver
  • func (l LocalResolver) CanResolve(request *pcap.EndpointRequest) bool
  • func (l LocalResolver) Healthy() bool
  • func (l LocalResolver) Name() string
  • func (l LocalResolver) Resolve(_ *pcap.EndpointRequest, _ *zap.Logger) ([]pcap.AgentEndpoint, error)
• type MemoryMessageWriter
  • func NewMemoryMessageWriter() *MemoryMessageWriter
  • func (m *MemoryMessageWriter) Filter(messageType pcap.MessageType) (result []*pcap.Message)
  • func (m *MemoryMessageWriter) WriteMessage(message *pcap.Message)

Variables

var APIPort = 8080

var MaxConcurrentCaptures int32 = 2

var TestNodeIndex = 0

Types

type LocalResolver

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

func NewLocalResolver

func NewLocalResolver(manualEndpoints []pcap.AgentEndpoint) LocalResolver

func (LocalResolver) CanResolve

func (l LocalResolver) CanResolve(request *pcap.EndpointRequest) bool

func (LocalResolver) Healthy

func (l LocalResolver) Healthy() bool

func (LocalResolver) Name

func (l LocalResolver) Name() string

func (LocalResolver) Resolve

func (l LocalResolver) Resolve(_ *pcap.EndpointRequest, _ *zap.Logger) ([]pcap.AgentEndpoint, error)

type MemoryMessageWriter

type MemoryMessageWriter struct {
	Messages []*pcap.Message
}

func NewMemoryMessageWriter

func NewMemoryMessageWriter() *MemoryMessageWriter

func (*MemoryMessageWriter) Filter

func (m *MemoryMessageWriter) Filter(messageType pcap.MessageType) (result []*pcap.Message)

func (*MemoryMessageWriter) WriteMessage

func (m *MemoryMessageWriter) WriteMessage(message *pcap.Message)