cloud_client

package

v1.0.0 Latest Latest Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/akitasoftware/akita-cli

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 ¶

View Source

const HEARTBEAT_INTERVAL = 30 * time.Second

How long to wait between heartbeat requests.

View Source

const LONG_POLL_INTERVAL = 5 * time.Second

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

View Source

const MAIN_GOROUTINE_BUFFER_SIZE = 50

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

View Source

const TRACE_BUFFER_SIZE = 10_000

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

Variables ¶

This section is empty.

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL