protos

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2023 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProfileType_name = map[int32]string{
		0: "Unspecified",
		1: "Heap",
		2: "CPU",
	}
	ProfileType_value = map[string]int32{
		"Unspecified": 0,
		"Heap":        1,
		"CPU":         2,
	}
)

Enum value maps for ProfileType.

View Source 
var (
	HealthStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "HEALTHY",
		2: "UNHEALTHY",
		3: "TERMINATED",
	}
	HealthStatus_value = map[string]int32{
		"UNKNOWN":    0,
		"HEALTHY":    1,
		"UNHEALTHY":  2,
		"TERMINATED": 3,
	}
)

Enum value maps for HealthStatus.

View Source 
var (
	MetricType_name = map[int32]string{
		0: "INVALID",
		1: "COUNTER",
		2: "GAUGE",
		3: "HISTOGRAM",
	}
	MetricType_value = map[string]int32{
		"INVALID":   0,
		"COUNTER":   1,
		"GAUGE":     2,
		"HISTOGRAM": 3,
	}
)

Enum value maps for MetricType.

View Source 
var (
	SpanKind_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INTERNAL",
		2: "SERVER",
		3: "CLIENT",
		4: "PRODUCER",
		5: "CONSUMER",
	}
	SpanKind_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INTERNAL":    1,
		"SERVER":      2,
		"CLIENT":      3,
		"PRODUCER":    4,
		"CONSUMER":    5,
	}
)

Enum value maps for SpanKind.

View Source 
var (
	Span_Status_Code_name = map[int32]string{
		0: "UNSET",
		1: "ERROR",
		2: "OK",
	}
	Span_Status_Code_value = map[string]int32{
		"UNSET": 0,
		"ERROR": 1,
		"OK":    2,
	}
)

Enum value maps for Span_Status_Code.

View Source 
var (
	Attribute_Value_Type_name = map[int32]string{
		0: "INVALID",
		1: "BOOL",
		2: "INT64",
		3: "FLOAT64",
		4: "STRING",
		5: "BOOLLIST",
		6: "INT64LIST",
		7: "FLOAT64LIST",
		8: "STRINGLIST",
	}
	Attribute_Value_Type_value = map[string]int32{
		"INVALID":     0,
		"BOOL":        1,
		"INT64":       2,
		"FLOAT64":     3,
		"STRING":      4,
		"BOOLLIST":    5,
		"INT64LIST":   6,
		"FLOAT64LIST": 7,
		"STRINGLIST":  8,
	}
)

Enum value maps for Attribute_Value_Type.

View Source 
var File_runtime_protos_runtime_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AppConfig 

type AppConfig struct {

	// Application name (derived from binary if missing).
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// File name of the binary that implements the app.
	Binary string `protobuf:"bytes,1,opt,name=binary,proto3" json:"binary,omitempty"`
	// Arguments to pass to the binary.
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// Environment variables available to the binary. Every entry should be of the
	// form "key=value". If a key appears more than once, only the last value of
	// the key is used.
	Env []string `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"`
	// Groups of components that must be co-located together in the same OS
	// process.
	//
	// This grouping allows the developer a level of control on where the
	// Service Weaver runtime wil place each component. For example, suppose that
	// the application binary contains six components: A, B, C, D, E, and F.
	// Furthermore, suppose that the developer specifies the following
	// grouping in the config.
	//
	//	same_process = [[A, B], [C, D, E]]
	//
	// In that case, no matter what algorithm the Service Weaver runtime uses to
	// place the components, components A and B will always be grouped together,
	// and components C, D, and E will always be grouped together. This means that
	// a pair of replicas of the components can share in-memory state and
	// communicate efficiently with each other (though not with other replicas).
	//
	// The placement algorithm the Service Weaver runtime uses varies across
	// deployment environment. For example, a multiprocess deployer may choose
	// to place each component into its own group, for maximum parallelism. A
	// singleprocess deployer, on the other hand, may choose to group all of the
	// components together. Regardless of which deployment environment is used,
	// however, this configuration option guarantees that specified components
	// will end up in the same group.
	//
	// Components are identified using their full package paths, e.g.:
	//
	//	"github.com/my/project/package/ComponentName"
	//
	// , with the exception of the component associated with the application
	// main(), which is identified using the name "main".
	//
	// TODO(spetrovic): Rename to colocate.
	SameProcess []*ComponentGroup `protobuf:"bytes,20,rep,name=same_process,json=sameProcess,proto3" json:"same_process,omitempty"`
	// A knob that lets the user specifies how many nanoseconds it expects for
	// the rollout to take. This is used internally by Service Weaver to figure
	// out the rollout strategy.
	//
	// If not specified, Service Weaver will pick a default value.
	RolloutNanos int64 `protobuf:"varint,4,opt,name=rollout_nanos,json=rolloutNanos,proto3" json:"rollout_nanos,omitempty"`
	// All config sections (includes [serviceweaver], [<deployer>], and
	// [<component>] sections).
	Sections map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

AppConfig holds configuration for a Service Weaver application.

func (*AppConfig) Descriptor deprecated 

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

Deprecated: Use AppConfig.ProtoReflect.Descriptor instead.

func (*AppConfig) GetArgs 

func (x *AppConfig) GetArgs() []string

func (*AppConfig) GetBinary 

func (x *AppConfig) GetBinary() string

func (*AppConfig) GetEnv 

func (x *AppConfig) GetEnv() []string

func (*AppConfig) GetName 

func (x *AppConfig) GetName() string

func (*AppConfig) GetRolloutNanos 

func (x *AppConfig) GetRolloutNanos() int64

func (*AppConfig) GetSameProcess 

func (x *AppConfig) GetSameProcess() []*ComponentGroup

func (*AppConfig) GetSections 

func (x *AppConfig) GetSections() map[string]string

func (*AppConfig) ProtoMessage 

func (*AppConfig) ProtoMessage()

func (*AppConfig) ProtoReflect 

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

func (*AppConfig) Reset 

func (x *AppConfig) Reset()

func (*AppConfig) String 

func (x *AppConfig) String() string

type Assignment 

type Assignment struct {
	Slices []*Assignment_Slice `protobuf:"bytes,1,rep,name=slices,proto3" json:"slices,omitempty"`
	// An assignment is scoped to a particular component in a particular deployment.
	// For example, different components in the same deployment or the same component in
	// different deployments get their own assignments. The assignment for a
	// component can change over time. Every one of these assignments is given a
	// monotonically increasing version. Versions are unique for a given component,
	// but not unique across components.
	App          string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	DeploymentId string `protobuf:"bytes,3,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Component    string `protobuf:"bytes,4,opt,name=component,proto3" json:"component,omitempty"`
	Version      uint64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Assignment stores key assignments for a given component.

An assignment partitions a key space (e.g., the hash space [0, 2^64)) into a set of subregions, called slices, and assigns each slice to a set of replicas.

func (*Assignment) Descriptor deprecated 

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

Deprecated: Use Assignment.ProtoReflect.Descriptor instead.

func (*Assignment) GetApp 

func (x *Assignment) GetApp() string

func (*Assignment) GetComponent 

func (x *Assignment) GetComponent() string

func (*Assignment) GetDeploymentId 

func (x *Assignment) GetDeploymentId() string

func (*Assignment) GetSlices 

func (x *Assignment) GetSlices() []*Assignment_Slice

func (*Assignment) GetVersion 

func (x *Assignment) GetVersion() uint64

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) ProtoReflect 

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

func (*Assignment) Reset 

func (x *Assignment) Reset()

func (*Assignment) String 

func (x *Assignment) String() string

type Assignment_Slice 

type Assignment_Slice struct {

	// Inclusive start key. Strictly greater than the `start` value for the
	// previous entry in the current assignment.
	//
	// The first slice should always set start to 0.
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// Replicas assigned to host this slice. The implementation will set
	// these values to strings of the form "<net>://<addr>". E.g.,
	//
	//	tcp://host:1234
	//	unix:///tmp/unix.sock
	Replicas []string `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// contains filtered or unexported fields
}

Represents a slice and the replicas to which it is assigned.

func (*Assignment_Slice) Descriptor deprecated 

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

Deprecated: Use Assignment_Slice.ProtoReflect.Descriptor instead.

func (*Assignment_Slice) GetReplicas 

func (x *Assignment_Slice) GetReplicas() []string

func (*Assignment_Slice) GetStart 

func (x *Assignment_Slice) GetStart() uint64

func (*Assignment_Slice) ProtoMessage 

func (*Assignment_Slice) ProtoMessage()

func (*Assignment_Slice) ProtoReflect 

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

func (*Assignment_Slice) Reset 

func (x *Assignment_Slice) Reset()

func (*Assignment_Slice) String 

func (x *Assignment_Slice) String() string

type Attribute 

type Attribute struct {
	Key   string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *Attribute_Value `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Attribute is a key-value pair representing a component property.

TODO(mwhittaker): Nest in Span. Attribute is too generic.

func (*Attribute) Descriptor deprecated 

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

Deprecated: Use Attribute.ProtoReflect.Descriptor instead.

func (*Attribute) GetKey 

func (x *Attribute) GetKey() string

func (*Attribute) GetValue 

func (x *Attribute) GetValue() *Attribute_Value

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) ProtoReflect 

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

func (*Attribute) Reset 

func (x *Attribute) Reset()

func (*Attribute) String 

func (x *Attribute) String() string

type Attribute_Value 

type Attribute_Value struct {
	Type Attribute_Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=runtime.Attribute_Value_Type" json:"type,omitempty"` // Attribute type
	// Types that are assignable to Value:
	//
	//	*Attribute_Value_Num
	//	*Attribute_Value_Str
	//	*Attribute_Value_Nums
	//	*Attribute_Value_Strs
	Value isAttribute_Value_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Attribute_Value) Descriptor deprecated 

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

Deprecated: Use Attribute_Value.ProtoReflect.Descriptor instead.

func (*Attribute_Value) GetNum 

func (x *Attribute_Value) GetNum() uint64

func (*Attribute_Value) GetNums 

func (x *Attribute_Value) GetNums() *Attribute_Value_NumberList

func (*Attribute_Value) GetStr 

func (x *Attribute_Value) GetStr() string

func (*Attribute_Value) GetStrs 

func (x *Attribute_Value) GetStrs() *Attribute_Value_StringList

func (*Attribute_Value) GetType 

func (x *Attribute_Value) GetType() Attribute_Value_Type

func (*Attribute_Value) GetValue 

func (m *Attribute_Value) GetValue() isAttribute_Value_Value

func (*Attribute_Value) ProtoMessage 

func (*Attribute_Value) ProtoMessage()

func (*Attribute_Value) ProtoReflect 

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

func (*Attribute_Value) Reset 

func (x *Attribute_Value) Reset()

func (*Attribute_Value) String 

func (x *Attribute_Value) String() string

type Attribute_Value_Num 

type Attribute_Value_Num struct {
	Num uint64 `protobuf:"varint,2,opt,name=num,proto3,oneof"`
}

type Attribute_Value_NumberList 

type Attribute_Value_NumberList struct {
	Nums []uint64 `protobuf:"varint,1,rep,packed,name=nums,proto3" json:"nums,omitempty"`
	// contains filtered or unexported fields
}

func (*Attribute_Value_NumberList) Descriptor deprecated 

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

Deprecated: Use Attribute_Value_NumberList.ProtoReflect.Descriptor instead.

func (*Attribute_Value_NumberList) GetNums 

func (x *Attribute_Value_NumberList) GetNums() []uint64

func (*Attribute_Value_NumberList) ProtoMessage 

func (*Attribute_Value_NumberList) ProtoMessage()

func (*Attribute_Value_NumberList) ProtoReflect 

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

func (*Attribute_Value_NumberList) Reset 

func (x *Attribute_Value_NumberList) Reset()

func (*Attribute_Value_NumberList) String 

func (x *Attribute_Value_NumberList) String() string

type Attribute_Value_Nums 

type Attribute_Value_Nums struct {
	Nums *Attribute_Value_NumberList `protobuf:"bytes,4,opt,name=nums,proto3,oneof"`
}

type Attribute_Value_Str 

type Attribute_Value_Str struct {
	Str string `protobuf:"bytes,3,opt,name=str,proto3,oneof"`
}

type Attribute_Value_StringList 

type Attribute_Value_StringList struct {
	Strs []string `protobuf:"bytes,2,rep,name=strs,proto3" json:"strs,omitempty"`
	// contains filtered or unexported fields
}

func (*Attribute_Value_StringList) Descriptor deprecated 

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

Deprecated: Use Attribute_Value_StringList.ProtoReflect.Descriptor instead.

func (*Attribute_Value_StringList) GetStrs 

func (x *Attribute_Value_StringList) GetStrs() []string

func (*Attribute_Value_StringList) ProtoMessage 

func (*Attribute_Value_StringList) ProtoMessage()

func (*Attribute_Value_StringList) ProtoReflect 

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

func (*Attribute_Value_StringList) Reset 

func (x *Attribute_Value_StringList) Reset()

func (*Attribute_Value_StringList) String 

func (x *Attribute_Value_StringList) String() string

type Attribute_Value_Strs 

type Attribute_Value_Strs struct {
	Strs *Attribute_Value_StringList `protobuf:"bytes,5,opt,name=strs,proto3,oneof"`
}

type Attribute_Value_Type 

type Attribute_Value_Type int32

Type describes the type of the value. 

const (
	Attribute_Value_INVALID     Attribute_Value_Type = 0 // Used when no value is set
	Attribute_Value_BOOL        Attribute_Value_Type = 1
	Attribute_Value_INT64       Attribute_Value_Type = 2
	Attribute_Value_FLOAT64     Attribute_Value_Type = 3
	Attribute_Value_STRING      Attribute_Value_Type = 4
	Attribute_Value_BOOLLIST    Attribute_Value_Type = 5
	Attribute_Value_INT64LIST   Attribute_Value_Type = 6
	Attribute_Value_FLOAT64LIST Attribute_Value_Type = 7
	Attribute_Value_STRINGLIST  Attribute_Value_Type = 8
)

func (Attribute_Value_Type) Descriptor 

func (Attribute_Value_Type) Descriptor() protoreflect.EnumDescriptor

func (Attribute_Value_Type) Enum 

func (x Attribute_Value_Type) Enum() *Attribute_Value_Type

func (Attribute_Value_Type) EnumDescriptor deprecated 

func (Attribute_Value_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Attribute_Value_Type.Descriptor instead.

func (Attribute_Value_Type) Number 

func (x Attribute_Value_Type) Number() protoreflect.EnumNumber

func (Attribute_Value_Type) String 

func (x Attribute_Value_Type) String() string

func (Attribute_Value_Type) Type 

func (Attribute_Value_Type) Type() protoreflect.EnumType

type ColocationGroup 

type ColocationGroup struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

A colocation group defines a set of components that are colocated together on the same machine or a VM. A colocation group may be replicated, in which case the communication between components in the same colocation group replica remains local to that replica.

func (*ColocationGroup) Descriptor deprecated 

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

Deprecated: Use ColocationGroup.ProtoReflect.Descriptor instead.

func (*ColocationGroup) GetName 

func (x *ColocationGroup) GetName() string

func (*ColocationGroup) ProtoMessage 

func (*ColocationGroup) ProtoMessage()

func (*ColocationGroup) ProtoReflect 

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

func (*ColocationGroup) Reset 

func (x *ColocationGroup) Reset()

func (*ColocationGroup) String 

func (x *ColocationGroup) String() string

type ComponentGroup added in v0.1.2 

type ComponentGroup struct {
	Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

A group of components. TODO(spetrovic): Unify with ColocationGroup.

func (*ComponentGroup) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ComponentGroup.ProtoReflect.Descriptor instead.

func (*ComponentGroup) GetComponents added in v0.1.2 

func (x *ComponentGroup) GetComponents() []string

func (*ComponentGroup) ProtoMessage added in v0.1.2 

func (*ComponentGroup) ProtoMessage()

func (*ComponentGroup) ProtoReflect added in v0.1.2 

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

func (*ComponentGroup) Reset added in v0.1.2 

func (x *ComponentGroup) Reset()

func (*ComponentGroup) String added in v0.1.2 

func (x *ComponentGroup) String() string

type ComponentToStart 

type ComponentToStart struct {
	App             string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	DeploymentId    string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	ColocationGroup string `protobuf:"bytes,3,opt,name=colocation_group,json=colocationGroup,proto3" json:"colocation_group,omitempty"`
	Component       string `protobuf:"bytes,4,opt,name=component,proto3" json:"component,omitempty"`
	IsRouted        bool   `protobuf:"varint,5,opt,name=isRouted,proto3" json:"isRouted,omitempty"` // whether the component is routed
	// contains filtered or unexported fields
}

ComponentToStart is a request to the envelope to register a component that should be started by the given colocation group.

func (*ComponentToStart) Descriptor deprecated 

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

Deprecated: Use ComponentToStart.ProtoReflect.Descriptor instead.

func (*ComponentToStart) GetApp 

func (x *ComponentToStart) GetApp() string

func (*ComponentToStart) GetColocationGroup 

func (x *ComponentToStart) GetColocationGroup() string

func (*ComponentToStart) GetComponent 

func (x *ComponentToStart) GetComponent() string

func (*ComponentToStart) GetDeploymentId 

func (x *ComponentToStart) GetDeploymentId() string

func (*ComponentToStart) GetIsRouted 

func (x *ComponentToStart) GetIsRouted() bool

func (*ComponentToStart) ProtoMessage 

func (*ComponentToStart) ProtoMessage()

func (*ComponentToStart) ProtoReflect 

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

func (*ComponentToStart) Reset 

func (x *ComponentToStart) Reset()

func (*ComponentToStart) String 

func (x *ComponentToStart) String() string

type ComponentsToStart 

type ComponentsToStart struct {

	// unchanged is set to true if the request was ended prematurely without
	// detecting a change. In this case, version and components to start are empty.
	Unchanged  bool     `protobuf:"varint,1,opt,name=unchanged,proto3" json:"unchanged,omitempty"`
	Version    string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Components []string `protobuf:"bytes,3,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

ComponentsToStart is a result of the GetComponentsToStart sent to the manager.

func (*ComponentsToStart) Descriptor deprecated 

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

Deprecated: Use ComponentsToStart.ProtoReflect.Descriptor instead.

func (*ComponentsToStart) GetComponents 

func (x *ComponentsToStart) GetComponents() []string

func (*ComponentsToStart) GetUnchanged 

func (x *ComponentsToStart) GetUnchanged() bool

func (*ComponentsToStart) GetVersion 

func (x *ComponentsToStart) GetVersion() string

func (*ComponentsToStart) ProtoMessage 

func (*ComponentsToStart) ProtoMessage()

func (*ComponentsToStart) ProtoReflect 

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

func (*ComponentsToStart) Reset 

func (x *ComponentsToStart) Reset()

func (*ComponentsToStart) String 

func (x *ComponentsToStart) String() string

type Deployment 

type Deployment struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the deployment.
	// Application configuration.
	App *AppConfig `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	// Run as a single process locally.
	SingleProcess bool `protobuf:"varint,10,opt,name=single_process,json=singleProcess,proto3" json:"single_process,omitempty"`
	// contains filtered or unexported fields
}

Deployment holds internal information necessary for an application deployment.

func (*Deployment) Descriptor deprecated 

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetApp 

func (x *Deployment) GetApp() *AppConfig

func (*Deployment) GetId 

func (x *Deployment) GetId() string

func (*Deployment) GetSingleProcess 

func (x *Deployment) GetSingleProcess() bool

func (*Deployment) ProtoMessage 

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect 

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

func (*Deployment) Reset 

func (x *Deployment) Reset()

func (*Deployment) String 

func (x *Deployment) String() string

type EnvelopeMsg 

type EnvelopeMsg struct {

	// Unique id identifies a request that is part of a synchronous call. A
	// request with positive id x expects a reply with negative id -x.
	// Non-synchronous calls have an id of 0.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// A request to the weavelet to send its current metrics.
	SendMetrics bool `protobuf:"varint,2,opt,name=send_metrics,json=sendMetrics,proto3" json:"send_metrics,omitempty"`
	// A request to the weavelet to send its health status.
	SendHealthStatus bool `protobuf:"varint,3,opt,name=send_health_status,json=sendHealthStatus,proto3" json:"send_health_status,omitempty"`
	// A request to the weavelet to profile itself and send back the profile
	// data.
	RunProfiling *RunProfiling `protobuf:"bytes,4,opt,name=run_profiling,json=runProfiling,proto3" json:"run_profiling,omitempty"`
	// A request to the weavelet to receive its weavelet information and respond
	// with acknowledgment.
	WeaveletInfo *WeaveletInfo `protobuf:"bytes,5,opt,name=weavelet_info,json=weaveletInfo,proto3" json:"weavelet_info,omitempty"`
	// A reply to the weavelet with the latest routing info.
	RoutingInfo *RoutingInfo `protobuf:"bytes,6,opt,name=routing_info,json=routingInfo,proto3" json:"routing_info,omitempty"`
	// A reply to the weavelet with the latest list of components to start.
	ComponentsToStart *ComponentsToStart `protobuf:"bytes,7,opt,name=components_to_start,json=componentsToStart,proto3" json:"components_to_start,omitempty"`
	// A reply to a GetAddressRequest.
	GetAddressReply *GetAddressReply `protobuf:"bytes,8,opt,name=get_address_reply,json=getAddressReply,proto3" json:"get_address_reply,omitempty"`
	// A reply to an ExportListenerRequest.
	ExportListenerReply *ExportListenerReply `protobuf:"bytes,9,opt,name=export_listener_reply,json=exportListenerReply,proto3" json:"export_listener_reply,omitempty"`
	// A reply to the weavelet with an error status.
	Error string `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

EnvelopeMsg holds a message sent by the envelope to the managed weavelet.

func (*EnvelopeMsg) Descriptor deprecated 

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

Deprecated: Use EnvelopeMsg.ProtoReflect.Descriptor instead.

func (*EnvelopeMsg) GetComponentsToStart 

func (x *EnvelopeMsg) GetComponentsToStart() *ComponentsToStart

func (*EnvelopeMsg) GetError 

func (x *EnvelopeMsg) GetError() string

func (*EnvelopeMsg) GetExportListenerReply 

func (x *EnvelopeMsg) GetExportListenerReply() *ExportListenerReply

func (*EnvelopeMsg) GetGetAddressReply added in v0.1.2 

func (x *EnvelopeMsg) GetGetAddressReply() *GetAddressReply

func (*EnvelopeMsg) GetId 

func (x *EnvelopeMsg) GetId() int64

func (*EnvelopeMsg) GetRoutingInfo 

func (x *EnvelopeMsg) GetRoutingInfo() *RoutingInfo

func (*EnvelopeMsg) GetRunProfiling 

func (x *EnvelopeMsg) GetRunProfiling() *RunProfiling

func (*EnvelopeMsg) GetSendHealthStatus 

func (x *EnvelopeMsg) GetSendHealthStatus() bool

func (*EnvelopeMsg) GetSendMetrics 

func (x *EnvelopeMsg) GetSendMetrics() bool

func (*EnvelopeMsg) GetWeaveletInfo 

func (x *EnvelopeMsg) GetWeaveletInfo() *WeaveletInfo

func (*EnvelopeMsg) ProtoMessage 

func (*EnvelopeMsg) ProtoMessage()

func (*EnvelopeMsg) ProtoReflect 

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

func (*EnvelopeMsg) Reset 

func (x *EnvelopeMsg) Reset()

func (*EnvelopeMsg) String 

func (x *EnvelopeMsg) String() string

type ExportListenerReply 

type ExportListenerReply struct {

	// If non-empty, a non-retriable error.
	//
	// TODO(mwhittaker): This field exists as a hack to avoid a weavelet retrying
	// this error. In the future, we should have a more robust way to avoid
	// retrying certain errors.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// The address of the proxy that forwards traffic to the returned listener, or
	// empty if there is no proxy.
	ProxyAddress string `protobuf:"bytes,2,opt,name=proxy_address,json=proxyAddress,proto3" json:"proxy_address,omitempty"`
	// contains filtered or unexported fields
}

ExportListenerReply is a reply to a ExportListenerRequest.

func (*ExportListenerReply) Descriptor deprecated 

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

Deprecated: Use ExportListenerReply.ProtoReflect.Descriptor instead.

func (*ExportListenerReply) GetError added in v0.1.2 

func (x *ExportListenerReply) GetError() string

func (*ExportListenerReply) GetProxyAddress 

func (x *ExportListenerReply) GetProxyAddress() string

func (*ExportListenerReply) ProtoMessage 

func (*ExportListenerReply) ProtoMessage()

func (*ExportListenerReply) ProtoReflect 

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

func (*ExportListenerReply) Reset 

func (x *ExportListenerReply) Reset()

func (*ExportListenerReply) String 

func (x *ExportListenerReply) String() string

type ExportListenerRequest added in v0.1.2 

type ExportListenerRequest struct {
	Listener     *Listener `protobuf:"bytes,1,opt,name=listener,proto3" json:"listener,omitempty"`                             // listener
	LocalAddress string    `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"` // LocalAddress argument in ListenerOptions
	// contains filtered or unexported fields
}

ExportListenerRequest is a request to export the provided listener.

func (*ExportListenerRequest) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.

func (*ExportListenerRequest) GetListener added in v0.1.2 

func (x *ExportListenerRequest) GetListener() *Listener

func (*ExportListenerRequest) GetLocalAddress added in v0.1.2 

func (x *ExportListenerRequest) GetLocalAddress() string

func (*ExportListenerRequest) ProtoMessage added in v0.1.2 

func (*ExportListenerRequest) ProtoMessage()

func (*ExportListenerRequest) ProtoReflect added in v0.1.2 

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

func (*ExportListenerRequest) Reset added in v0.1.2 

func (x *ExportListenerRequest) Reset()

func (*ExportListenerRequest) String added in v0.1.2 

func (x *ExportListenerRequest) String() string

type GetAddressReply added in v0.1.2 

type GetAddressReply struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // address to listen on
	// contains filtered or unexported fields
}

GetAddressReply is a reply to a GetAddressRequest.

func (*GetAddressReply) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use GetAddressReply.ProtoReflect.Descriptor instead.

func (*GetAddressReply) GetAddress added in v0.1.2 

func (x *GetAddressReply) GetAddress() string

func (*GetAddressReply) ProtoMessage added in v0.1.2 

func (*GetAddressReply) ProtoMessage()

func (*GetAddressReply) ProtoReflect added in v0.1.2 

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

func (*GetAddressReply) Reset added in v0.1.2 

func (x *GetAddressReply) Reset()

func (*GetAddressReply) String added in v0.1.2 

func (x *GetAddressReply) String() string

type GetAddressRequest added in v0.1.2 

type GetAddressRequest struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                     // listener name
	LocalAddress string `protobuf:"bytes,2,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"` // LocalAddress argument in ListenerOptions
	// contains filtered or unexported fields
}

GetAddressRequest is a request for the address a weavelet should listen on for a particular listener.

Imagine a weavelet calls GetListener with LocalAdress localhost:9000. Here are some examples of how different deployers may handle a GetAddressRequest.

  • The singleprocess deployer may instruct the weavelet to listen directly on localhost:9000.
  • The multiprocess deployer may instruct the weavelet to listen on localhost:0. It will separately start a proxy on localhost:9000.
  • The SSH deployer may instruct the weavelet to listen on $HOSTNAME:0. It will separately start a proxy on localhost:9000.

func (*GetAddressRequest) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use GetAddressRequest.ProtoReflect.Descriptor instead.

func (*GetAddressRequest) GetLocalAddress added in v0.1.2 

func (x *GetAddressRequest) GetLocalAddress() string

func (*GetAddressRequest) GetName added in v0.1.2 

func (x *GetAddressRequest) GetName() string

func (*GetAddressRequest) ProtoMessage added in v0.1.2 

func (*GetAddressRequest) ProtoMessage()

func (*GetAddressRequest) ProtoReflect added in v0.1.2 

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

func (*GetAddressRequest) Reset added in v0.1.2 

func (x *GetAddressRequest) Reset()

func (*GetAddressRequest) String added in v0.1.2 

func (x *GetAddressRequest) String() string

type GetComponentsToStart 

type GetComponentsToStart struct {
	App          string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Group        string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Version      string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

GetComponentsToStart is a request to the envelope to retrieve the set of components that should be started by a given colocation group.

func (*GetComponentsToStart) Descriptor deprecated 

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

Deprecated: Use GetComponentsToStart.ProtoReflect.Descriptor instead.

func (*GetComponentsToStart) GetApp 

func (x *GetComponentsToStart) GetApp() string

func (*GetComponentsToStart) GetDeploymentId 

func (x *GetComponentsToStart) GetDeploymentId() string

func (*GetComponentsToStart) GetGroup added in v0.1.2 

func (x *GetComponentsToStart) GetGroup() string

func (*GetComponentsToStart) GetVersion 

func (x *GetComponentsToStart) GetVersion() string

func (*GetComponentsToStart) ProtoMessage 

func (*GetComponentsToStart) ProtoMessage()

func (*GetComponentsToStart) ProtoReflect 

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

func (*GetComponentsToStart) Reset 

func (x *GetComponentsToStart) Reset()

func (*GetComponentsToStart) String 

func (x *GetComponentsToStart) String() string

type GetRoutingInfo 

type GetRoutingInfo struct {
	App          string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	DeploymentId string `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Group        string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Version      string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

GetRoutingInfo is a request to retrieve routing information for a given colocation group.

func (*GetRoutingInfo) Descriptor deprecated 

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

Deprecated: Use GetRoutingInfo.ProtoReflect.Descriptor instead.

func (*GetRoutingInfo) GetApp 

func (x *GetRoutingInfo) GetApp() string

func (*GetRoutingInfo) GetDeploymentId 

func (x *GetRoutingInfo) GetDeploymentId() string

func (*GetRoutingInfo) GetGroup added in v0.1.2 

func (x *GetRoutingInfo) GetGroup() string

func (*GetRoutingInfo) GetVersion 

func (x *GetRoutingInfo) GetVersion() string

func (*GetRoutingInfo) ProtoMessage 

func (*GetRoutingInfo) ProtoMessage()

func (*GetRoutingInfo) ProtoReflect 

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

func (*GetRoutingInfo) Reset 

func (x *GetRoutingInfo) Reset()

func (*GetRoutingInfo) String 

func (x *GetRoutingInfo) String() string

type HealthReport 

type HealthReport struct {
	Status HealthStatus `protobuf:"varint,1,opt,name=status,proto3,enum=runtime.HealthStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

HealthReport contains the health report for a given replica.

func (*HealthReport) Descriptor deprecated 

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

Deprecated: Use HealthReport.ProtoReflect.Descriptor instead.

func (*HealthReport) GetStatus 

func (x *HealthReport) GetStatus() HealthStatus

func (*HealthReport) ProtoMessage 

func (*HealthReport) ProtoMessage()

func (*HealthReport) ProtoReflect 

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

func (*HealthReport) Reset 

func (x *HealthReport) Reset()

func (*HealthReport) String 

func (x *HealthReport) String() string

type HealthStatus 

type HealthStatus int32

HealthStatus specifies the possible types of health status for a replica. 

const (
	HealthStatus_UNKNOWN    HealthStatus = 0
	HealthStatus_HEALTHY    HealthStatus = 1
	HealthStatus_UNHEALTHY  HealthStatus = 2
	HealthStatus_TERMINATED HealthStatus = 3
)

func (HealthStatus) Descriptor 

func (HealthStatus) Descriptor() protoreflect.EnumDescriptor

func (HealthStatus) Enum 

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated 

func (HealthStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number 

func (x HealthStatus) Number() protoreflect.EnumNumber

func (HealthStatus) String 

func (x HealthStatus) String() string

func (HealthStatus) Type 

func (HealthStatus) Type() protoreflect.EnumType

type Listener 

type Listener struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // listener name
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` // network address
	// contains filtered or unexported fields
}

Listener holds information about a network listener.

func (*Listener) Descriptor deprecated 

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

Deprecated: Use Listener.ProtoReflect.Descriptor instead.

func (*Listener) GetAddr 

func (x *Listener) GetAddr() string

func (*Listener) GetName 

func (x *Listener) GetName() string

func (*Listener) ProtoMessage 

func (*Listener) ProtoMessage()

func (*Listener) ProtoReflect 

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

func (*Listener) Reset 

func (x *Listener) Reset()

func (*Listener) String 

func (x *Listener) String() string

type Listeners 

type Listeners struct {
	Listeners []*Listener `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

Listeners represents a set of network listeners.

func (*Listeners) Descriptor deprecated 

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

Deprecated: Use Listeners.ProtoReflect.Descriptor instead.

func (*Listeners) GetListeners 

func (x *Listeners) GetListeners() []*Listener

func (*Listeners) ProtoMessage 

func (*Listeners) ProtoMessage()

func (*Listeners) ProtoReflect 

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

func (*Listeners) Reset 

func (x *Listeners) Reset()

func (*Listeners) String 

func (x *Listeners) String() string

type LogEntry 

type LogEntry struct {
	App        string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                   // application name (e.g., todo)
	Version    string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`                           // deployment id (e.g., uuid.New().String())
	Component  string `protobuf:"bytes,3,opt,name=component,proto3" json:"component,omitempty"`                       // component  (e.g., Todo, stdout, stderr, global)
	Node       string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`                                 // weavelet id (e.g., uuid.New().String())
	TimeMicros int64  `protobuf:"fixed64,5,opt,name=time_micros,json=timeMicros,proto3" json:"time_micros,omitempty"` // time when logged (microseconds since epoch)
	Level      string `protobuf:"bytes,6,opt,name=level,proto3" json:"level,omitempty"`                               // log level (e.g., debug, info, warn, error, fatal)
	File       string `protobuf:"bytes,7,opt,name=file,proto3" json:"file,omitempty"`                                 // source file (e.g., // /tmp/serviceweaver/server.go)
	Line       int32  `protobuf:"varint,8,opt,name=line,proto3" json:"line,omitempty"`                                // source line // (e.g., 80)
	Msg        string `protobuf:"bytes,9,opt,name=msg,proto3" json:"msg,omitempty"`                                   // user provided msg (e.g., "Hello!")
	// User-provided attributes and their associated values. The storage format
	// is a name followed by its value, i.e.:
	//
	//	name1, value1, name2, value2, name3, value3, ...
	Attrs []string `protobuf:"bytes,10,rep,name=attrs,proto3" json:"attrs,omitempty"`
	// contains filtered or unexported fields
}

LogEntry is a log entry. Every log entry consists of a message (the thing the user logged) and a set of metadata describing the message.

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetApp 

func (x *LogEntry) GetApp() string

func (*LogEntry) GetAttrs 

func (x *LogEntry) GetAttrs() []string

func (*LogEntry) GetComponent 

func (x *LogEntry) GetComponent() string

func (*LogEntry) GetFile 

func (x *LogEntry) GetFile() string

func (*LogEntry) GetLevel 

func (x *LogEntry) GetLevel() string

func (*LogEntry) GetLine 

func (x *LogEntry) GetLine() int32

func (*LogEntry) GetMsg 

func (x *LogEntry) GetMsg() string

func (*LogEntry) GetNode 

func (x *LogEntry) GetNode() string

func (*LogEntry) GetTimeMicros 

func (x *LogEntry) GetTimeMicros() int64

func (*LogEntry) GetVersion 

func (x *LogEntry) GetVersion() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type MetricDef 

type MetricDef struct {
	Id     uint64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Typ    MetricType        `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"`
	Help   string            `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	Labels map[string]string ``                                                                           /* 153-byte string literal not displayed */
	Bounds []float64         `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"` // bucket bounds, for histograms
	// contains filtered or unexported fields
}

MetricDef is the definition of a new metric.

func (*MetricDef) Descriptor deprecated 

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

Deprecated: Use MetricDef.ProtoReflect.Descriptor instead.

func (*MetricDef) GetBounds 

func (x *MetricDef) GetBounds() []float64

func (*MetricDef) GetHelp 

func (x *MetricDef) GetHelp() string

func (*MetricDef) GetId 

func (x *MetricDef) GetId() uint64

func (*MetricDef) GetLabels 

func (x *MetricDef) GetLabels() map[string]string

func (*MetricDef) GetName 

func (x *MetricDef) GetName() string

func (*MetricDef) GetTyp 

func (x *MetricDef) GetTyp() MetricType

func (*MetricDef) ProtoMessage 

func (*MetricDef) ProtoMessage()

func (*MetricDef) ProtoReflect 

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

func (*MetricDef) Reset 

func (x *MetricDef) Reset()

func (*MetricDef) String 

func (x *MetricDef) String() string

type MetricSnapshot 

type MetricSnapshot struct {
	Id     uint64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Typ    MetricType        `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"`
	Help   string            `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`
	Labels map[string]string `` /* 153-byte string literal not displayed */
	Bounds []float64         `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"`
	Value  float64           `protobuf:"fixed64,7,opt,name=value,proto3" json:"value,omitempty"`
	Counts []uint64          `protobuf:"varint,8,rep,packed,name=counts,proto3" json:"counts,omitempty"`
	// contains filtered or unexported fields
}

MetricSnapshot is a snapshot of a metric. It is the union of a MetricDef and a MetricValue.

func (*MetricSnapshot) Descriptor deprecated 

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

Deprecated: Use MetricSnapshot.ProtoReflect.Descriptor instead.

func (*MetricSnapshot) GetBounds 

func (x *MetricSnapshot) GetBounds() []float64

func (*MetricSnapshot) GetCounts 

func (x *MetricSnapshot) GetCounts() []uint64

func (*MetricSnapshot) GetHelp 

func (x *MetricSnapshot) GetHelp() string

func (*MetricSnapshot) GetId 

func (x *MetricSnapshot) GetId() uint64

func (*MetricSnapshot) GetLabels 

func (x *MetricSnapshot) GetLabels() map[string]string

func (*MetricSnapshot) GetName 

func (x *MetricSnapshot) GetName() string

func (*MetricSnapshot) GetTyp 

func (x *MetricSnapshot) GetTyp() MetricType

func (*MetricSnapshot) GetValue 

func (x *MetricSnapshot) GetValue() float64

func (*MetricSnapshot) ProtoMessage 

func (*MetricSnapshot) ProtoMessage()

func (*MetricSnapshot) ProtoReflect 

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

func (*MetricSnapshot) Reset 

func (x *MetricSnapshot) Reset()

func (*MetricSnapshot) String 

func (x *MetricSnapshot) String() string

type MetricType 

type MetricType int32

MetricType specifies a particular kind of metric. 

const (
	MetricType_INVALID   MetricType = 0
	MetricType_COUNTER   MetricType = 1
	MetricType_GAUGE     MetricType = 2
	MetricType_HISTOGRAM MetricType = 3
)

func (MetricType) Descriptor 

func (MetricType) Descriptor() protoreflect.EnumDescriptor

func (MetricType) Enum 

func (x MetricType) Enum() *MetricType

func (MetricType) EnumDescriptor deprecated 

func (MetricType) EnumDescriptor() ([]byte, []int)

Deprecated: Use MetricType.Descriptor instead.

func (MetricType) Number 

func (x MetricType) Number() protoreflect.EnumNumber

func (MetricType) String 

func (x MetricType) String() string

func (MetricType) Type 

func (MetricType) Type() protoreflect.EnumType

type MetricUpdate 

type MetricUpdate struct {

	// Metric definitions and updated values.
	//
	// All metrics are identified by their globally unique id. Two endpoints
	// exchanging metric updates must ensure that a received metric value has been
	// preceded by a metric definition with the same id, either in the current
	// update or an earlier one.
	Defs   []*MetricDef   `protobuf:"bytes,1,rep,name=defs,proto3" json:"defs,omitempty"`     // metric definitions
	Values []*MetricValue `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"` // metric values
	// contains filtered or unexported fields
}

MetricUpdate contains the metrics' updated values.

func (*MetricUpdate) Descriptor deprecated 

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

Deprecated: Use MetricUpdate.ProtoReflect.Descriptor instead.

func (*MetricUpdate) GetDefs 

func (x *MetricUpdate) GetDefs() []*MetricDef

func (*MetricUpdate) GetValues 

func (x *MetricUpdate) GetValues() []*MetricValue

func (*MetricUpdate) ProtoMessage 

func (*MetricUpdate) ProtoMessage()

func (*MetricUpdate) ProtoReflect 

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

func (*MetricUpdate) Reset 

func (x *MetricUpdate) Reset()

func (*MetricUpdate) String 

func (x *MetricUpdate) String() string

type MetricValue 

type MetricValue struct {
	Id     uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`                // metric's unique id.
	Value  float64  `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`         // value for counter and gauge, sum for histogram
	Counts []uint64 `protobuf:"varint,3,rep,packed,name=counts,proto3" json:"counts,omitempty"` // histogram counts
	// contains filtered or unexported fields
}

MetricValue is the value associated with a metric.

func (*MetricValue) Descriptor deprecated 

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

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetCounts 

func (x *MetricValue) GetCounts() []uint64

func (*MetricValue) GetId 

func (x *MetricValue) GetId() uint64

func (*MetricValue) GetValue 

func (x *MetricValue) GetValue() float64

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect 

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

func (*MetricValue) Reset 

func (x *MetricValue) Reset()

func (*MetricValue) String 

func (x *MetricValue) String() string

type Profile 

type Profile struct {
	AppName   string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	VersionId string `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // Encoded profile data.
	// Errors encountered collecting the profile data.
	// Note that the profile data may be partially populated even if there are
	// collection errors.
	Errors []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

Profile stores profile data for a given application version.

func (*Profile) Descriptor deprecated 

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

Deprecated: Use Profile.ProtoReflect.Descriptor instead.

func (*Profile) GetAppName 

func (x *Profile) GetAppName() string

func (*Profile) GetData 

func (x *Profile) GetData() []byte

func (*Profile) GetErrors 

func (x *Profile) GetErrors() []string

func (*Profile) GetVersionId 

func (x *Profile) GetVersionId() string

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) ProtoReflect 

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

func (*Profile) Reset 

func (x *Profile) Reset()

func (*Profile) String 

func (x *Profile) String() string

type ProfileType 

type ProfileType int32

ProfileType specifies a type of profile to collect. 

const (
	ProfileType_Unspecified ProfileType = 0
	ProfileType_Heap        ProfileType = 1
	ProfileType_CPU         ProfileType = 2
)

func (ProfileType) Descriptor 

func (ProfileType) Descriptor() protoreflect.EnumDescriptor

func (ProfileType) Enum 

func (x ProfileType) Enum() *ProfileType

func (ProfileType) EnumDescriptor deprecated 

func (ProfileType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProfileType.Descriptor instead.

func (ProfileType) Number 

func (x ProfileType) Number() protoreflect.EnumNumber

func (ProfileType) String 

func (x ProfileType) String() string

func (ProfileType) Type 

func (ProfileType) Type() protoreflect.EnumType

type ReplicaToRegister 

type ReplicaToRegister struct {
	App            string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	GroupReplicaId string `protobuf:"bytes,2,opt,name=group_replica_id,json=groupReplicaId,proto3" json:"group_replica_id,omitempty"`
	DeploymentId   string `protobuf:"bytes,3,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"`
	Group          string `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Address        string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"` // Service Weaver RPC address for the replica.
	Pid            int64  `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`        // Service Weaver RPC address for the replica.
	// contains filtered or unexported fields
}

ReplicaToRegister is a request to the envelope to register a replica of a given colocation group.

func (*ReplicaToRegister) Descriptor deprecated 

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

Deprecated: Use ReplicaToRegister.ProtoReflect.Descriptor instead.

func (*ReplicaToRegister) GetAddress 

func (x *ReplicaToRegister) GetAddress() string

func (*ReplicaToRegister) GetApp 

func (x *ReplicaToRegister) GetApp() string

func (*ReplicaToRegister) GetDeploymentId 

func (x *ReplicaToRegister) GetDeploymentId() string

func (*ReplicaToRegister) GetGroup added in v0.1.2 

func (x *ReplicaToRegister) GetGroup() string

func (*ReplicaToRegister) GetGroupReplicaId 

func (x *ReplicaToRegister) GetGroupReplicaId() string

func (*ReplicaToRegister) GetPid 

func (x *ReplicaToRegister) GetPid() int64

func (*ReplicaToRegister) ProtoMessage 

func (*ReplicaToRegister) ProtoMessage()

func (*ReplicaToRegister) ProtoReflect 

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

func (*ReplicaToRegister) Reset 

func (x *ReplicaToRegister) Reset()

func (*ReplicaToRegister) String 

func (x *ReplicaToRegister) String() string

type RoutingInfo 

type RoutingInfo struct {

	// unchanged is set to true if the request was ended prematurely without
	// detecting a change. In this case, version and replicas are empty.
	Unchanged bool   `protobuf:"varint,1,opt,name=unchanged,proto3" json:"unchanged,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Each replica is a string of the form "<net>://<addr>". E.g.,
	//
	//	tcp://host:1234
	//	unix:///tmp/unix.sock
	Replicas []string `protobuf:"bytes,3,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// Assignments for all the routed components that are hosted by the
	// colocation group.
	Assignments []*Assignment `protobuf:"bytes,4,rep,name=assignments,proto3" json:"assignments,omitempty"`
	// contains filtered or unexported fields
}

RoutingInfo contains routing information for a colocation group.

func (*RoutingInfo) Descriptor deprecated 

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

Deprecated: Use RoutingInfo.ProtoReflect.Descriptor instead.

func (*RoutingInfo) GetAssignments 

func (x *RoutingInfo) GetAssignments() []*Assignment

func (*RoutingInfo) GetReplicas 

func (x *RoutingInfo) GetReplicas() []string

func (*RoutingInfo) GetUnchanged 

func (x *RoutingInfo) GetUnchanged() bool

func (*RoutingInfo) GetVersion 

func (x *RoutingInfo) GetVersion() string

func (*RoutingInfo) ProtoMessage 

func (*RoutingInfo) ProtoMessage()

func (*RoutingInfo) ProtoReflect 

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

func (*RoutingInfo) Reset 

func (x *RoutingInfo) Reset()

func (*RoutingInfo) String 

func (x *RoutingInfo) String() string

type RunProfiling 

type RunProfiling struct {
	AppName   string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	VersionId string `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	Group     string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"` // If non-empty, only profile the given colocation group.
	// Type of the profile we want to collect (e.g., heap, cpu).
	ProfileType ProfileType `protobuf:"varint,4,opt,name=profile_type,json=profileType,proto3,enum=runtime.ProfileType" json:"profile_type,omitempty"`
	// Duration for the CPU profile collection, in nanoseconds.
	CpuDurationNs int64 `protobuf:"varint,5,opt,name=cpu_duration_ns,json=cpuDurationNs,proto3" json:"cpu_duration_ns,omitempty"`
	// contains filtered or unexported fields
}

RunProfiling is a request to profile the given application version.

func (*RunProfiling) Descriptor deprecated 

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

Deprecated: Use RunProfiling.ProtoReflect.Descriptor instead.

func (*RunProfiling) GetAppName 

func (x *RunProfiling) GetAppName() string

func (*RunProfiling) GetCpuDurationNs 

func (x *RunProfiling) GetCpuDurationNs() int64

func (*RunProfiling) GetGroup added in v0.1.2 

func (x *RunProfiling) GetGroup() string

func (*RunProfiling) GetProfileType 

func (x *RunProfiling) GetProfileType() ProfileType

func (*RunProfiling) GetVersionId 

func (x *RunProfiling) GetVersionId() string

func (*RunProfiling) ProtoMessage 

func (*RunProfiling) ProtoMessage()

func (*RunProfiling) ProtoReflect 

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

func (*RunProfiling) Reset 

func (x *RunProfiling) Reset()

func (*RunProfiling) String 

func (x *RunProfiling) String() string

type Span 

type Span struct {
	Name         string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                       // Span name
	TraceId      []byte         `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                  // Span trace id
	SpanId       []byte         `protobuf:"bytes,3,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`                     // Unique span id
	ParentSpanId []byte         `protobuf:"bytes,4,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"` // If non-empty, the span's parent id
	Kind         SpanKind       `protobuf:"varint,5,opt,name=kind,proto3,enum=runtime.SpanKind" json:"kind,omitempty"`                // Span's role in the trace.
	StartMicros  int64          `protobuf:"fixed64,6,opt,name=start_micros,json=startMicros,proto3" json:"start_micros,omitempty"`    // Span start time (microseconds since epoch)
	EndMicros    int64          `protobuf:"fixed64,7,opt,name=end_micros,json=endMicros,proto3" json:"end_micros,omitempty"`          // Span end time (microseconds since epoch)
	Attributes   []*Attribute   `protobuf:"bytes,8,rep,name=attributes,proto3" json:"attributes,omitempty"`                           // Span attributes
	Links        []*Span_Link   `protobuf:"bytes,9,rep,name=links,proto3" json:"links,omitempty"`                                     // Links to other spans
	Events       []*Span_Event  `protobuf:"bytes,10,rep,name=events,proto3" json:"events,omitempty"`                                  // Events that occured in the span's lifetime
	Status       *Span_Status   `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`                                  // Span status
	Library      *Span_Library  `protobuf:"bytes,12,opt,name=library,proto3" json:"library,omitempty"`                                // Instrumentation library that created the span
	Resource     *Span_Resource `protobuf:"bytes,13,opt,name=resource,proto3" json:"resource,omitempty"`
	// Number of span attributes dropped due to limits being reached.
	DroppedAttributeCount int64 `` /* 128-byte string literal not displayed */
	// Number of links dropped due to limits being reached.
	DroppedLinkCount int64 `protobuf:"varint,15,opt,name=dropped_link_count,json=droppedLinkCount,proto3" json:"dropped_link_count,omitempty"`
	// Number of events dropped due to limits being reached.
	DroppedEventCount int64 `protobuf:"varint,16,opt,name=dropped_event_count,json=droppedEventCount,proto3" json:"dropped_event_count,omitempty"`
	// Number of spans that consider this span a direct parent.
	ChildSpanCount int64 `protobuf:"varint,17,opt,name=child_span_count,json=childSpanCount,proto3" json:"child_span_count,omitempty"`
	// contains filtered or unexported fields
}

Span is a proto-based representation of an open-telemetry Span.

func (*Span) Descriptor deprecated 

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetAttributes 

func (x *Span) GetAttributes() []*Attribute

func (*Span) GetChildSpanCount 

func (x *Span) GetChildSpanCount() int64

func (*Span) GetDroppedAttributeCount 

func (x *Span) GetDroppedAttributeCount() int64

func (*Span) GetDroppedEventCount 

func (x *Span) GetDroppedEventCount() int64

func (*Span) GetDroppedLinkCount 

func (x *Span) GetDroppedLinkCount() int64

func (*Span) GetEndMicros 

func (x *Span) GetEndMicros() int64

func (*Span) GetEvents 

func (x *Span) GetEvents() []*Span_Event

func (*Span) GetKind 

func (x *Span) GetKind() SpanKind

func (*Span) GetLibrary 

func (x *Span) GetLibrary() *Span_Library
func (x *Span) GetLinks() []*Span_Link

func (*Span) GetName 

func (x *Span) GetName() string

func (*Span) GetParentSpanId 

func (x *Span) GetParentSpanId() []byte

func (*Span) GetResource 

func (x *Span) GetResource() *Span_Resource

func (*Span) GetSpanId 

func (x *Span) GetSpanId() []byte

func (*Span) GetStartMicros 

func (x *Span) GetStartMicros() int64

func (*Span) GetStatus 

func (x *Span) GetStatus() *Span_Status

func (*Span) GetTraceId 

func (x *Span) GetTraceId() []byte

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) ProtoReflect 

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

func (*Span) Reset 

func (x *Span) Reset()

func (*Span) String 

func (x *Span) String() string

type SpanKind 

type SpanKind int32

SpanKind is the role a span plays in a trace. 

const (
	SpanKind_UNSPECIFIED SpanKind = 0
	SpanKind_INTERNAL    SpanKind = 1
	SpanKind_SERVER      SpanKind = 2
	SpanKind_CLIENT      SpanKind = 3
	SpanKind_PRODUCER    SpanKind = 4
	SpanKind_CONSUMER    SpanKind = 5
)

func (SpanKind) Descriptor 

func (SpanKind) Descriptor() protoreflect.EnumDescriptor

func (SpanKind) Enum 

func (x SpanKind) Enum() *SpanKind

func (SpanKind) EnumDescriptor deprecated 

func (SpanKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use SpanKind.Descriptor instead.

func (SpanKind) Number 

func (x SpanKind) Number() protoreflect.EnumNumber

func (SpanKind) String 

func (x SpanKind) String() string

func (SpanKind) Type 

func (SpanKind) Type() protoreflect.EnumType

type Span_Event 

type Span_Event struct {
	Name       string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                 // Even name
	TimeMicros int64        `protobuf:"fixed64,2,opt,name=time_micros,json=timeMicros,proto3" json:"time_micros,omitempty"` // Time the event was recorded (microseconds since epoch)
	Attributes []*Attribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"`                     // Event attributes
	// Number of attributes dropped due to limits being reached.
	DroppedAttributeCount int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Event represent an event that occurred in the span's lifetime.

func (*Span_Event) Descriptor deprecated 

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

Deprecated: Use Span_Event.ProtoReflect.Descriptor instead.

func (*Span_Event) GetAttributes 

func (x *Span_Event) GetAttributes() []*Attribute

func (*Span_Event) GetDroppedAttributeCount 

func (x *Span_Event) GetDroppedAttributeCount() int64

func (*Span_Event) GetName 

func (x *Span_Event) GetName() string

func (*Span_Event) GetTimeMicros 

func (x *Span_Event) GetTimeMicros() int64

func (*Span_Event) ProtoMessage 

func (*Span_Event) ProtoMessage()

func (*Span_Event) ProtoReflect 

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

func (*Span_Event) Reset 

func (x *Span_Event) Reset()

func (*Span_Event) String 

func (x *Span_Event) String() string

type Span_Library 

type Span_Library struct {

	// Name of the instrumentation library, typically the package name of
	// the library.
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version   string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`                      // The version of the instrumentation library
	SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"` // Schema url of the telemetry emitted by library
	// contains filtered or unexported fields
}

Library stores information about the instrumentation library that created the span.

func (*Span_Library) Descriptor deprecated 

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

Deprecated: Use Span_Library.ProtoReflect.Descriptor instead.

func (*Span_Library) GetName 

func (x *Span_Library) GetName() string

func (*Span_Library) GetSchemaUrl 

func (x *Span_Library) GetSchemaUrl() string

func (*Span_Library) GetVersion 

func (x *Span_Library) GetVersion() string

func (*Span_Library) ProtoMessage 

func (*Span_Library) ProtoMessage()

func (*Span_Library) ProtoReflect 

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

func (*Span_Library) Reset 

func (x *Span_Library) Reset()

func (*Span_Library) String 

func (x *Span_Library) String() string
type Span_Link struct {
	TraceId    []byte       `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // Span trace id
	SpanId     []byte       `protobuf:"bytes,2,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`    // Unique span id
	Attributes []*Attribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"`          // Span attributes
	// Number of span attributes dropped due to limits being reached
	DroppedAttributeCount int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Link represents the link a span has to another span.

func (*Span_Link) Descriptor deprecated 

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

Deprecated: Use Span_Link.ProtoReflect.Descriptor instead.

func (*Span_Link) GetAttributes 

func (x *Span_Link) GetAttributes() []*Attribute

func (*Span_Link) GetDroppedAttributeCount 

func (x *Span_Link) GetDroppedAttributeCount() int64

func (*Span_Link) GetSpanId 

func (x *Span_Link) GetSpanId() []byte

func (*Span_Link) GetTraceId 

func (x *Span_Link) GetTraceId() []byte

func (*Span_Link) ProtoMessage 

func (*Span_Link) ProtoMessage()

func (*Span_Link) ProtoReflect 

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

func (*Span_Link) Reset 

func (x *Span_Link) Reset()

func (*Span_Link) String 

func (x *Span_Link) String() string

type Span_Resource 

type Span_Resource struct {

	// URL that describes the shape and a composition of data for this span.
	SchemaUrl  string       `protobuf:"bytes,1,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"`
	Attributes []*Attribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"` // Resource attributes
	// contains filtered or unexported fields
}

Resource describes an entity (e.g., a Service Weaver component) this span belongs to.

func (*Span_Resource) Descriptor deprecated 

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

Deprecated: Use Span_Resource.ProtoReflect.Descriptor instead.

func (*Span_Resource) GetAttributes 

func (x *Span_Resource) GetAttributes() []*Attribute

func (*Span_Resource) GetSchemaUrl 

func (x *Span_Resource) GetSchemaUrl() string

func (*Span_Resource) ProtoMessage 

func (*Span_Resource) ProtoMessage()

func (*Span_Resource) ProtoReflect 

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

func (*Span_Resource) Reset 

func (x *Span_Resource) Reset()

func (*Span_Resource) String 

func (x *Span_Resource) String() string

type Span_Status 

type Span_Status struct {
	Code  Span_Status_Code `protobuf:"varint,1,opt,name=code,proto3,enum=runtime.Span_Status_Code" json:"code,omitempty"` // Span status code
	Error string           `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`                              // Error text; set only for an ERROR code
	// contains filtered or unexported fields
}

Status represents the status for a span.

func (*Span_Status) Descriptor deprecated 

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

Deprecated: Use Span_Status.ProtoReflect.Descriptor instead.

func (*Span_Status) GetCode 

func (x *Span_Status) GetCode() Span_Status_Code

func (*Span_Status) GetError 

func (x *Span_Status) GetError() string

func (*Span_Status) ProtoMessage 

func (*Span_Status) ProtoMessage()

func (*Span_Status) ProtoReflect 

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

func (*Span_Status) Reset 

func (x *Span_Status) Reset()

func (*Span_Status) String 

func (x *Span_Status) String() string

type Span_Status_Code 

type Span_Status_Code int32
const (
	Span_Status_UNSET Span_Status_Code = 0
	Span_Status_ERROR Span_Status_Code = 1
	Span_Status_OK    Span_Status_Code = 2
)

func (Span_Status_Code) Descriptor 

func (Span_Status_Code) Descriptor() protoreflect.EnumDescriptor

func (Span_Status_Code) Enum 

func (x Span_Status_Code) Enum() *Span_Status_Code

func (Span_Status_Code) EnumDescriptor deprecated 

func (Span_Status_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use Span_Status_Code.Descriptor instead.

func (Span_Status_Code) Number 

func (x Span_Status_Code) Number() protoreflect.EnumNumber

func (Span_Status_Code) String 

func (x Span_Status_Code) String() string

func (Span_Status_Code) Type 

func (Span_Status_Code) Type() protoreflect.EnumType

type Spans 

type Spans struct {
	Span []*Span `protobuf:"bytes,1,rep,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

Spans is a list of Span messages.

func (*Spans) Descriptor deprecated 

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

Deprecated: Use Spans.ProtoReflect.Descriptor instead.

func (*Spans) GetSpan 

func (x *Spans) GetSpan() []*Span

func (*Spans) ProtoMessage 

func (*Spans) ProtoMessage()

func (*Spans) ProtoReflect 

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

func (*Spans) Reset 

func (x *Spans) Reset()

func (*Spans) String 

func (x *Spans) String() string

type WeaveletInfo added in v0.1.2 

type WeaveletInfo struct {
	App          string           `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                       // app name
	DeploymentId string           `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // deployment id
	Group        *ColocationGroup `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`                                   // colocation group
	GroupId      string           `protobuf:"bytes,4,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`                // colocation group replica id
	Id           string           `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`                                         // weavelet id
	// TODO(spetrovic): Rename to same_group.
	SameProcess []*ComponentGroup `protobuf:"bytes,6,rep,name=same_process,json=sameProcess,proto3" json:"same_process,omitempty"` // See AppConfig.SameProcess.
	Sections    map[string]string ``                                                                                               // See AppConfig.Sections.
	/* 157-byte string literal not displayed */
	SingleProcess      bool   `protobuf:"varint,8,opt,name=single_process,json=singleProcess,proto3" json:"single_process,omitempty"`                   // a single-process deployment?
	UseLocalhost       bool   `protobuf:"varint,9,opt,name=use_localhost,json=useLocalhost,proto3" json:"use_localhost,omitempty"`                      // listeners listen on localhost?
	WeaveletPicksPorts bool   `protobuf:"varint,10,opt,name=weavelet_picks_ports,json=weaveletPicksPorts,proto3" json:"weavelet_picks_ports,omitempty"` // a weavelet picks its own port?
	NetworkStorageDir  string `protobuf:"bytes,11,opt,name=network_storage_dir,json=networkStorageDir,proto3" json:"network_storage_dir,omitempty"`     // colocation group storage dir
	// contains filtered or unexported fields
}

WeaveletInfo contains information provided to a weavelet from its deployer.

func (*WeaveletInfo) Descriptor deprecated added in v0.1.2 

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

Deprecated: Use WeaveletInfo.ProtoReflect.Descriptor instead.

func (*WeaveletInfo) GetApp added in v0.1.2 

func (x *WeaveletInfo) GetApp() string

func (*WeaveletInfo) GetDeploymentId added in v0.1.2 

func (x *WeaveletInfo) GetDeploymentId() string

func (*WeaveletInfo) GetGroup added in v0.1.2 

func (x *WeaveletInfo) GetGroup() *ColocationGroup

func (*WeaveletInfo) GetGroupId added in v0.1.2 

func (x *WeaveletInfo) GetGroupId() string

func (*WeaveletInfo) GetId added in v0.1.2 

func (x *WeaveletInfo) GetId() string

func (*WeaveletInfo) GetNetworkStorageDir added in v0.1.2 

func (x *WeaveletInfo) GetNetworkStorageDir() string

func (*WeaveletInfo) GetSameProcess added in v0.1.2 

func (x *WeaveletInfo) GetSameProcess() []*ComponentGroup

func (*WeaveletInfo) GetSections added in v0.1.2 

func (x *WeaveletInfo) GetSections() map[string]string

func (*WeaveletInfo) GetSingleProcess added in v0.1.2 

func (x *WeaveletInfo) GetSingleProcess() bool

func (*WeaveletInfo) GetUseLocalhost added in v0.1.2 

func (x *WeaveletInfo) GetUseLocalhost() bool

func (*WeaveletInfo) GetWeaveletPicksPorts added in v0.1.2 

func (x *WeaveletInfo) GetWeaveletPicksPorts() bool

func (*WeaveletInfo) ProtoMessage added in v0.1.2 

func (*WeaveletInfo) ProtoMessage()

func (*WeaveletInfo) ProtoReflect added in v0.1.2 

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

func (*WeaveletInfo) Reset added in v0.1.2 

func (x *WeaveletInfo) Reset()

func (*WeaveletInfo) String added in v0.1.2 

func (x *WeaveletInfo) String() string

type WeaveletLoadReport 

type WeaveletLoadReport struct {
	App          string                                       `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                       // Application name
	DeploymentId string                                       `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // Deployment id.
	Group        string                                       `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`                                   // Colocation group.
	Replica      string                                       `protobuf:"bytes,4,opt,name=replica,proto3" json:"replica,omitempty"`                               // e.g., tcp://124.123.123.412:1291
	Loads        map[string]*WeaveletLoadReport_ComponentLoad ``                                                                                                  // load for every component on the weavelet
	/* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

WeaveletLoadReport stores load information for all routed components hosted by a particular weavelet.

func (*WeaveletLoadReport) Descriptor deprecated 

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

Deprecated: Use WeaveletLoadReport.ProtoReflect.Descriptor instead.

func (*WeaveletLoadReport) GetApp 

func (x *WeaveletLoadReport) GetApp() string

func (*WeaveletLoadReport) GetDeploymentId 

func (x *WeaveletLoadReport) GetDeploymentId() string

func (*WeaveletLoadReport) GetGroup added in v0.1.2 

func (x *WeaveletLoadReport) GetGroup() string

func (*WeaveletLoadReport) GetLoads 

func (x *WeaveletLoadReport) GetLoads() map[string]*WeaveletLoadReport_ComponentLoad

func (*WeaveletLoadReport) GetReplica 

func (x *WeaveletLoadReport) GetReplica() string

func (*WeaveletLoadReport) ProtoMessage 

func (*WeaveletLoadReport) ProtoMessage()

func (*WeaveletLoadReport) ProtoReflect 

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

func (*WeaveletLoadReport) Reset 

func (x *WeaveletLoadReport) Reset()

func (*WeaveletLoadReport) String 

func (x *WeaveletLoadReport) String() string

type WeaveletLoadReport_ComponentLoad 

type WeaveletLoadReport_ComponentLoad struct {

	// TODO(mwhittaker): In full generality, load is a generic
	// application-specific double-valued measurement (e.g., total number of
	// requests, size of components in memory). For now to simplify things, we
	// assume load is measured as requests per second.
	Load []*WeaveletLoadReport_ComponentLoad_SliceLoad `protobuf:"bytes,1,rep,name=load,proto3" json:"load,omitempty"` // load, by slice
	// TODO(mwhittaker): For now, load is reported with respect to a given
	// assignment. When the assignment changes, the load is reset. This approach
	// works for rate-based load like requests per second, but not other
	// non-rate based load like size of cached components.
	Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

ComponentLoad includes load information for a component. The component's key space is divided into a number of slices, each of which is associated with a particular double-valued load.

TODO(mwhittaker): In the short term, a weavelet will report one SliceLoad for every slice it is assigned. In the future, however, we may report load in more advanced ways.

func (*WeaveletLoadReport_ComponentLoad) Descriptor deprecated 

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

Deprecated: Use WeaveletLoadReport_ComponentLoad.ProtoReflect.Descriptor instead.

func (*WeaveletLoadReport_ComponentLoad) GetLoad 

func (x *WeaveletLoadReport_ComponentLoad) GetLoad() []*WeaveletLoadReport_ComponentLoad_SliceLoad

func (*WeaveletLoadReport_ComponentLoad) GetVersion 

func (x *WeaveletLoadReport_ComponentLoad) GetVersion() uint64

func (*WeaveletLoadReport_ComponentLoad) ProtoMessage 

func (*WeaveletLoadReport_ComponentLoad) ProtoMessage()

func (*WeaveletLoadReport_ComponentLoad) ProtoReflect 

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

func (*WeaveletLoadReport_ComponentLoad) Reset 

func (x *WeaveletLoadReport_ComponentLoad) Reset()

func (*WeaveletLoadReport_ComponentLoad) String 

func (x *WeaveletLoadReport_ComponentLoad) String() string

type WeaveletLoadReport_ComponentLoad_SliceLoad 

type WeaveletLoadReport_ComponentLoad_SliceLoad struct {
	Start  uint64                                                     `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // inclusive
	End    uint64                                                     `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`     // exclusive
	Load   float64                                                    `protobuf:"fixed64,3,opt,name=load,proto3" json:"load,omitempty"`
	Splits []*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad `protobuf:"bytes,4,rep,name=splits,proto3" json:"splits,omitempty"`
	// The "size" of the slice. Given a slice [a, b), it's tempting to think
	// the slice has size b - a. This has a couple of problems.
	//
	//  1. Even if a slice is large, only a few keys in the slice may be
	//     used. For example, a weavelet with slice [0, 2^60) may only
	//     receive requests for keys in the range [0, 100).
	//  2. a and b are not necessarily numeric. Imagine we are performing
	//     range sharding on strings and have the slice ["ccbae",
	//     "hhaefi"). What is the size of this slice?
	//
	// We instead measure the "size" of a slice as an estimate of the number
	// of keys accessed in the slice. For example, if a slice [0, 1000)
	// receives requests for keys 0, 1, 2, 3, and 10, then the size of the
	// slice is 5.
	//
	// TODO(mwhittaker): Implement this. For now, we do report the size of a
	// slice [a, b) as b - a.
	Size uint64 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

SliceLoad includes the load of a slice, [start, end).

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) Descriptor deprecated 

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

Deprecated: Use WeaveletLoadReport_ComponentLoad_SliceLoad.ProtoReflect.Descriptor instead.

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) GetEnd 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) GetEnd() uint64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) GetLoad 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) GetLoad() float64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) GetSize 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) GetSize() uint64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) GetSplits 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) GetSplits() []*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) GetStart 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) GetStart() uint64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) ProtoMessage 

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) ProtoMessage()

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) ProtoReflect 

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

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) Reset 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) Reset()

func (*WeaveletLoadReport_ComponentLoad_SliceLoad) String 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad) String() string

type WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad 

type WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad struct {
	Start uint64  `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Load  float64 `protobuf:"fixed64,2,opt,name=load,proto3" json:"load,omitempty"`
	// contains filtered or unexported fields
}

splits divides the load of this slice into smaller subslices. For example, given a slice [0, 100) and load 9.0, we may have the following subslices: 

SubsliceLoad{Start:  0, Load: 3.0} // [0, 20)
SubsliceLoad{Start: 20, Load: 3.0} // [20, 80)
SubsliceLoad{Start: 80, Load: 3.0} // [80, 100)

TODO(mwhittaker): Implement this. For now, splits is left empty.

TODO(mwhittaker): In the future, we likely want to report hot keys as their own slice. Change SubsliceLoad to support that.

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) Descriptor deprecated 

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

Deprecated: Use WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad.ProtoReflect.Descriptor instead.

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) GetLoad 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) GetLoad() float64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) GetStart 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) GetStart() uint64

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) ProtoMessage 

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) ProtoMessage()

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) ProtoReflect 

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

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) Reset 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) Reset()

func (*WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) String 

func (x *WeaveletLoadReport_ComponentLoad_SliceLoad_SubsliceLoad) String() string

type WeaveletMsg 

type WeaveletMsg struct {

	// Unique id identifies the request for which this message is a reply.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Updated metrics.
	Metrics *MetricUpdate `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// Latest log entry.
	LogEntry *LogEntry `protobuf:"bytes,3,opt,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
	// Trace spans to be exported.
	TraceSpans *Spans `protobuf:"bytes,4,opt,name=trace_spans,json=traceSpans,proto3" json:"trace_spans,omitempty"`
	// Component to be started.
	ComponentToStart *ComponentToStart `protobuf:"bytes,5,opt,name=component_to_start,json=componentToStart,proto3" json:"component_to_start,omitempty"`
	// Colocation group to be started.
	ColocationGroupToStart *ColocationGroup `` /* 131-byte string literal not displayed */
	// Replica to register.
	ReplicaToRegister *ReplicaToRegister `protobuf:"bytes,7,opt,name=replica_to_register,json=replicaToRegister,proto3" json:"replica_to_register,omitempty"`
	// Weavelet load to be reported.
	LoadReport *WeaveletLoadReport `protobuf:"bytes,8,opt,name=load_report,json=loadReport,proto3" json:"load_report,omitempty"`
	// Updated health status.
	HealthReport *HealthReport `protobuf:"bytes,9,opt,name=health_report,json=healthReport,proto3" json:"health_report,omitempty"`
	// Weavelet profile.
	Profile *Profile `protobuf:"bytes,10,opt,name=profile,proto3" json:"profile,omitempty"`
	// A reply to the envelope with an error status.
	Error string `protobuf:"bytes,11,opt,name=error,proto3" json:"error,omitempty"`
	// Request to get the routing info.
	GetRoutingInfo *GetRoutingInfo `protobuf:"bytes,12,opt,name=get_routing_info,json=getRoutingInfo,proto3" json:"get_routing_info,omitempty"`
	// Request to get the list of components to be started.
	GetComponentsToStart *GetComponentsToStart `` /* 126-byte string literal not displayed */
	// Request to get the address for a listener.
	GetAddressRequest *GetAddressRequest `protobuf:"bytes,14,opt,name=get_address_request,json=getAddressRequest,proto3" json:"get_address_request,omitempty"`
	// Request to export a listener.
	ExportListenerRequest *ExportListenerRequest `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

WeaveletMsg holds a message sent by a weavelet to the envelope that manages it.

func (*WeaveletMsg) Descriptor deprecated 

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

Deprecated: Use WeaveletMsg.ProtoReflect.Descriptor instead.

func (*WeaveletMsg) GetColocationGroupToStart 

func (x *WeaveletMsg) GetColocationGroupToStart() *ColocationGroup

func (*WeaveletMsg) GetComponentToStart 

func (x *WeaveletMsg) GetComponentToStart() *ComponentToStart

func (*WeaveletMsg) GetError 

func (x *WeaveletMsg) GetError() string

func (*WeaveletMsg) GetExportListenerRequest added in v0.1.2 

func (x *WeaveletMsg) GetExportListenerRequest() *ExportListenerRequest

func (*WeaveletMsg) GetGetAddressRequest added in v0.1.2 

func (x *WeaveletMsg) GetGetAddressRequest() *GetAddressRequest

func (*WeaveletMsg) GetGetComponentsToStart 

func (x *WeaveletMsg) GetGetComponentsToStart() *GetComponentsToStart

func (*WeaveletMsg) GetGetRoutingInfo 

func (x *WeaveletMsg) GetGetRoutingInfo() *GetRoutingInfo

func (*WeaveletMsg) GetHealthReport 

func (x *WeaveletMsg) GetHealthReport() *HealthReport

func (*WeaveletMsg) GetId 

func (x *WeaveletMsg) GetId() int64

func (*WeaveletMsg) GetLoadReport 

func (x *WeaveletMsg) GetLoadReport() *WeaveletLoadReport

func (*WeaveletMsg) GetLogEntry 

func (x *WeaveletMsg) GetLogEntry() *LogEntry

func (*WeaveletMsg) GetMetrics 

func (x *WeaveletMsg) GetMetrics() *MetricUpdate

func (*WeaveletMsg) GetProfile 

func (x *WeaveletMsg) GetProfile() *Profile

func (*WeaveletMsg) GetReplicaToRegister 

func (x *WeaveletMsg) GetReplicaToRegister() *ReplicaToRegister

func (*WeaveletMsg) GetTraceSpans 

func (x *WeaveletMsg) GetTraceSpans() *Spans

func (*WeaveletMsg) ProtoMessage 

func (*WeaveletMsg) ProtoMessage()

func (*WeaveletMsg) ProtoReflect 

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

func (*WeaveletMsg) Reset 

func (x *WeaveletMsg) Reset()

func (*WeaveletMsg) String 

func (x *WeaveletMsg) 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.