xds

Documentation

Index

• Constants
• Variables
• func New(cfg *any.Any, logger *zap.Logger, scope tally.Scope) (module.Module, error)
• func TypeUrl(message proto.Message) string
• type ClusterHashV3
  • func (ClusterHashV3) ID(node *gcpCoreV3.Node) string
• type ECDSConfig
• type ECDSResource
  • func NewECDSResource(cluster string, config *gcpCoreV3.TypedExtensionConfig) (*ECDSResource, error)
• type ECDSResourceGenerator
• type ECDSServer
  • func NewECDSServer(ctx context.Context, config cache.Cache, callbacks gcpServerV3.Callbacks) ECDSServer
• type Poller
  • func (p *Poller) Start(ctx context.Context)
• type RTDSConfig
• type RTDSResource
  • func NewRTDSResource(cluster string, keyValues []*RuntimeKeyValue) (*RTDSResource, error)
• type RTDSResourceGenerator
• type RuntimeKeyValue
• type SafeEcdsResourceMap
• type Server
  • func (s *Server) Register(r module.Registrar) error

Constants

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

Variables

var ECDSGeneratorsByTypeUrl = map[string]ECDSResourceGenerator{}

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

type ECDSServer interface {
	extensionconfigservice.ExtensionConfigDiscoveryServiceServer
}

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