traceability

type Agent ¶

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

Agent - mulesoft Beater configuration. Implements the beat.Beater interface.

func (a *Agent) Run(b *beat.Beat) error

func (a *Agent) Stop()

type Emitter ¶

type Emitter interface {
	Start() error
	OnConfigChange(gatewayCfg *config.AgentConfig)
}

type EventMapper ¶

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

EventMapper -

func (em *EventMapper) ProcessMapping(event anypoint.AnalyticsEvent) ([]*transaction.LogEvent, error)

type EventProcessor ¶

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

EventProcessor - represents the processor for received event for Amplify Central The event processing can be done either when the beat input receives the log entry or before the beat transport publishes the event to transport. When processing the received log entry on input, the log entry is mapped to structure expected for Amplify Central Observer and then beat.Event is published to beat output that produces the event over the configured transport. When processing the log entry on output, the log entry is published to output as beat.Event. The output transport invokes the Process(events []publisher.Event) method which is set as output event processor. The Process() method processes the received log entry and performs the mapping to structure expected for Amplify Central Observer. The method returns the converted Events to transport publisher which then produces the events over the transport.

func NewEventProcessor(
	gateway *config.AgentConfig,
	eventGenerator transaction.EventGenerator,
	mapper Mapper,
) *EventProcessor

func (ep *EventProcessor) ProcessRaw(rawEvent []byte) []beat.Event

type GwTrafficLogEntry ¶

type GwTrafficLogEntry struct {
	APIName             string        `json:"apiName"`
	InboundTransaction  GwTransaction `json:"inbound"`
	OutboundTransaction GwTransaction `json:"outbound"`
	TraceID             string        `json:"traceId"`
}

GwTrafficLogEntry - Represents the structure of log entry the agent will receive

type GwTransaction ¶

type GwTransaction struct {
	DesHost         string  `json:"destHost"`
	DestPort        int     `json:"destPort"`
	ID              string  `json:"id"`
	Method          string  `json:"method"`
	RequestBytes    int     `json:"requestByte"`
	RequestHeaders  Headers `json:"requestHeaders"`
	ResponseBytes   int     `json:"responseByte"`
	ResponseHeaders Headers `json:"responseHeaders"`
	SourceHost      string  `json:"srcHost"`
	SourcePort      int     `json:"srcPort"`
	StatusCode      int     `json:"statusCode"`
	URI             string  `json:"uri"`
}

GwTransaction - Type for gateway transaction detail

type Headers ¶

type Headers map[string]string

Headers - Type for request/response headers

type Mapper ¶

type Mapper interface {
	ProcessMapping(event anypoint.AnalyticsEvent) ([]*transaction.LogEvent, error)
}

type MuleEventEmitter ¶

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

MuleEventEmitter - Gathers analytics data for publishing to Central.

func NewMuleEventEmitter(cachePath string, eventChannel chan string, client anypoint.AnalyticsClient) *MuleEventEmitter

func (me *MuleEventEmitter) OnConfigChange(gatewayCfg *config.AgentConfig)

func (me *MuleEventEmitter) Start() error

type MuleEventEmitterJob ¶

type MuleEventEmitterJob struct {
	Emitter
	// contains filtered or unexported fields
}

MuleEventEmitterJob wraps an Emitter and implements the Job interface so that it can be executed by the sdk.

func NewMuleEventEmitterJob(
	emitter Emitter,
	pollInterval time.Duration,
	checkStatus hc.CheckStatus,
	getStatus func(endpoint string) hc.StatusLevel,
	registerHC healthChecker,
) (*MuleEventEmitterJob, error)

func (m *MuleEventEmitterJob) Execute() error

func (m *MuleEventEmitterJob) OnConfigChange(gatewayCfg *config.AgentConfig)

func (m *MuleEventEmitterJob) Ready() bool

func (m *MuleEventEmitterJob) Start() error

func (m *MuleEventEmitterJob) Status() error

type Processor ¶

type Processor interface {
	ProcessRaw(rawEvent []byte) []beat.Event
}