cloud_client

Documentation

Index

• Constants
• func NewRegistrationRequest(clientName string, serviceID akid.ServiceID, ...) registrationRequest
• func NewTraceEventRequest(clientName string, serviceID akid.ServiceID, traceID akid.LearnSessionID, ...) traceEventRequest
• func Run(daemonName, host string, clientID akid.ClientID, plugins []plugin.AkitaPlugin) chan<- Event
• type Event
• type TraceEvent
• type TraceEventDetails
• type TraceEventResponse

Constants

const HEARTBEAT_INTERVAL = 30 * time.Second

How long to wait between heartbeat requests.

const LONG_POLL_INTERVAL = 5 * time.Second

How long to wait after a failed long poll before trying again.

const MAIN_GOROUTINE_BUFFER_SIZE = 50

The number of events to buffer in the event channel in the daemon's main goroutine

const TRACE_BUFFER_SIZE = 10_000

The number of events to buffer for any given trace before dropping incoming events.

Functions

func NewRegistrationRequest

func NewRegistrationRequest(clientName string, serviceID akid.ServiceID, activeTraces []akid.LearnSessionID, responseChannel chan<- daemon.ActiveTraceDiff) registrationRequest

func NewTraceEventRequest

func NewTraceEventRequest(clientName string, serviceID akid.ServiceID, traceID akid.LearnSessionID, traceEvents []*TraceEvent, noMoreEvents bool, responseChannel chan<- TraceEventResponse) traceEventRequest

func Run

func Run(daemonName, host string, clientID akid.ClientID, plugins []plugin.AkitaPlugin) chan<- Event

Instantiates a cloud client and starts its main goroutine. Returns a channel on which requests to the client can be made.

Types

type Event

type Event interface {
	// contains filtered or unexported methods
}

An event that is handled by the main goroutine for the cloud client.

type TraceEvent

type TraceEvent = har_loader.CustomHAREntry

type TraceEventDetails

type TraceEventDetails struct {
	// How many were dropped because the queue was full.
	Drops int `json:"drops"`
}

Provides details on the processing status of trace events.

type TraceEventResponse

type TraceEventResponse struct {
	HTTPStatus int
	Body       traceEventResponseBody
}

A response to a TraceEventRequest.