util

Documentation

Index

• Variables
• func ContainsCLITraffic(t akinet.ParsedNetworkTraffic) bool
• func DaemonHeartbeat(c rest.FrontClient, daemonName string) error
• func GetLearnSessionByTags(c rest.LearnClient, serviceID akid.ServiceID, tags map[tags.Key]string) (*kgxapi.ListedLearnSession, error)
• func GetLearnSessionIDByName(c rest.LearnClient, name string) (akid.LearnSessionID, error)
• func GetServiceIDByName(c rest.FrontClient, name string) (akid.ServiceID, error)
• func GetTraceURIByTags(domain string, clientID akid.ClientID, serviceName string, ...) (akiuri.URI, error)
• func LongPollActiveTracesForService(c rest.FrontClient, daemonName string, serviceID akid.ServiceID, ...) (daemon.ActiveTraceDiff, error)
• func NewLearnSession(domain string, clientID akid.ClientID, svc akid.ServiceID, sessionName string, ...) (akid.LearnSessionID, error)
• func ParseTags(tagsArg []string) (map[tags.Key]string, error)
• func ParseTagsAndWarn(tagsArg []string) (map[tags.Key]string, error)
• func ResolveSpecURI(lc rest.LearnClient, uri akiuri.URI) (akid.APISpecID, error)
• func WarnOnReservedTags(tagSet map[tags.Key]string)
• type ExitError
  • func (ee ExitError) Error() string

Variables

var RandomAPIModelName func() string = randomName

Produces a random name for an API model.

var RandomLearnSessionName func() string = randomName

Produces a random name for a learning session.

Functions

func ContainsCLITraffic

func ContainsCLITraffic(t akinet.ParsedNetworkTraffic) bool

Detect Akita internal traffic

func DaemonHeartbeat

func DaemonHeartbeat(c rest.FrontClient, daemonName string) error

func GetLearnSessionByTags

func GetLearnSessionByTags(c rest.LearnClient, serviceID akid.ServiceID, tags map[tags.Key]string) (*kgxapi.ListedLearnSession, error)

func GetLearnSessionIDByName

func GetLearnSessionIDByName(c rest.LearnClient, name string) (akid.LearnSessionID, error)

func GetServiceIDByName

func GetServiceIDByName(c rest.FrontClient, name string) (akid.ServiceID, error)

func GetTraceURIByTags

func GetTraceURIByTags(domain string, clientID akid.ClientID, serviceName string, tags map[tags.Key]string, flagName string) (akiuri.URI, error)

Get the most recent trace for a service; helper method for commands to implement the --append-by-tag or --trace-tag flags.

func LongPollActiveTracesForService

func LongPollActiveTracesForService(c rest.FrontClient, daemonName string, serviceID akid.ServiceID, currentTraces []akid.LearnSessionID) (daemon.ActiveTraceDiff, error)

Long-polls the cloud for changes to the set of active traces for a service.

func NewLearnSession

func NewLearnSession(domain string, clientID akid.ClientID, svc akid.ServiceID, sessionName string, tags map[tags.Key]string, baseSpecRef *kgxapi.APISpecReference) (akid.LearnSessionID, error)

func ParseTags

func ParseTags(tagsArg []string) (map[tags.Key]string, error)

func ParseTagsAndWarn

func ParseTagsAndWarn(tagsArg []string) (map[tags.Key]string, error)

func ResolveSpecURI

func ResolveSpecURI(lc rest.LearnClient, uri akiuri.URI) (akid.APISpecID, error)

func WarnOnReservedTags

func WarnOnReservedTags(tagSet map[tags.Key]string)

Types

type ExitError

type ExitError struct {
	ExitCode int
	Err      error
}

func (ExitError) Error

func (ee ExitError) Error() string