Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Shared client to maximize connection re-use. // TODO: make this private to the package once kgx package is removed. HTTPClient *retryablehttp.Client )
Functions ¶
func GetUserAgent ¶
func GetUserAgent() string
func NewFrontClient ¶
Types ¶
type CreateSpecOptions ¶
type FrontClient ¶
type FrontClient interface {
GetServices(context.Context) ([]Service, error)
DaemonHeartbeat(ctx context.Context, daemonName string) error
// Long-polls for changes to the set of active traces for a service.
// Callers specify what they think the current set of active traces is. When
// the cloud has a different set, this method returns options for capturing
// new traces and a set of deactivated traces. An error is returned if the
// connection is dropped (e.g., due to timing out).
LongPollActiveTracesForService(context context.Context, daemonName string, serviceID akid.ServiceID, currentTraces []akid.LearnSessionID) (daemon.ActiveTraceDiff, error)
}
type GetSpecOptions ¶
type GetSpecOptions struct {
EnableRelatedTypes bool
}
type LearnClient ¶
type LearnClient interface {
ListLearnSessions(context.Context, akid.ServiceID, map[tags.Key]string) ([]*kgxapi.ListedLearnSession, error)
GetLearnSession(context.Context, akid.ServiceID, akid.LearnSessionID) (*kgxapi.LearnSession, error)
CreateLearnSession(context.Context, *kgxapi.APISpecReference, string, map[tags.Key]string) (akid.LearnSessionID, error)
ReportWitnesses(context.Context, akid.LearnSessionID, []*kgxapi.WitnessReport) error
// Deprecated: old way of creating a spec from a single learn session.
// Use CreateSpec instead.
CheckpointLearnSession(context.Context, akid.LearnSessionID) (akid.APISpecID, error)
// Creates a spec from a set of learn sessions.
CreateSpec(context.Context, string, []akid.LearnSessionID, CreateSpecOptions) (akid.APISpecID, error)
GetSpec(context.Context, akid.APISpecID, GetSpecOptions) (kgxapi.GetSpecResponse, error)
GetSpecVersion(context.Context, string) (kgxapi.APISpecVersion, error)
UploadSpec(context.Context, kgxapi.UploadSpecRequest) (*kgxapi.UploadSpecResponse, error)
// Resolve names.
GetAPISpecIDByName(context.Context, string) (akid.APISpecID, error)
GetLearnSessionIDByName(context.Context, string) (akid.LearnSessionID, error)
// Spec diff
GetSpecDiffTrie(context.Context, akid.APISpecID, akid.APISpecID) (*path_trie.PathTrie, error)
}
Click to show internal directories.
Click to hide internal directories.