babysitter

Documentation

Index

• type Babysitter
  • func Start(ctx context.Context, logger *slog.Logger, cfg *config.GKEConfig, ...) (*Babysitter, error)
  • func (b *Babysitter) ActivateComponent(ctx context.Context, req *protos.ActivateComponentRequest) (*protos.ActivateComponentReply, error)
  • func (b *Babysitter) CheckHealth(_ context.Context, req *protos.GetHealthRequest) (*protos.GetHealthReply, error)
  • func (b *Babysitter) ExportListener(ctx context.Context, req *protos.ExportListenerRequest) (*protos.ExportListenerReply, error)
  • func (b *Babysitter) GetListenerAddress(ctx context.Context, req *protos.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)
  • func (b *Babysitter) GetSelfCertificate(context.Context, *protos.GetSelfCertificateRequest) (*protos.GetSelfCertificateReply, error)
  • func (b *Babysitter) HandleLogEntry(_ context.Context, entry *protos.LogEntry) error
  • func (b *Babysitter) HandleTraceSpans(_ context.Context, traces *protos.TraceSpans) error
  • func (b *Babysitter) RunProfiling(_ context.Context, req *protos.GetProfileRequest) (*protos.GetProfileReply, error)
  • func (b *Babysitter) VerifyClientCertificate(_ context.Context, req *protos.VerifyClientCertificateRequest) (*protos.VerifyClientCertificateReply, error)
  • func (b *Babysitter) VerifyServerCertificate(_ context.Context, req *protos.VerifyServerCertificateRequest) (*protos.VerifyServerCertificateReply, error)
  • func (b *Babysitter) WeaveletInfo() *protos.WeaveletInfo
• type HttpClient
  • func (h *HttpClient) CheckHealth(ctx context.Context, req *protos.GetHealthRequest) (*protos.GetHealthReply, error)
  • func (h *HttpClient) RunProfiling(ctx context.Context, req *protos.GetProfileRequest) (*protos.GetProfileReply, error)
• type ReplicaWatcher

Types

type Babysitter

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

Babysitter starts and manages a weavelet inside the Pod.

func Start

func Start(
	ctx context.Context,
	logger *slog.Logger,
	cfg *config.GKEConfig,
	replicaSet string,
	projectName string,
	podName string,
	internalAddress string,
	mux *http.ServeMux,
	selfAddr string,
	manager endpoints.Manager,
	caCert *x509.Certificate,
	getSelfCert func() ([]byte, []byte, error),
	newReplicaWatcher func(context.Context, string) (ReplicaWatcher, error),
	logSaver func(*protos.LogEntry),
	traceSaver func(spans *protos.TraceSpans) error,
	metricExporter func(metrics []*metrics.MetricSnapshot) error,
) (*Babysitter, error)

Start creates and starts a new babysitter.

func (*Babysitter) ActivateComponent

func (b *Babysitter) ActivateComponent(ctx context.Context, req *protos.ActivateComponentRequest) (*protos.ActivateComponentReply, error)

ActivateComponent implements the envelope.EnvelopeHandler interface.

func (*Babysitter) CheckHealth

func (b *Babysitter) CheckHealth(_ context.Context, req *protos.GetHealthRequest) (*protos.GetHealthReply, error)

CheckHealth implements the endpoints.Babysitter interface.

func (*Babysitter) ExportListener

func (b *Babysitter) ExportListener(ctx context.Context, req *protos.ExportListenerRequest) (*protos.ExportListenerReply, error)

ExportListener implements the envelope.EnvelopeHandler interface.

func (*Babysitter) GetListenerAddress

func (b *Babysitter) GetListenerAddress(ctx context.Context, req *protos.GetListenerAddressRequest) (*protos.GetListenerAddressReply, error)

GetListenerAddress implements the envelope.EnvelopeHandler interface.

func (*Babysitter) GetSelfCertificate

func (b *Babysitter) GetSelfCertificate(context.Context, *protos.GetSelfCertificateRequest) (*protos.GetSelfCertificateReply, error)

func (*Babysitter) HandleLogEntry

func (b *Babysitter) HandleLogEntry(_ context.Context, entry *protos.LogEntry) error

HandleLogEntry implements the envelope.EnvelopeHandler interface.

func (*Babysitter) HandleTraceSpans

func (b *Babysitter) HandleTraceSpans(_ context.Context, traces *protos.TraceSpans) error

HandleTraceSpans implements the envelope.EnvelopeHandler interface.

func (*Babysitter) RunProfiling

func (b *Babysitter) RunProfiling(_ context.Context, req *protos.GetProfileRequest) (*protos.GetProfileReply, error)

RunProfiling implements the endpoints.Babysitter interface.

func (*Babysitter) VerifyClientCertificate

func (b *Babysitter) VerifyClientCertificate(_ context.Context, req *protos.VerifyClientCertificateRequest) (*protos.VerifyClientCertificateReply, error)

VerifyClientCertificate implements the envelope.EnvelopeHandler interface.

func (*Babysitter) VerifyServerCertificate

func (b *Babysitter) VerifyServerCertificate(_ context.Context, req *protos.VerifyServerCertificateRequest) (*protos.VerifyServerCertificateReply, error)

VerifyServerCertificate implements the envelope.EnvelopeHandler interface.

func (*Babysitter) WeaveletInfo

func (b *Babysitter) WeaveletInfo() *protos.WeaveletInfo

WeaveletInfo returns information about the weavelet managed by the babysitter.

type HttpClient

type HttpClient struct {
	Addr      string      // babysitter address
	TLSConfig *tls.Config // TLS config, possibly nil.
}

HttpClient is a Client that executes requests over HTTP.

func (*HttpClient) CheckHealth

func (h *HttpClient) CheckHealth(ctx context.Context, req *protos.GetHealthRequest) (*protos.GetHealthReply, error)

CheckHealth implements the endpoints.Babysitter interface.

func (*HttpClient) RunProfiling

func (h *HttpClient) RunProfiling(ctx context.Context, req *protos.GetProfileRequest) (*protos.GetProfileReply, error)

RunProfiling implements the endpoints.Babysitter interface.

type ReplicaWatcher

type ReplicaWatcher interface {
	// GetReplicas returns addresses of all replicas in a given replica set.
	// If there have been no changes since the last call to GetReplicas(),
	// this method will block.
	GetReplicas(context.Context) ([]string, error)
}

ReplicaWatcher maintains an up-to-date information about replicas in a ReplicaSet.