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 GetOrCreateServiceIDByPostmanCollectionID(c rest.FrontClient, collectionID string) (akid.ServiceID, error)
• func GetServiceIDByName(c rest.FrontClient, name string) (akid.ServiceID, error)
• func GetServiceIDByPostmanCollectionID(c rest.FrontClient, ctx context.Context, collectionID 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 GetOrCreateServiceIDByPostmanCollectionID

func GetOrCreateServiceIDByPostmanCollectionID(c rest.FrontClient, collectionID string) (akid.ServiceID, error)

func GetServiceIDByName

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

func GetServiceIDByPostmanCollectionID

func GetServiceIDByPostmanCollectionID(c rest.FrontClient, ctx context.Context, collectionID 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