xds

package
v0.0.0-...-f507469 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const Name = "clutch.module.chaos.experimentation.xds"

Variables

View Source
var ECDSGeneratorsByTypeUrl = map[string]ECDSResourceGenerator{}
View Source
var RTDSGeneratorsByTypeUrl = map[string]RTDSResourceGenerator{}

Functions

func New

func New(cfg *any.Any, logger *zap.Logger, scope tally.Scope) (module.Module, error)

func TypeUrl

func TypeUrl(message proto.Message) string

Types

type ClusterHashV3

type ClusterHashV3 struct{}

ClusterHash implements NodeHash interface

func (ClusterHashV3) ID

func (ClusterHashV3) ID(node *gcpCoreV3.Node) string

ID is an override method to use Cluster instead of a Node

type ECDSConfig

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

type ECDSResource

type ECDSResource struct {
	Cluster         string
	ExtensionConfig *gcpCoreV3.TypedExtensionConfig
}

func NewECDSResource

func NewECDSResource(cluster string, config *gcpCoreV3.TypedExtensionConfig) (*ECDSResource, error)

type ECDSResourceGenerator

type ECDSResourceGenerator interface {
	// Generates an ECDS resource for a given experiment. The implementation should return nil resource and
	// no error if it's not interested in creating resources for a given experiment.
	GenerateResource(experiment *experimentstore.Experiment) (*ECDSResource, error)
	// Generates an ECDS resource for a given experiment and a given resource name that
	// moves ECDS state back to its initial state - as if the receiver has not generated any ECDS
	// resource. The implementation of the method should return nil resource and no error if it receives
	// a `resourceName` that it doesn't recognize.
	GenerateDefaultResource(cluster string, resourceName string) (*ECDSResource, error)
}

type ECDSServer

func NewECDSServer

func NewECDSServer(ctx context.Context, config cache.Cache, callbacks gcpServerV3.Callbacks) ECDSServer

type Poller

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

func (*Poller) Start

func (p *Poller) Start(ctx context.Context)

type RTDSConfig

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

type RTDSResource

type RTDSResource struct {
	Cluster          string
	RuntimeKeyValues []*RuntimeKeyValue
}

func NewRTDSResource

func NewRTDSResource(cluster string, keyValues []*RuntimeKeyValue) (*RTDSResource, error)

type RTDSResourceGenerator

type RTDSResourceGenerator interface {
	// Generates an RTDS resource for a given experiment. The implementation of this method should
	// return a nil resource and no error if  the receiver is not interested in generating faults for a
	// passed experiment.
	GenerateResource(experiment *experimentstore.Experiment) (*RTDSResource, error)
}

type RuntimeKeyValue

type RuntimeKeyValue struct {
	Key   string
	Value uint32
}

type SafeEcdsResourceMap

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

type Server

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

Server serves xDS

func (*Server) Register

func (s *Server) Register(r module.Registrar) error

Directories

Path Synopsis
internal

Jump to

Keyboard shortcuts

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