agent

Jan 5, 2023

Changes in this version

+ var Version string

type Agent

+ func (a *Agent) ResolveIngress(ctx context.Context, request *agent.IngressInfoRequest) (*agent.IngressInfoResponse, error)

+ func (a *Agent) Service(ctx context.Context) error

+ func (a *Agent) Version(context.Context, *emptypb.Empty) (*agent.VersionInfo, error)

+ type Env struct

+ AESDiagnosticsURL *url.URL

+ AESReportDiagnostics bool

+ AESSnapshotURL *url.URL

+ AgentConfigResourceName string

+ AgentNamespace string

+ AgentWatchFieldSelector string

+ AmbassadorAPIKey string

+ AmbassadorID string

+ ClusterID string

+ ConnAddress *ConnInfo

+ LogLevel logrus.Level

+ MinReportPeriod time.Duration

+ NamespacesToWatch []string

+ RpcInterceptHeaderKey string

+ RpcInterceptHeaderValue string

+ ScoutID string

+ ServerHost string

+ ServerPort uint16

+ func LoadEnv(lookupFunc func(string) (string, bool)) (*Env, error)

Dec 21, 2022

Changes in this version

type Agent

+ func (a *Agent) ReportSnapshot(ctx context.Context)

Dec 16, 2022

Changes in this version

type Agent

+ func (a *Agent) MetricsReporter(ctx context.Context) error

+ func (a *Agent) ReportMetrics(ctx context.Context)

Sep 20, 2022

Changes in this version

+ func GetClusterID(ctx context.Context, client *kubernetes.Clientset, nsName string) (clusterID string)

+ type AmbassadorWatcher struct

+ func NewAmbassadorWatcher(clientset *kubernetes.Clientset, ns string) *AmbassadorWatcher

+ func (w *AmbassadorWatcher) EnsureStarted(ctx context.Context)

+ type ConfigWatchers struct

+ func NewConfigWatchers(clientset *kubernetes.Clientset, watchedNs string) *ConfigWatchers

+ func (w *ConfigWatchers) EnsureStarted(ctx context.Context)

+ type CoreWatchers struct

+ func NewCoreWatchers(clientset *kubernetes.Clientset, namespaces []string) *CoreWatchers

+ func (w *CoreWatchers) EnsureStarted(ctx context.Context)

+ type SIWatcher struct

+ func NewSIWatcher(clientset *kubernetes.Clientset, namespaces []string) *SIWatcher

+ func (w *SIWatcher) Cancel()

+ func (w *SIWatcher) EnsureStarted(ctx context.Context)

Aug 26, 2022

Changes in this version

+ const APIKeyMetadataKey

+ const NamespaceKubeSystem

+ func Float64ToPointer(f float64) *float64

+ func GetIdentity(ambassadorMeta *snapshotTypes.AmbassadorMetaInfo, ambHost string) *agent.Identity

+ func GetIdentityFromDiagnostics(ambSystem *diagnosticsTypes.System, ambHost string) *agent.Identity

+ func Int64ToPointer(i int64) *int64

+ func MaxDuration(a, b time.Duration) time.Duration

+ func NewArgoRolloutsGetter() (argov1alpha1.RolloutsGetter, error)

+ func NewConfigMapStore(cms []*kates.ConfigMap) *configMapStore

+ func NewCoreStore(snapshot *CoreSnapshot) *coreStore

+ func NewDeploymentStore(ds []*kates.Deployment) *deploymentStore

+ func NewEndpointsStore(es []*kates.Endpoints) *endpointStore

+ func NewMetricsServer(handler StreamHandler) *metricsServer

+ func NewPodStore(pods []*kates.Pod) *podStore

+ func StrToPointer(str string) *string

+ type APIDocsHTTPClient interface

+ Get func(ctx context.Context, requestURL *url.URL, requestHost string, ...) ([]byte, error)

+ type APIDocsStore struct

+ Client APIDocsHTTPClient

+ DontProcessSnapshotBeforeTime time.Time

+ func NewAPIDocsStore() *APIDocsStore

+ func (a *APIDocsStore) ProcessSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot)

+ func (a *APIDocsStore) StateOfWorld() []*snapshotTypes.APIDoc

+ type Agent struct

+ func NewAgent(directiveHandler DirectiveHandler, rolloutsGetterFactory rolloutsGetterFactory, ...) *Agent

+ func (a *Agent) ClearComm()

+ func (a *Agent) MaybeReportSnapshot(ctx context.Context)

+ func (a *Agent) MetricsRelayHandler(ctx context.Context, in *envoyMetrics.StreamMetricsMessage)

+ func (a *Agent) ProcessDiagnostics(ctx context.Context, diagnostics *diagnosticsTypes.Diagnostics, ambHost string) (*agent.Diagnostics, error)

+ func (a *Agent) ProcessSnapshot(ctx context.Context, snapshot *snapshotTypes.Snapshot, ambHost string) error

+ func (a *Agent) ReportDiagnostics(ctx context.Context, agentDiagnostics *agent.Diagnostics)

+ func (a *Agent) SetLastDirectiveID(ctx context.Context, id string)

+ func (a *Agent) SetMinReportPeriod(ctx context.Context, dur time.Duration)

+ func (a *Agent) SetReportDiagnosticsAllowed(reportDiagnosticsAllowed bool)

+ func (a *Agent) StartReporting(ctx context.Context)

+ func (a *Agent) StopReporting(ctx context.Context)

+ func (a *Agent) Watch(ctx context.Context, snapshotURL, diagnosticsURL string) error

+ type ApplicationStore struct

+ func NewApplicationStore() *ApplicationStore

+ func (a *ApplicationStore) Deltas() []*kates.Delta

+ func (a *ApplicationStore) FromCallback(callback *GenericCallback) (*ApplicationStore, error)

+ func (a *ApplicationStore) StateOfWorld() []*unstructured.Unstructured

+ type BasicDirectiveHandler struct

+ DefaultMinReportPeriod time.Duration

+ func (dh *BasicDirectiveHandler) HandleDirective(ctx context.Context, a *Agent, directive *agentapi.Directive)

+ type CallbackEventType string

+ const CallbackEventAdded

+ const CallbackEventDeleted

+ const CallbackEventUpdated

+ type Comm interface

+ Close func() error

+ Directives func() <-chan *agent.Directive

+ Report func(context.Context, *agent.Snapshot, string) error

+ ReportCommandResult func(context.Context, *agent.CommandResult, string) error

+ StreamDiagnostics func(context.Context, *agent.Diagnostics, string) error

+ StreamMetrics func(context.Context, *agent.StreamMetricsMessage, string) error

+ type ConnInfo struct

+ type CoreSnapshot struct

+ ConfigMaps []*kates.ConfigMap

+ Deployments []*kates.Deployment

+ Endpoints []*kates.Endpoints

+ Pods []*kates.Pod

+ type DirectiveHandler interface

+ HandleDirective func(context.Context, *Agent, *agentapi.Directive)

+ type DynamicClient struct

+ func NewDynamicClient(di dynamic.Interface, informerFn InformerFunc) *DynamicClient

+ func (dc *DynamicClient) WatchGeneric(ctx context.Context, ns string, gvr *schema.GroupVersionResource) <-chan *GenericCallback

+ type GenericCallback struct

+ EventType CallbackEventType

+ Obj *unstructured.Unstructured

+ Sotw []interface{}

+ type Header struct

+ Name string

+ Value string

+ type Informer interface

+ AddEventHandler func(handler cache.ResourceEventHandler)

+ ListCache func() []interface{}

+ Run func(stopCh <-chan struct{})

+ func NewK8sInformer(cli dynamic.Interface, ns string, gvr *schema.GroupVersionResource) Informer

+ type InformerFunc func(dynamic.Interface, string, *schema.GroupVersionResource) Informer

+ type K8sInformer struct

+ func (i *K8sInformer) ListCache() []interface{}

+ type RPCComm struct

+ func NewComm(ctx context.Context, connInfo *ConnInfo, agentID *agent.Identity, ...) (*RPCComm, error)

+ func (c *RPCComm) Close() error

+ func (c *RPCComm) Directives() <-chan *agent.Directive

+ func (c *RPCComm) Report(ctx context.Context, report *agent.Snapshot, apiKey string) error

+ func (c *RPCComm) ReportCommandResult(ctx context.Context, result *agent.CommandResult, apiKey string) error

+ func (c *RPCComm) StreamDiagnostics(ctx context.Context, diagnosticsReport *agent.Diagnostics, apiKey string) error

+ func (c *RPCComm) StreamMetrics(ctx context.Context, metrics *agent.StreamMetricsMessage, apiKey string) error

+ type RolloutStore struct

+ func NewRolloutStore() *RolloutStore

+ func (a *RolloutStore) StateOfWorld() []*unstructured.Unstructured

+ func (r *RolloutStore) FromCallback(callback *GenericCallback) (*RolloutStore, error)

+ func (s *RolloutStore) Deltas() []*kates.Delta

+ type SecretInterface interface

+ Create func(ctx context.Context, secret *apiv1.Secret, opts metav1.CreateOptions) (*apiv1.Secret, error)

+ Delete func(ctx context.Context, name string, opts metav1.DeleteOptions) error

+ Get func(ctx context.Context, name string, opts metav1.GetOptions) (*apiv1.Secret, error)

+ Patch func(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *apiv1.Secret, err error)

+ func NewSecretsGetter(namespace string) (SecretInterface, error)

+ type StreamHandler func(ctx context.Context, in *envoyMetrics.StreamMetricsMessage)