local

Documentation

Index

• Constants
• Variables
• func Controller(context.Context) (string, *http.Client, error)
• func NewPrometheusHandler(db *metricdb.T, logger *slog.Logger) http.Handler
• func PrepareRollout(ctx context.Context, cfg *config.GKEConfig) (*controller.RolloutRequest, error)
• func RecordListener(ctx context.Context, s store.Store, cfg *config.GKEConfig, lis *nanny.Listener) error
• func RunController(ctx context.Context, region string, port int) error
• func RunDistributor(ctx context.Context, region string, port, managerPort int) error
• func RunManager(ctx context.Context, region string, port, proxyPort int) error
• func RunProxy(ctx context.Context, port int) error
• func Store(region string) (store.Store, error)
• type ListenState
  • func (*ListenState) Descriptor() ([]byte, []int)
  • func (x *ListenState) GetListeners() []*nanny.Listener
  • func (*ListenState) ProtoMessage()
  • func (x *ListenState) ProtoReflect() protoreflect.Message
  • func (x *ListenState) Reset()
  • func (x *ListenState) String() string
• type Starter
  • func NewStarter() (*Starter, error)
  • func (s *Starter) Start(ctx context.Context, cfg *config.GKEConfig, replicaSetName string) error
  • func (s *Starter) Stop(_ context.Context, versions []*config.GKEConfig) error

Constants

const PrometheusURL = "/metrics"

URL on the controller where the metrics are exported in the Prometheus format.

Variables

var (
	// The directories and files where "weaver gke-local" stores data.
	LogDir      = filepath.Join(runtime.LogsDir(), "gke-local")
	DataDir     = filepath.Join(must(runtime.DataDir()), "gke-local")
	MetricsFile = filepath.Join(DataDir, "metrics.db")
	TracesFile  = filepath.Join(DataDir, "traces.db")
)

var File_internal_local_local_proto protoreflect.FileDescriptor

Functions

func Controller

func Controller(context.Context) (string, *http.Client, error)

Controller returns the address the tool should use to connect to the controller, as well as the HTTP client that can be used to reach it.

func NewPrometheusHandler

func NewPrometheusHandler(db *metricdb.T, logger *slog.Logger) http.Handler

NewPrometheusHandler returns a Prometheus HTTP handler that exports metrics stored in the given metrics database. The returned handler supports the following query parameters:

• app=<app>, which restricts metrics to the given application, and
• version=<version>, which restricts metrics to the given app version.

func PrepareRollout

func PrepareRollout(ctx context.Context, cfg *config.GKEConfig) (*controller.RolloutRequest, error)

PrepareRollout returns a new rollout request for the given application version. This call may mutate the passed-in config.

func RecordListener

func RecordListener(ctx context.Context, s store.Store, cfg *config.GKEConfig, lis *nanny.Listener) error

RecordListener records the network listener exported by an application version.

func RunController

func RunController(ctx context.Context, region string, port int) error

RunController creates and runs a controller.

func RunDistributor

func RunDistributor(ctx context.Context, region string, port, managerPort int) error

RunDistributor creates and runs a distributor.

func RunManager

func RunManager(ctx context.Context, region string, port, proxyPort int) error

RunManager creates and runs a manager.

func RunProxy

func RunProxy(ctx context.Context, port int) error

RunProxy creates and runs a proxy listening on ":port".

func Store

func Store(region string) (store.Store, error)

Store returns a store that persists data in the given directory. If the directory does not exist, it is created.

Types

type ListenState

type ListenState struct {

	// Listeners is the set of all exported listeners in the deployment.
	Listeners []*nanny.Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

ListenState contains the state stored for the network listeners in the store.

func (*ListenState) Descriptor

func (*ListenState) Descriptor() ([]byte, []int)

Deprecated: Use ListenState.ProtoReflect.Descriptor instead.

func (*ListenState) GetListeners

func (x *ListenState) GetListeners() []*nanny.Listener

func (*ListenState) ProtoMessage

func (*ListenState) ProtoMessage()

func (*ListenState) ProtoReflect

func (x *ListenState) ProtoReflect() protoreflect.Message

func (*ListenState) Reset

func (x *ListenState) Reset()

func (*ListenState) String

func (x *ListenState) String() string

type Starter

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

Starter starts ReplicaSets on the local machine.

func NewStarter

func NewStarter() (*Starter, error)

NewStarter creates a starter that runs all replicas of a colocation group as OS processes on the local machine.

func (*Starter) Start

func (s *Starter) Start(ctx context.Context, cfg *config.GKEConfig, replicaSetName string) error

Start starts the ReplicaSet for a given deployment.

func (*Starter) Stop

func (s *Starter) Stop(_ context.Context, versions []*config.GKEConfig) error

Stop kills processes in all of the versions' replica sets, blocking until all of the processes are killed.