agent

package
v3.7.0-rc.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 9, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	RolloutCommand_Action_name = map[int32]string{
		0: "PAUSE",
		1: "RESUME",
		2: "ABORT",
	}
	RolloutCommand_Action_value = map[string]int32{
		"PAUSE":  0,
		"RESUME": 1,
		"ABORT":  2,
	}
)

Enum value maps for RolloutCommand_Action.

View Source
var (
	SecretSyncCommand_Action_name = map[int32]string{
		0: "SET",
		1: "DELETE",
	}
	SecretSyncCommand_Action_value = map[string]int32{
		"SET":    0,
		"DELETE": 1,
	}
)

Enum value maps for SecretSyncCommand_Action.

View Source
var Director_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.Director",
	HandlerType: (*DirectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Report",
			Handler:    _Director_Report_Handler,
		},
		{
			MethodName: "ReportCommandResult",
			Handler:    _Director_ReportCommandResult_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReportStream",
			Handler:       _Director_ReportStream_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamDiagnostics",
			Handler:       _Director_StreamDiagnostics_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "StreamMetrics",
			Handler:       _Director_StreamMetrics_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Retrieve",
			Handler:       _Director_Retrieve_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent/director.proto",
}

Director_ServiceDesc is the grpc.ServiceDesc for Director service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_agent_director_proto protoreflect.FileDescriptor

Functions

func RegisterDirectorServer

func RegisterDirectorServer(s grpc.ServiceRegistrar, srv DirectorServer)

Types

type Command

type Command struct {

	// Log this message if present
	Message           string             `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	RolloutCommand    *RolloutCommand    `protobuf:"bytes,2,opt,name=rolloutCommand,proto3" json:"rolloutCommand,omitempty"`
	SecretSyncCommand *SecretSyncCommand `protobuf:"bytes,3,opt,name=secretSyncCommand,proto3" json:"secretSyncCommand,omitempty"`
	// contains filtered or unexported fields
}

An individual instruction from the DCP

func (*Command) Descriptor deprecated

func (*Command) Descriptor() ([]byte, []int)

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetMessage

func (x *Command) GetMessage() string

func (*Command) GetRolloutCommand

func (x *Command) GetRolloutCommand() *RolloutCommand

func (*Command) GetSecretSyncCommand added in v3.1.0

func (x *Command) GetSecretSyncCommand() *SecretSyncCommand

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) ProtoReflect

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset

func (x *Command) Reset()

func (*Command) String

func (x *Command) String() string

type CommandResult

type CommandResult struct {
	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Message   string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandResult) Descriptor deprecated

func (*CommandResult) Descriptor() ([]byte, []int)

Deprecated: Use CommandResult.ProtoReflect.Descriptor instead.

func (*CommandResult) GetCommandId

func (x *CommandResult) GetCommandId() string

func (*CommandResult) GetMessage

func (x *CommandResult) GetMessage() string

func (*CommandResult) GetSuccess

func (x *CommandResult) GetSuccess() bool

func (*CommandResult) ProtoMessage

func (*CommandResult) ProtoMessage()

func (*CommandResult) ProtoReflect

func (x *CommandResult) ProtoReflect() protoreflect.Message

func (*CommandResult) Reset

func (x *CommandResult) Reset()

func (*CommandResult) String

func (x *CommandResult) String() string

type CommandResultResponse

type CommandResultResponse struct {
	// contains filtered or unexported fields
}

func (*CommandResultResponse) Descriptor deprecated

func (*CommandResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommandResultResponse.ProtoReflect.Descriptor instead.

func (*CommandResultResponse) ProtoMessage

func (*CommandResultResponse) ProtoMessage()

func (*CommandResultResponse) ProtoReflect

func (x *CommandResultResponse) ProtoReflect() protoreflect.Message

func (*CommandResultResponse) Reset

func (x *CommandResultResponse) Reset()

func (*CommandResultResponse) String

func (x *CommandResultResponse) String() string

type Diagnostics added in v3.1.0

type Diagnostics struct {
	Identity       *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Message        string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RawDiagnostics []byte    `protobuf:"bytes,3,opt,name=raw_diagnostics,json=rawDiagnostics,proto3" json:"raw_diagnostics,omitempty"`
	// describes how the raw_diagnostic is encoded
	ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// api version of Diagnostics
	ApiVersion string                 `protobuf:"bytes,5,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	SnapshotTs *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
	// contains filtered or unexported fields
}

Diagnostic information from ambassador admin

func (*Diagnostics) Descriptor deprecated added in v3.1.0

func (*Diagnostics) Descriptor() ([]byte, []int)

Deprecated: Use Diagnostics.ProtoReflect.Descriptor instead.

func (*Diagnostics) GetApiVersion added in v3.1.0

func (x *Diagnostics) GetApiVersion() string

func (*Diagnostics) GetContentType added in v3.1.0

func (x *Diagnostics) GetContentType() string

func (*Diagnostics) GetIdentity added in v3.1.0

func (x *Diagnostics) GetIdentity() *Identity

func (*Diagnostics) GetMessage added in v3.1.0

func (x *Diagnostics) GetMessage() string

func (*Diagnostics) GetRawDiagnostics added in v3.1.0

func (x *Diagnostics) GetRawDiagnostics() []byte

func (*Diagnostics) GetSnapshotTs added in v3.1.0

func (x *Diagnostics) GetSnapshotTs() *timestamppb.Timestamp

func (*Diagnostics) ProtoMessage added in v3.1.0

func (*Diagnostics) ProtoMessage()

func (*Diagnostics) ProtoReflect added in v3.1.0

func (x *Diagnostics) ProtoReflect() protoreflect.Message

func (*Diagnostics) Reset added in v3.1.0

func (x *Diagnostics) Reset()

func (*Diagnostics) String added in v3.1.0

func (x *Diagnostics) String() string

type DiagnosticsResponse added in v3.1.0

type DiagnosticsResponse struct {
	// contains filtered or unexported fields
}

The Director's response to a Diagnostics message from the Agent

func (*DiagnosticsResponse) Descriptor deprecated added in v3.1.0

func (*DiagnosticsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DiagnosticsResponse.ProtoReflect.Descriptor instead.

func (*DiagnosticsResponse) ProtoMessage added in v3.1.0

func (*DiagnosticsResponse) ProtoMessage()

func (*DiagnosticsResponse) ProtoReflect added in v3.1.0

func (x *DiagnosticsResponse) ProtoReflect() protoreflect.Message

func (*DiagnosticsResponse) Reset added in v3.1.0

func (x *DiagnosticsResponse) Reset()

func (*DiagnosticsResponse) String added in v3.1.0

func (x *DiagnosticsResponse) String() string

type Directive

type Directive struct {
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Stop sending snapshots. The default value (false) indicates that
	// snapshot should be sent.
	StopReporting bool `protobuf:"varint,2,opt,name=stop_reporting,json=stopReporting,proto3" json:"stop_reporting,omitempty"`
	// Minimum time to wait before pushing the next snapshot. The default
	// value (zero duration) indicates that the Agent should not modify
	// the existing report period.
	MinReportPeriod *durationpb.Duration `protobuf:"bytes,3,opt,name=min_report_period,json=minReportPeriod,proto3" json:"min_report_period,omitempty"`
	// Commands to execute
	Commands []*Command `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

Instructions that the DCP can send to Ambassador

func (*Directive) Descriptor deprecated

func (*Directive) Descriptor() ([]byte, []int)

Deprecated: Use Directive.ProtoReflect.Descriptor instead.

func (*Directive) GetCommands

func (x *Directive) GetCommands() []*Command

func (*Directive) GetID

func (x *Directive) GetID() string

func (*Directive) GetMinReportPeriod

func (x *Directive) GetMinReportPeriod() *durationpb.Duration

func (*Directive) GetStopReporting

func (x *Directive) GetStopReporting() bool

func (*Directive) ProtoMessage

func (*Directive) ProtoMessage()

func (*Directive) ProtoReflect

func (x *Directive) ProtoReflect() protoreflect.Message

func (*Directive) Reset

func (x *Directive) Reset()

func (*Directive) String

func (x *Directive) String() string

type DirectorClient

type DirectorClient interface {
	// Deprecated: Do not use.
	// Report a consistent Snapshot of information to the DCP.  This
	// method is deprecated, you should call ReportStream instead.
	Report(ctx context.Context, in *Snapshot, opts ...grpc.CallOption) (*SnapshotResponse, error)
	// Report a consistent Snapshot of information to the DCP.
	ReportStream(ctx context.Context, opts ...grpc.CallOption) (Director_ReportStreamClient, error)
	// Report a consistent Diagnostics snapshot of information to the DCP.
	StreamDiagnostics(ctx context.Context, opts ...grpc.CallOption) (Director_StreamDiagnosticsClient, error)
	// Stream metrics to the DCP.
	StreamMetrics(ctx context.Context, opts ...grpc.CallOption) (Director_StreamMetricsClient, error)
	// Retrieve Directives from the DCP
	Retrieve(ctx context.Context, in *Identity, opts ...grpc.CallOption) (Director_RetrieveClient, error)
	// Reports the result of a command execution to the cloud
	ReportCommandResult(ctx context.Context, in *CommandResult, opts ...grpc.CallOption) (*CommandResultResponse, error)
}

DirectorClient is the client API for Director service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDirectorClient

func NewDirectorClient(cc grpc.ClientConnInterface) DirectorClient

type DirectorServer

type DirectorServer interface {
	// Deprecated: Do not use.
	// Report a consistent Snapshot of information to the DCP.  This
	// method is deprecated, you should call ReportStream instead.
	Report(context.Context, *Snapshot) (*SnapshotResponse, error)
	// Report a consistent Snapshot of information to the DCP.
	ReportStream(Director_ReportStreamServer) error
	// Report a consistent Diagnostics snapshot of information to the DCP.
	StreamDiagnostics(Director_StreamDiagnosticsServer) error
	// Stream metrics to the DCP.
	StreamMetrics(Director_StreamMetricsServer) error
	// Retrieve Directives from the DCP
	Retrieve(*Identity, Director_RetrieveServer) error
	// Reports the result of a command execution to the cloud
	ReportCommandResult(context.Context, *CommandResult) (*CommandResultResponse, error)
	// contains filtered or unexported methods
}

DirectorServer is the server API for Director service. All implementations must embed UnimplementedDirectorServer for forward compatibility

type Director_ReportStreamClient

type Director_ReportStreamClient interface {
	Send(*RawSnapshotChunk) error
	CloseAndRecv() (*SnapshotResponse, error)
	grpc.ClientStream
}

type Director_ReportStreamServer

type Director_ReportStreamServer interface {
	SendAndClose(*SnapshotResponse) error
	Recv() (*RawSnapshotChunk, error)
	grpc.ServerStream
}

type Director_RetrieveClient

type Director_RetrieveClient interface {
	Recv() (*Directive, error)
	grpc.ClientStream
}

type Director_RetrieveServer

type Director_RetrieveServer interface {
	Send(*Directive) error
	grpc.ServerStream
}

type Director_StreamDiagnosticsClient added in v3.1.0

type Director_StreamDiagnosticsClient interface {
	Send(*RawDiagnosticsChunk) error
	CloseAndRecv() (*DiagnosticsResponse, error)
	grpc.ClientStream
}

type Director_StreamDiagnosticsServer added in v3.1.0

type Director_StreamDiagnosticsServer interface {
	SendAndClose(*DiagnosticsResponse) error
	Recv() (*RawDiagnosticsChunk, error)
	grpc.ServerStream
}

type Director_StreamMetricsClient

type Director_StreamMetricsClient interface {
	Send(*StreamMetricsMessage) error
	CloseAndRecv() (*StreamMetricsResponse, error)
	grpc.ClientStream
}

type Director_StreamMetricsServer

type Director_StreamMetricsServer interface {
	SendAndClose(*StreamMetricsResponse) error
	Recv() (*StreamMetricsMessage, error)
	grpc.ServerStream
}

type Identity

type Identity struct {

	// The account ID assigned by the DCP
	//
	// Deprecated: Marked as deprecated in agent/director.proto.
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Ambassador version
	//
	// Deprecated: Marked as deprecated in agent/director.proto.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// This Ambassador's hostname
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// License information
	License string `protobuf:"bytes,4,opt,name=license,proto3" json:"license,omitempty"`
	// The cluster ID, as determined by Ambassador
	ClusterId string `protobuf:"bytes,5,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Label or description for the user
	//
	// Deprecated: Marked as deprecated in agent/director.proto.
	Label string `protobuf:"bytes,6,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

How Ambassador's Agent identifies itself to the DCP This is the identity of the ambassador the agent is reporting on behalf of no user account specific information should be contained in here

func (*Identity) Descriptor deprecated

func (*Identity) Descriptor() ([]byte, []int)

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetAccountId deprecated

func (x *Identity) GetAccountId() string

Deprecated: Marked as deprecated in agent/director.proto.

func (*Identity) GetClusterId

func (x *Identity) GetClusterId() string

func (*Identity) GetHostname

func (x *Identity) GetHostname() string

func (*Identity) GetLabel deprecated

func (x *Identity) GetLabel() string

Deprecated: Marked as deprecated in agent/director.proto.

func (*Identity) GetLicense

func (x *Identity) GetLicense() string

func (*Identity) GetVersion deprecated

func (x *Identity) GetVersion() string

Deprecated: Marked as deprecated in agent/director.proto.

func (*Identity) ProtoMessage

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect

func (x *Identity) ProtoReflect() protoreflect.Message

func (*Identity) Reset

func (x *Identity) Reset()

func (*Identity) String

func (x *Identity) String() string

type RawDiagnosticsChunk added in v3.1.0

type RawDiagnosticsChunk struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

RawDiagnosticChunk is a fragment of a JSON serialization of a Diagnostic protobuf object.

func (*RawDiagnosticsChunk) Descriptor deprecated added in v3.1.0

func (*RawDiagnosticsChunk) Descriptor() ([]byte, []int)

Deprecated: Use RawDiagnosticsChunk.ProtoReflect.Descriptor instead.

func (*RawDiagnosticsChunk) GetChunk added in v3.1.0

func (x *RawDiagnosticsChunk) GetChunk() []byte

func (*RawDiagnosticsChunk) ProtoMessage added in v3.1.0

func (*RawDiagnosticsChunk) ProtoMessage()

func (*RawDiagnosticsChunk) ProtoReflect added in v3.1.0

func (x *RawDiagnosticsChunk) ProtoReflect() protoreflect.Message

func (*RawDiagnosticsChunk) Reset added in v3.1.0

func (x *RawDiagnosticsChunk) Reset()

func (*RawDiagnosticsChunk) String added in v3.1.0

func (x *RawDiagnosticsChunk) String() string

type RawSnapshotChunk

type RawSnapshotChunk struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

RawSnapshotChunk is a fragment of a JSON serialization of a Snapshot protobuf object.

func (*RawSnapshotChunk) Descriptor deprecated

func (*RawSnapshotChunk) Descriptor() ([]byte, []int)

Deprecated: Use RawSnapshotChunk.ProtoReflect.Descriptor instead.

func (*RawSnapshotChunk) GetChunk

func (x *RawSnapshotChunk) GetChunk() []byte

func (*RawSnapshotChunk) ProtoMessage

func (*RawSnapshotChunk) ProtoMessage()

func (*RawSnapshotChunk) ProtoReflect

func (x *RawSnapshotChunk) ProtoReflect() protoreflect.Message

func (*RawSnapshotChunk) Reset

func (x *RawSnapshotChunk) Reset()

func (*RawSnapshotChunk) String

func (x *RawSnapshotChunk) String() string

type RolloutCommand

type RolloutCommand struct {
	Name      string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string                `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Action    RolloutCommand_Action `protobuf:"varint,3,opt,name=action,proto3,enum=agent.RolloutCommand_Action" json:"action,omitempty"`
	CommandId string                `protobuf:"bytes,4,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RolloutCommand) Descriptor deprecated

func (*RolloutCommand) Descriptor() ([]byte, []int)

Deprecated: Use RolloutCommand.ProtoReflect.Descriptor instead.

func (*RolloutCommand) GetAction

func (x *RolloutCommand) GetAction() RolloutCommand_Action

func (*RolloutCommand) GetCommandId

func (x *RolloutCommand) GetCommandId() string

func (*RolloutCommand) GetName

func (x *RolloutCommand) GetName() string

func (*RolloutCommand) GetNamespace

func (x *RolloutCommand) GetNamespace() string

func (*RolloutCommand) ProtoMessage

func (*RolloutCommand) ProtoMessage()

func (*RolloutCommand) ProtoReflect

func (x *RolloutCommand) ProtoReflect() protoreflect.Message

func (*RolloutCommand) Reset

func (x *RolloutCommand) Reset()

func (*RolloutCommand) String

func (x *RolloutCommand) String() string

type RolloutCommand_Action

type RolloutCommand_Action int32
const (
	RolloutCommand_PAUSE  RolloutCommand_Action = 0
	RolloutCommand_RESUME RolloutCommand_Action = 1
	RolloutCommand_ABORT  RolloutCommand_Action = 2
)

func (RolloutCommand_Action) Descriptor

func (RolloutCommand_Action) Enum

func (RolloutCommand_Action) EnumDescriptor deprecated

func (RolloutCommand_Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use RolloutCommand_Action.Descriptor instead.

func (RolloutCommand_Action) Number

func (RolloutCommand_Action) String

func (x RolloutCommand_Action) String() string

func (RolloutCommand_Action) Type

type SecretSyncCommand added in v3.1.0

type SecretSyncCommand struct {
	Name      string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace string                   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	CommandId string                   `protobuf:"bytes,3,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Action    SecretSyncCommand_Action `protobuf:"varint,4,opt,name=action,proto3,enum=agent.SecretSyncCommand_Action" json:"action,omitempty"`
	Secret    map[string][]byte        `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SecretSyncCommand) Descriptor deprecated added in v3.1.0

func (*SecretSyncCommand) Descriptor() ([]byte, []int)

Deprecated: Use SecretSyncCommand.ProtoReflect.Descriptor instead.

func (*SecretSyncCommand) GetAction added in v3.1.0

func (*SecretSyncCommand) GetCommandId added in v3.1.0

func (x *SecretSyncCommand) GetCommandId() string

func (*SecretSyncCommand) GetName added in v3.1.0

func (x *SecretSyncCommand) GetName() string

func (*SecretSyncCommand) GetNamespace added in v3.1.0

func (x *SecretSyncCommand) GetNamespace() string

func (*SecretSyncCommand) GetSecret added in v3.1.0

func (x *SecretSyncCommand) GetSecret() map[string][]byte

func (*SecretSyncCommand) ProtoMessage added in v3.1.0

func (*SecretSyncCommand) ProtoMessage()

func (*SecretSyncCommand) ProtoReflect added in v3.1.0

func (x *SecretSyncCommand) ProtoReflect() protoreflect.Message

func (*SecretSyncCommand) Reset added in v3.1.0

func (x *SecretSyncCommand) Reset()

func (*SecretSyncCommand) String added in v3.1.0

func (x *SecretSyncCommand) String() string

type SecretSyncCommand_Action added in v3.1.0

type SecretSyncCommand_Action int32
const (
	SecretSyncCommand_SET    SecretSyncCommand_Action = 0
	SecretSyncCommand_DELETE SecretSyncCommand_Action = 1
)

func (SecretSyncCommand_Action) Descriptor added in v3.1.0

func (SecretSyncCommand_Action) Enum added in v3.1.0

func (SecretSyncCommand_Action) EnumDescriptor deprecated added in v3.1.0

func (SecretSyncCommand_Action) EnumDescriptor() ([]byte, []int)

Deprecated: Use SecretSyncCommand_Action.Descriptor instead.

func (SecretSyncCommand_Action) Number added in v3.1.0

func (SecretSyncCommand_Action) String added in v3.1.0

func (x SecretSyncCommand_Action) String() string

func (SecretSyncCommand_Action) Type added in v3.1.0

type Service

type Service struct {
	Name        string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace   string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels      map[string]string `` /* 153-byte string literal not displayed */
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetAnnotations

func (x *Service) GetAnnotations() map[string]string

func (*Service) GetLabels

func (x *Service) GetLabels() map[string]string

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) GetNamespace

func (x *Service) GetNamespace() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type Snapshot

type Snapshot struct {
	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Message  string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// no longer used.
	//
	// Deprecated: Marked as deprecated in agent/director.proto.
	Services    []*Service `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	RawSnapshot []byte     `protobuf:"bytes,4,opt,name=raw_snapshot,json=rawSnapshot,proto3" json:"raw_snapshot,omitempty"`
	// describes how the raw_snapshot is encoded
	ContentType string `protobuf:"bytes,5,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// api version of RawSnapshot
	ApiVersion string                 `protobuf:"bytes,6,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	SnapshotTs *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=snapshot_ts,json=snapshotTs,proto3" json:"snapshot_ts,omitempty"`
	// contains filtered or unexported fields
}

Information that Ambassador's Agent can send to the Director component of the DCP

func (*Snapshot) Descriptor deprecated

func (*Snapshot) Descriptor() ([]byte, []int)

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetApiVersion

func (x *Snapshot) GetApiVersion() string

func (*Snapshot) GetContentType

func (x *Snapshot) GetContentType() string

func (*Snapshot) GetIdentity

func (x *Snapshot) GetIdentity() *Identity

func (*Snapshot) GetMessage

func (x *Snapshot) GetMessage() string

func (*Snapshot) GetRawSnapshot

func (x *Snapshot) GetRawSnapshot() []byte

func (*Snapshot) GetServices deprecated

func (x *Snapshot) GetServices() []*Service

Deprecated: Marked as deprecated in agent/director.proto.

func (*Snapshot) GetSnapshotTs

func (x *Snapshot) GetSnapshotTs() *timestamppb.Timestamp

func (*Snapshot) ProtoMessage

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect

func (x *Snapshot) ProtoReflect() protoreflect.Message

func (*Snapshot) Reset

func (x *Snapshot) Reset()

func (*Snapshot) String

func (x *Snapshot) String() string

type SnapshotResponse

type SnapshotResponse struct {
	// contains filtered or unexported fields
}

The Director's response to a Snapshot from the Agent

func (*SnapshotResponse) Descriptor deprecated

func (*SnapshotResponse) Descriptor() ([]byte, []int)

Deprecated: Use SnapshotResponse.ProtoReflect.Descriptor instead.

func (*SnapshotResponse) ProtoMessage

func (*SnapshotResponse) ProtoMessage()

func (*SnapshotResponse) ProtoReflect

func (x *SnapshotResponse) ProtoReflect() protoreflect.Message

func (*SnapshotResponse) Reset

func (x *SnapshotResponse) Reset()

func (*SnapshotResponse) String

func (x *SnapshotResponse) String() string

type StreamMetricsMessage

type StreamMetricsMessage struct {
	Identity *Identity `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// A list of metric entries
	EnvoyMetrics []*_go.MetricFamily `protobuf:"bytes,2,rep,name=envoy_metrics,json=envoyMetrics,proto3" json:"envoy_metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamMetricsMessage) Descriptor deprecated

func (*StreamMetricsMessage) Descriptor() ([]byte, []int)

Deprecated: Use StreamMetricsMessage.ProtoReflect.Descriptor instead.

func (*StreamMetricsMessage) GetEnvoyMetrics

func (x *StreamMetricsMessage) GetEnvoyMetrics() []*_go.MetricFamily

func (*StreamMetricsMessage) GetIdentity

func (x *StreamMetricsMessage) GetIdentity() *Identity

func (*StreamMetricsMessage) ProtoMessage

func (*StreamMetricsMessage) ProtoMessage()

func (*StreamMetricsMessage) ProtoReflect

func (x *StreamMetricsMessage) ProtoReflect() protoreflect.Message

func (*StreamMetricsMessage) Reset

func (x *StreamMetricsMessage) Reset()

func (*StreamMetricsMessage) String

func (x *StreamMetricsMessage) String() string

type StreamMetricsResponse

type StreamMetricsResponse struct {
	// contains filtered or unexported fields
}

func (*StreamMetricsResponse) Descriptor deprecated

func (*StreamMetricsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamMetricsResponse.ProtoReflect.Descriptor instead.

func (*StreamMetricsResponse) ProtoMessage

func (*StreamMetricsResponse) ProtoMessage()

func (*StreamMetricsResponse) ProtoReflect

func (x *StreamMetricsResponse) ProtoReflect() protoreflect.Message

func (*StreamMetricsResponse) Reset

func (x *StreamMetricsResponse) Reset()

func (*StreamMetricsResponse) String

func (x *StreamMetricsResponse) String() string

type UnimplementedDirectorServer

type UnimplementedDirectorServer struct {
}

UnimplementedDirectorServer must be embedded to have forward compatible implementations.

func (UnimplementedDirectorServer) Report

func (UnimplementedDirectorServer) ReportCommandResult

func (UnimplementedDirectorServer) ReportStream

func (UnimplementedDirectorServer) Retrieve

func (UnimplementedDirectorServer) StreamDiagnostics added in v3.1.0

func (UnimplementedDirectorServer) StreamMetrics

type UnsafeDirectorServer added in v3.2.0

type UnsafeDirectorServer interface {
	// contains filtered or unexported methods
}

UnsafeDirectorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DirectorServer will result in compilation errors.

Jump to

Keyboard shortcuts

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