endpoints

Documentation

Index

• func Middleware(log logrus.FieldLogger, metrics telemetry.Metrics) middleware.Middleware
• type Config
• type Endpoints
  • func New(c Config) *Endpoints
  • func (e *Endpoints) ListenAndServe(ctx context.Context) error
  • func (e *Endpoints) RunTCPAgent(ctx context.Context) error
• type PeerTrackerAttestor
  • func (a PeerTrackerAttestor) Attest(ctx context.Context) ([]*common.Selector, error)
• type Server

Functions

func Middleware

func Middleware(log logrus.FieldLogger, metrics telemetry.Metrics) middleware.Middleware

Types

type Config

type Config struct {
	BindAddr net.Addr

	AgentAddr *net.TCPAddr

	Attestor attestor.Attestor

	Manager manager.Manager

	Log logrus.FieldLogger

	Metrics telemetry.Metrics

	// The TLS Certificate resource name to use for the default X509-SVID with Envoy SDS
	DefaultSVIDName string

	// The Validation Context resource name to use when fetching X.509 bundle together with federated bundles with Envoy SDS
	DefaultAllBundlesName string

	// The Validation Context resource name to use for the default X.509 bundle with Envoy SDS
	DefaultBundleName string

	// Disable custom Envoy SDS validator
	DisableSPIFFECertValidation bool

	AllowUnauthenticatedVerifiers bool

	AllowedForeignJWTClaims []string

	TrustDomain spiffeid.TrustDomain
	// contains filtered or unexported fields
}

type Endpoints

type Endpoints struct {
	TCPAddr *net.TCPAddr
	// contains filtered or unexported fields
}

func New

func New(c Config) *Endpoints

func (*Endpoints) ListenAndServe

func (e *Endpoints) ListenAndServe(ctx context.Context) error

func (*Endpoints) RunTCPAgent

func (e *Endpoints) RunTCPAgent(ctx context.Context) error

runTCPServer will start the agent and block until it exits or we are dying.

type PeerTrackerAttestor

type PeerTrackerAttestor struct {
	Attestor attestor.Attestor
}

func (PeerTrackerAttestor) Attest

func (a PeerTrackerAttestor) Attest(ctx context.Context) ([]*common.Selector, error)

type Server

type Server interface {
	ListenAndServe(ctx context.Context) error
	RunTCPAgent(ctx context.Context) error
}