impl

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 13, 2024 License: Apache-2.0 Imports: 55 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_kube_proto protoreflect.FileDescriptor

Functions

func Deploy 

func Deploy(ctx context.Context, configFilename string) error

Deploy generates a Kubernetes YAML file and corresponding Docker image to deploy the Service Weaver application specified by the provided kube.yaml config file.

func NewBabysitter 

func NewBabysitter(ctx context.Context, app *protos.AppConfig, config *BabysitterConfig, components []string, opts BabysitterOptions) (*babysitter, error)

func ToolVersion 

func ToolVersion() (string, bool, error)

ToolVersion returns the version of the running tool binary, along with an indication whether the tool was built manually, i.e., not via go install.

Types

type AntipodeAgentOptions 

type AntipodeAgentOptions struct {

	// the type of the datastore e.g. "redis"
	DatastoreType string `protobuf:"bytes,1,opt,name=datastoreType,proto3" json:"datastoreType,omitempty"`
	// the datastore host
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// the datastore port
	Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	// the datastore user
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// the datastore password
	Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// the datastore name
	Datastore string `protobuf:"bytes,6,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*AntipodeAgentOptions) Descriptor deprecated 

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

Deprecated: Use AntipodeAgentOptions.ProtoReflect.Descriptor instead.

func (*AntipodeAgentOptions) GetDatastore 

func (x *AntipodeAgentOptions) GetDatastore() string

func (*AntipodeAgentOptions) GetDatastoreType 

func (x *AntipodeAgentOptions) GetDatastoreType() string

func (*AntipodeAgentOptions) GetHost 

func (x *AntipodeAgentOptions) GetHost() string

func (*AntipodeAgentOptions) GetPassword 

func (x *AntipodeAgentOptions) GetPassword() string

func (*AntipodeAgentOptions) GetPort 

func (x *AntipodeAgentOptions) GetPort() string

func (*AntipodeAgentOptions) GetUser 

func (x *AntipodeAgentOptions) GetUser() string

func (*AntipodeAgentOptions) ProtoMessage 

func (*AntipodeAgentOptions) ProtoMessage()

func (*AntipodeAgentOptions) ProtoReflect 

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

func (*AntipodeAgentOptions) Reset 

func (x *AntipodeAgentOptions) Reset()

func (*AntipodeAgentOptions) String 

func (x *AntipodeAgentOptions) String() string

type BabysitterConfig 

type BabysitterConfig struct {
	Namespace    string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`                           // Kubernetes namespace
	DeploymentId string           `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // globally unique deployment id
	Listeners    map[string]int32 ``                                                                                                  // a map from listener name to port
	/* 160-byte string literal not displayed */
	AntipodeAgents map[string]*AntipodeAgentOptions `` // a map from Antipode agent name to AntipodeAgentOptions
	/* 169-byte string literal not displayed */
	Groups map[string]string `` // a map from component name to group name
	/* 153-byte string literal not displayed */
	Telemetry *Telemetry `protobuf:"bytes,6,opt,name=telemetry,proto3" json:"telemetry,omitempty"` // options to control how the telemetry is being manipulated.
	// contains filtered or unexported fields
}

BabysitterConfig contains configuration passed to a babysitter.

func (*BabysitterConfig) Descriptor deprecated 

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

Deprecated: Use BabysitterConfig.ProtoReflect.Descriptor instead.

func (*BabysitterConfig) GetAntipodeAgents 

func (x *BabysitterConfig) GetAntipodeAgents() map[string]*AntipodeAgentOptions

func (*BabysitterConfig) GetDeploymentId 

func (x *BabysitterConfig) GetDeploymentId() string

func (*BabysitterConfig) GetGroups 

func (x *BabysitterConfig) GetGroups() map[string]string

func (*BabysitterConfig) GetListeners 

func (x *BabysitterConfig) GetListeners() map[string]int32

func (*BabysitterConfig) GetNamespace 

func (x *BabysitterConfig) GetNamespace() string

func (*BabysitterConfig) GetTelemetry 

func (x *BabysitterConfig) GetTelemetry() *Telemetry

func (*BabysitterConfig) ProtoMessage 

func (*BabysitterConfig) ProtoMessage()

func (*BabysitterConfig) ProtoReflect 

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

func (*BabysitterConfig) Reset 

func (x *BabysitterConfig) Reset()

func (*BabysitterConfig) String 

func (x *BabysitterConfig) String() string

type BabysitterOptions 

type BabysitterOptions struct {
	HandleLogEntry   func(context.Context, *protos.LogEntry) error
	HandleTraceSpans func(context.Context, []trace.ReadOnlySpan) error
	HandleMetrics    func(context.Context, []*metrics.MetricSnapshot) error
}

BabysitterOptions configure a babysitter. See tool.Plugins for details.

type MetricOptions 

type MetricOptions struct {

	// If true, the deployer also exports metrics created implicitly by the
	// framework; e.g., autogenerated metrics, http metrics.
	AutoGenerateMetrics bool `protobuf:"varint,1,opt,name=auto_generate_metrics,json=autoGenerateMetrics,proto3" json:"auto_generate_metrics,omitempty"`
	// How often to export the metrics to Google Cloud.
	ExportInterval *duration.Duration `protobuf:"bytes,2,opt,name=export_interval,json=exportInterval,proto3" json:"export_interval,omitempty"`
	// contains filtered or unexported fields
}

Options to configure how the metrics are handled by the deployer.

func (*MetricOptions) Descriptor deprecated 

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

Deprecated: Use MetricOptions.ProtoReflect.Descriptor instead.

func (*MetricOptions) GetAutoGenerateMetrics 

func (x *MetricOptions) GetAutoGenerateMetrics() bool

func (*MetricOptions) GetExportInterval 

func (x *MetricOptions) GetExportInterval() *duration.Duration

func (*MetricOptions) ProtoMessage 

func (*MetricOptions) ProtoMessage()

func (*MetricOptions) ProtoReflect 

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

func (*MetricOptions) Reset 

func (x *MetricOptions) Reset()

func (*MetricOptions) String 

func (x *MetricOptions) String() string

type Telemetry 

type Telemetry struct {
	Metrics *MetricOptions `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

Options to control how the telemetry is being manipulated.

func (*Telemetry) Descriptor deprecated 

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

Deprecated: Use Telemetry.ProtoReflect.Descriptor instead.

func (*Telemetry) GetMetrics 

func (x *Telemetry) GetMetrics() *MetricOptions

func (*Telemetry) ProtoMessage 

func (*Telemetry) ProtoMessage()

func (*Telemetry) ProtoReflect 

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

func (*Telemetry) Reset 

func (x *Telemetry) Reset()

func (*Telemetry) String 

func (x *Telemetry) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.