probe

Documentation

Index

• Constants
• func GrpcProtocolProvider(caAddress string, dialOpts []grpc.DialOption) (protocol.CAProtocol, error)
• type CAProtocolProvider
• type LivenessCheckController
  • func NewLivenessCheckController(probeCheckInterval time.Duration, caAddr string, ca *ca.IstioCA, ...) (*LivenessCheckController, error)
  • func (c *LivenessCheckController) Run()

Constants

const (
	// LivenessProbeClientIdentity is the default identity for the liveness probe check
	LivenessProbeClientIdentity = "k8s.cluster.local"
)

Functions

func GrpcProtocolProvider

func GrpcProtocolProvider(caAddress string, dialOpts []grpc.DialOption) (protocol.CAProtocol, error)

GrpcProtocolProvider returns a CAProtocol instance talking to CA via gRPC.

Types

type CAProtocolProvider

type CAProtocolProvider func(caAddress string, dialOpts []grpc.DialOption) (protocol.CAProtocol, error)

CAProtocolProvider returns a CAProtocol instance for talking to CA.

type LivenessCheckController

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

LivenessCheckController updates the availability of the liveness probe of the CA instance

func NewLivenessCheckController

func NewLivenessCheckController(probeCheckInterval time.Duration, caAddr string,
	ca *ca.IstioCA, livenessProbeOptions *probe.Options,
	provider CAProtocolProvider) (*LivenessCheckController, error)

NewLivenessCheckController creates the liveness check controller instance

func (*LivenessCheckController) Run

func (c *LivenessCheckController) Run()

Run starts the check routine