agent

package
v2.0.2-rc.1 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_agent_director_proto protoreflect.FileDescriptor

Functions

func RegisterDirectorServer 

func RegisterDirectorServer(s *grpc.Server, 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"`
	// contains filtered or unexported fields
}

An individual instruction from the CEPC

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) 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 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 *duration.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 CEPC 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() *duration.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 {
	// Report a consistent Snapshot of information to the CEPC
	Report(ctx context.Context, in *Snapshot, opts ...grpc.CallOption) (*SnapshotResponse, error)
	// Retrieve Directives from the CEPC
	Retrieve(ctx context.Context, in *Identity, opts ...grpc.CallOption) (Director_RetrieveClient, error)
	RetrieveSnapshot(ctx context.Context, in *Identity, opts ...grpc.CallOption) (Director_RetrieveSnapshotClient, error)
}

DirectorClient is the client API for Director service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDirectorClient 

func NewDirectorClient(cc grpc.ClientConnInterface) DirectorClient

type DirectorServer 

type DirectorServer interface {
	// Report a consistent Snapshot of information to the CEPC
	Report(context.Context, *Snapshot) (*SnapshotResponse, error)
	// Retrieve Directives from the CEPC
	Retrieve(*Identity, Director_RetrieveServer) error
	RetrieveSnapshot(*Identity, Director_RetrieveSnapshotServer) error
}

DirectorServer is the server API for Director service.

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_RetrieveSnapshotClient 

type Director_RetrieveSnapshotClient interface {
	Recv() (*RawSnapshotChunk, error)
	grpc.ClientStream
}

type Director_RetrieveSnapshotServer 

type Director_RetrieveSnapshotServer interface {
	Send(*RawSnapshotChunk) error
	grpc.ServerStream
}

type Identity 

type Identity struct {

	// The account ID assigned by the CEPC
	//
	// Deprecated: Do not use.
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Ambassador version
	//
	// Deprecated: Do not use.
	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: Do not use.
	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 CEPC 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: Do not use.

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: Do not use.

func (*Identity) GetLicense 

func (x *Identity) GetLicense() string

func (*Identity) GetVersion deprecated 

func (x *Identity) GetVersion() string

Deprecated: Do not use.

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 RawSnapshotChunk 

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

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 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: Do not use.
	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 *timestamp.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 CEPC

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: Do not use.

func (*Snapshot) GetSnapshotTs 

func (x *Snapshot) GetSnapshotTs() *timestamp.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 UnimplementedDirectorServer 

type UnimplementedDirectorServer struct {
}

UnimplementedDirectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedDirectorServer) Report 

func (*UnimplementedDirectorServer) Report(context.Context, *Snapshot) (*SnapshotResponse, error)

func (*UnimplementedDirectorServer) Retrieve 

func (*UnimplementedDirectorServer) Retrieve(*Identity, Director_RetrieveServer) error

func (*UnimplementedDirectorServer) RetrieveSnapshot 

func (*UnimplementedDirectorServer) RetrieveSnapshot(*Identity, Director_RetrieveSnapshotServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.