protos

package
v0.4.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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 (
	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 (
	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_config_proto protoreflect.FileDescriptor
View Source 
var File_runtime_protos_runtime_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ActivateComponentReply added in v0.2.0 

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

ActivateComponentReply is a reply to an ActivateComponentRequest.

func (*ActivateComponentReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ActivateComponentReply.ProtoReflect.Descriptor instead.

func (*ActivateComponentReply) ProtoMessage added in v0.2.0 

func (*ActivateComponentReply) ProtoMessage()

func (*ActivateComponentReply) ProtoReflect added in v0.2.0 

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

func (*ActivateComponentReply) Reset added in v0.2.0 

func (x *ActivateComponentReply) Reset()

func (*ActivateComponentReply) String added in v0.2.0 

func (x *ActivateComponentReply) String() string

type ActivateComponentRequest added in v0.2.0 

type ActivateComponentRequest struct {
	Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"` // component name
	Routed    bool   `protobuf:"varint,2,opt,name=routed,proto3" json:"routed,omitempty"`      // is the component routed?
	// contains filtered or unexported fields
}

ActivateComponentRequest is a request from a weavelet to ensure that the provided component is running somewhere. An ActivateComponentRequest also implicitly signals that a weavelet is interested in receiving routing info for the component via UpdateRoutingInfoRequest.

func (*ActivateComponentRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use ActivateComponentRequest.ProtoReflect.Descriptor instead.

func (*ActivateComponentRequest) GetComponent added in v0.2.0 

func (x *ActivateComponentRequest) GetComponent() string

func (*ActivateComponentRequest) GetRouted added in v0.2.0 

func (x *ActivateComponentRequest) GetRouted() bool

func (*ActivateComponentRequest) ProtoMessage added in v0.2.0 

func (*ActivateComponentRequest) ProtoMessage()

func (*ActivateComponentRequest) ProtoReflect added in v0.2.0 

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

func (*ActivateComponentRequest) Reset added in v0.2.0 

func (x *ActivateComponentRequest) Reset()

func (*ActivateComponentRequest) String added in v0.2.0 

func (x *ActivateComponentRequest) String() string

type AppConfig 

type AppConfig struct {

	// Application name (derived from binary if missing).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// File name of the binary that implements the app.
	Binary string `protobuf:"bytes,2,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,4,rep,name=env,proto3" json:"env,omitempty"`
	// Groups of components that must be co-located in the same OS process.
	//
	// This grouping allows the developer a level of control on where the Service
	// Weaver runtime will 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.
	//
	//	colocate = [[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".
	Colocate []*ComponentGroup `protobuf:"bytes,5,rep,name=colocate,proto3" json:"colocate,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,6,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) GetColocate added in v0.2.0 

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

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) 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"`
	// 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.
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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) 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. Every address is 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
}

A slice of the key space 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 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.

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 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.

TODO(mwhittaker): Delete this proto.

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 EnvelopeInfo added in v0.2.0 

type EnvelopeInfo 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"` // globally unique deployment id
	Id           string            `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`                                         // globally unique weavelet id
	Sections     map[string]string ``                                                                                                  // See AppConfig.Sections.
	/* 157-byte string literal not displayed */
	SingleProcess bool `protobuf:"varint,5,opt,name=single_process,json=singleProcess,proto3" json:"single_process,omitempty"` // a single-process deployment?
	SingleMachine bool `protobuf:"varint,6,opt,name=single_machine,json=singleMachine,proto3" json:"single_machine,omitempty"` // a single-machine deployment?
	RunMain       bool `protobuf:"varint,7,opt,name=run_main,json=runMain,proto3" json:"run_main,omitempty"`                   // run the main function?
	// contains filtered or unexported fields
}

EnvelopeInfo is the information provided by an envelope to a weavelet during the initial envelope-weavelet handshake.

func (*EnvelopeInfo) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use EnvelopeInfo.ProtoReflect.Descriptor instead.

func (*EnvelopeInfo) GetApp added in v0.2.0 

func (x *EnvelopeInfo) GetApp() string

func (*EnvelopeInfo) GetDeploymentId added in v0.2.0 

func (x *EnvelopeInfo) GetDeploymentId() string

func (*EnvelopeInfo) GetId added in v0.2.0 

func (x *EnvelopeInfo) GetId() string

func (*EnvelopeInfo) GetRunMain added in v0.2.0 

func (x *EnvelopeInfo) GetRunMain() bool

func (*EnvelopeInfo) GetSections added in v0.2.0 

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

func (*EnvelopeInfo) GetSingleMachine added in v0.2.0 

func (x *EnvelopeInfo) GetSingleMachine() bool

func (*EnvelopeInfo) GetSingleProcess added in v0.2.0 

func (x *EnvelopeInfo) GetSingleProcess() bool

func (*EnvelopeInfo) ProtoMessage added in v0.2.0 

func (*EnvelopeInfo) ProtoMessage()

func (*EnvelopeInfo) ProtoReflect added in v0.2.0 

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

func (*EnvelopeInfo) Reset added in v0.2.0 

func (x *EnvelopeInfo) Reset()

func (*EnvelopeInfo) String added in v0.2.0 

func (x *EnvelopeInfo) String() string

type EnvelopeMsg 

type EnvelopeMsg struct {

	// A unique id for RPCs. An RPC request with positive id x expects a reply
	// with negative id -x. An unacknowledged RPC request has an id of 0.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Handshake.
	EnvelopeInfo *EnvelopeInfo `protobuf:"bytes,2,opt,name=envelope_info,json=envelopeInfo,proto3" json:"envelope_info,omitempty"`
	// Envelope initiated RPC requests.
	GetHealthRequest         *GetHealthRequest         `protobuf:"bytes,3,opt,name=get_health_request,json=getHealthRequest,proto3" json:"get_health_request,omitempty"`
	GetMetricsRequest        *GetMetricsRequest        `protobuf:"bytes,4,opt,name=get_metrics_request,json=getMetricsRequest,proto3" json:"get_metrics_request,omitempty"`
	GetLoadRequest           *GetLoadRequest           `protobuf:"bytes,5,opt,name=get_load_request,json=getLoadRequest,proto3" json:"get_load_request,omitempty"`
	GetProfileRequest        *GetProfileRequest        `protobuf:"bytes,6,opt,name=get_profile_request,json=getProfileRequest,proto3" json:"get_profile_request,omitempty"`
	UpdateRoutingInfoRequest *UpdateRoutingInfoRequest `` /* 137-byte string literal not displayed */
	UpdateComponentsRequest  *UpdateComponentsRequest  `` /* 132-byte string literal not displayed */
	// Weavelet initiated RPC replies.
	Error                   string                   `protobuf:"bytes,9,opt,name=error,proto3" json:"error,omitempty"` // non-nil on error
	ActivateComponentReply  *ActivateComponentReply  ``                                                                /* 130-byte string literal not displayed */
	GetListenerAddressReply *GetListenerAddressReply ``                                                                /* 135-byte string literal not displayed */
	ExportListenerReply     *ExportListenerReply     `protobuf:"bytes,12,opt,name=export_listener_reply,json=exportListenerReply,proto3" json:"export_listener_reply,omitempty"`
	// contains filtered or unexported fields
}

EnvelopeMsg is a message sent by an envelope to a weavelet.

func (*EnvelopeMsg) Descriptor deprecated 

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

Deprecated: Use EnvelopeMsg.ProtoReflect.Descriptor instead.

func (*EnvelopeMsg) GetActivateComponentReply added in v0.2.0 

func (x *EnvelopeMsg) GetActivateComponentReply() *ActivateComponentReply

func (*EnvelopeMsg) GetEnvelopeInfo added in v0.2.0 

func (x *EnvelopeMsg) GetEnvelopeInfo() *EnvelopeInfo

func (*EnvelopeMsg) GetError 

func (x *EnvelopeMsg) GetError() string

func (*EnvelopeMsg) GetExportListenerReply 

func (x *EnvelopeMsg) GetExportListenerReply() *ExportListenerReply

func (*EnvelopeMsg) GetGetHealthRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetHealthRequest() *GetHealthRequest

func (*EnvelopeMsg) GetGetListenerAddressReply added in v0.2.0 

func (x *EnvelopeMsg) GetGetListenerAddressReply() *GetListenerAddressReply

func (*EnvelopeMsg) GetGetLoadRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetLoadRequest() *GetLoadRequest

func (*EnvelopeMsg) GetGetMetricsRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetMetricsRequest() *GetMetricsRequest

func (*EnvelopeMsg) GetGetProfileRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetProfileRequest() *GetProfileRequest

func (*EnvelopeMsg) GetId 

func (x *EnvelopeMsg) GetId() int64

func (*EnvelopeMsg) GetUpdateComponentsRequest added in v0.2.0 

func (x *EnvelopeMsg) GetUpdateComponentsRequest() *UpdateComponentsRequest

func (*EnvelopeMsg) GetUpdateRoutingInfoRequest added in v0.2.0 

func (x *EnvelopeMsg) GetUpdateRoutingInfoRequest() *UpdateRoutingInfoRequest

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 {

	// The address of the proxy that forwards traffic to the listener, or empty if
	// there is no proxy.
	ProxyAddress string `protobuf:"bytes,1,opt,name=proxy_address,json=proxyAddress,proto3" json:"proxy_address,omitempty"`
	// 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,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ExportListenerReply is a reply to an 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     string `protobuf:"bytes,1,opt,name=listener,proto3" json:"listener,omitempty"`
	Address      string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	LocalAddress string `protobuf:"bytes,3,opt,name=local_address,json=localAddress,proto3" json:"local_address,omitempty"` // LocalAddress argument in ListenerOptions
	// contains filtered or unexported fields
}

ExportListenerRequest is a request from a weavelet to export the provided listener. Exporting a listener typically, but not always, involves running a proxy that forwards traffic to the provided address.

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

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

Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.

func (*ExportListenerRequest) GetAddress added in v0.2.0 

func (x *ExportListenerRequest) GetAddress() string

func (*ExportListenerRequest) GetListener added in v0.1.2 

func (x *ExportListenerRequest) GetListener() string

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 GetHealthReply added in v0.2.0 

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

GetHealthReply is a reply to a GetHealthRequest.

func (*GetHealthReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetHealthReply.ProtoReflect.Descriptor instead.

func (*GetHealthReply) GetStatus added in v0.2.0 

func (x *GetHealthReply) GetStatus() HealthStatus

func (*GetHealthReply) ProtoMessage added in v0.2.0 

func (*GetHealthReply) ProtoMessage()

func (*GetHealthReply) ProtoReflect added in v0.2.0 

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

func (*GetHealthReply) Reset added in v0.2.0 

func (x *GetHealthReply) Reset()

func (*GetHealthReply) String added in v0.2.0 

func (x *GetHealthReply) String() string

type GetHealthRequest added in v0.2.0 

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

GetHealthRequest is a request from an envelope for a weavelet's health.

func (*GetHealthRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetHealthRequest.ProtoReflect.Descriptor instead.

func (*GetHealthRequest) ProtoMessage added in v0.2.0 

func (*GetHealthRequest) ProtoMessage()

func (*GetHealthRequest) ProtoReflect added in v0.2.0 

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

func (*GetHealthRequest) Reset added in v0.2.0 

func (x *GetHealthRequest) Reset()

func (*GetHealthRequest) String added in v0.2.0 

func (x *GetHealthRequest) String() string

type GetListenerAddressReply added in v0.2.0 

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

GetListenerAddressReply is a reply to a GetListenerAddressRequest.

func (*GetListenerAddressReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetListenerAddressReply.ProtoReflect.Descriptor instead.

func (*GetListenerAddressReply) GetAddress added in v0.2.0 

func (x *GetListenerAddressReply) GetAddress() string

func (*GetListenerAddressReply) ProtoMessage added in v0.2.0 

func (*GetListenerAddressReply) ProtoMessage()

func (*GetListenerAddressReply) ProtoReflect added in v0.2.0 

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

func (*GetListenerAddressReply) Reset added in v0.2.0 

func (x *GetListenerAddressReply) Reset()

func (*GetListenerAddressReply) String added in v0.2.0 

func (x *GetListenerAddressReply) String() string

type GetListenerAddressRequest added in v0.2.0 

type GetListenerAddressRequest 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
}

GetListenerAddressRequest is a request from a weavelet for the address the 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 GetListenerAddressRequest.

  • 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 (*GetListenerAddressRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetListenerAddressRequest.ProtoReflect.Descriptor instead.

func (*GetListenerAddressRequest) GetLocalAddress added in v0.2.0 

func (x *GetListenerAddressRequest) GetLocalAddress() string

func (*GetListenerAddressRequest) GetName added in v0.2.0 

func (x *GetListenerAddressRequest) GetName() string

func (*GetListenerAddressRequest) ProtoMessage added in v0.2.0 

func (*GetListenerAddressRequest) ProtoMessage()

func (*GetListenerAddressRequest) ProtoReflect added in v0.2.0 

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

func (*GetListenerAddressRequest) Reset added in v0.2.0 

func (x *GetListenerAddressRequest) Reset()

func (*GetListenerAddressRequest) String added in v0.2.0 

func (x *GetListenerAddressRequest) String() string

type GetLoadReply added in v0.2.0 

type GetLoadReply struct {
	Load *LoadReport `protobuf:"bytes,1,opt,name=load,proto3" json:"load,omitempty"`
	// contains filtered or unexported fields
}

GetLoadReply is a reply to a GetLoadRequest.

func (*GetLoadReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.

func (*GetLoadReply) GetLoad added in v0.2.0 

func (x *GetLoadReply) GetLoad() *LoadReport

func (*GetLoadReply) ProtoMessage added in v0.2.0 

func (*GetLoadReply) ProtoMessage()

func (*GetLoadReply) ProtoReflect added in v0.2.0 

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

func (*GetLoadReply) Reset added in v0.2.0 

func (x *GetLoadReply) Reset()

func (*GetLoadReply) String added in v0.2.0 

func (x *GetLoadReply) String() string

type GetLoadRequest added in v0.2.0 

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

GetLoadRequest is a request from an envelope for a weavelet's load report.

func (*GetLoadRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.

func (*GetLoadRequest) ProtoMessage added in v0.2.0 

func (*GetLoadRequest) ProtoMessage()

func (*GetLoadRequest) ProtoReflect added in v0.2.0 

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

func (*GetLoadRequest) Reset added in v0.2.0 

func (x *GetLoadRequest) Reset()

func (*GetLoadRequest) String added in v0.2.0 

func (x *GetLoadRequest) String() string

type GetMetricsReply added in v0.2.0 

type GetMetricsReply struct {
	Update *MetricUpdate `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
	// contains filtered or unexported fields
}

GetMetricsReply is a reply to a GetMetricsRequest. It only contains information about the metrics that have changed since the prior GetMetricsRequest.

func (*GetMetricsReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetMetricsReply.ProtoReflect.Descriptor instead.

func (*GetMetricsReply) GetUpdate added in v0.2.0 

func (x *GetMetricsReply) GetUpdate() *MetricUpdate

func (*GetMetricsReply) ProtoMessage added in v0.2.0 

func (*GetMetricsReply) ProtoMessage()

func (*GetMetricsReply) ProtoReflect added in v0.2.0 

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

func (*GetMetricsReply) Reset added in v0.2.0 

func (x *GetMetricsReply) Reset()

func (*GetMetricsReply) String added in v0.2.0 

func (x *GetMetricsReply) String() string

type GetMetricsRequest added in v0.2.0 

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

GetMetricsRequest is a request from an envelope for a weavelet's metrics. There can only be one outstanding GetMetricsRequest at a time.

func (*GetMetricsRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) ProtoMessage added in v0.2.0 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect added in v0.2.0 

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

func (*GetMetricsRequest) Reset added in v0.2.0 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String added in v0.2.0 

func (x *GetMetricsRequest) String() string

type GetProfileReply added in v0.2.0 

type GetProfileReply struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // encoded profile data
	// contains filtered or unexported fields
}

GetProfileReply is a reply to a GetProfileRequest.

func (*GetProfileReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetProfileReply.ProtoReflect.Descriptor instead.

func (*GetProfileReply) GetData added in v0.2.0 

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

func (*GetProfileReply) ProtoMessage added in v0.2.0 

func (*GetProfileReply) ProtoMessage()

func (*GetProfileReply) ProtoReflect added in v0.2.0 

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

func (*GetProfileReply) Reset added in v0.2.0 

func (x *GetProfileReply) Reset()

func (*GetProfileReply) String added in v0.2.0 

func (x *GetProfileReply) String() string

type GetProfileRequest added in v0.2.0 

type GetProfileRequest struct {

	// Type of the profile (e.g., heap, cpu).
	ProfileType ProfileType `protobuf:"varint,1,opt,name=profile_type,json=profileType,proto3,enum=runtime.ProfileType" json:"profile_type,omitempty"`
	// Duration of CPU profiles, in nanoseconds.
	CpuDurationNs int64 `protobuf:"varint,2,opt,name=cpu_duration_ns,json=cpuDurationNs,proto3" json:"cpu_duration_ns,omitempty"`
	// contains filtered or unexported fields
}

GetProfileRequest is a request from an envelope for a weavelet to collect and return a profile. There can only be one outstanding GetProfileRequest at a time.

func (*GetProfileRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetProfileRequest) GetCpuDurationNs added in v0.2.0 

func (x *GetProfileRequest) GetCpuDurationNs() int64

func (*GetProfileRequest) GetProfileType added in v0.2.0 

func (x *GetProfileRequest) GetProfileType() ProfileType

func (*GetProfileRequest) ProtoMessage added in v0.2.0 

func (*GetProfileRequest) ProtoMessage()

func (*GetProfileRequest) ProtoReflect added in v0.2.0 

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

func (*GetProfileRequest) Reset added in v0.2.0 

func (x *GetProfileRequest) Reset()

func (*GetProfileRequest) String added in v0.2.0 

func (x *GetProfileRequest) String() string

type HealthStatus 

type HealthStatus int32

HealthStatus specifies the health of a weavelet. 

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 LoadReport added in v0.2.0 

type LoadReport struct {
	Loads map[string]*LoadReport_ComponentLoad `` // load for routed components
	/* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

LoadReport contains load information for all routed components hosted by a particular weavelet.

func (*LoadReport) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LoadReport.ProtoReflect.Descriptor instead.

func (*LoadReport) GetLoads added in v0.2.0 

func (x *LoadReport) GetLoads() map[string]*LoadReport_ComponentLoad

func (*LoadReport) ProtoMessage added in v0.2.0 

func (*LoadReport) ProtoMessage()

func (*LoadReport) ProtoReflect added in v0.2.0 

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

func (*LoadReport) Reset added in v0.2.0 

func (x *LoadReport) Reset()

func (*LoadReport) String added in v0.2.0 

func (x *LoadReport) String() string

type LoadReport_ComponentLoad added in v0.2.0 

type LoadReport_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 []*LoadReport_SliceLoad `protobuf:"bytes,1,rep,name=load,proto3" json:"load,omitempty"`
	// 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,2,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 (*LoadReport_ComponentLoad) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LoadReport_ComponentLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_ComponentLoad) GetLoad added in v0.2.0 

func (x *LoadReport_ComponentLoad) GetLoad() []*LoadReport_SliceLoad

func (*LoadReport_ComponentLoad) GetVersion added in v0.2.0 

func (x *LoadReport_ComponentLoad) GetVersion() uint64

func (*LoadReport_ComponentLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_ComponentLoad) ProtoMessage()

func (*LoadReport_ComponentLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_ComponentLoad) Reset added in v0.2.0 

func (x *LoadReport_ComponentLoad) Reset()

func (*LoadReport_ComponentLoad) String added in v0.2.0 

func (x *LoadReport_ComponentLoad) String() string

type LoadReport_SliceLoad added in v0.2.0 

type LoadReport_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 []*LoadReport_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.
	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 (*LoadReport_SliceLoad) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LoadReport_SliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SliceLoad) GetEnd added in v0.2.0 

func (x *LoadReport_SliceLoad) GetEnd() uint64

func (*LoadReport_SliceLoad) GetLoad added in v0.2.0 

func (x *LoadReport_SliceLoad) GetLoad() float64

func (*LoadReport_SliceLoad) GetSize added in v0.2.0 

func (x *LoadReport_SliceLoad) GetSize() uint64

func (*LoadReport_SliceLoad) GetSplits added in v0.2.0 

func (x *LoadReport_SliceLoad) GetSplits() []*LoadReport_SubsliceLoad

func (*LoadReport_SliceLoad) GetStart added in v0.2.0 

func (x *LoadReport_SliceLoad) GetStart() uint64

func (*LoadReport_SliceLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_SliceLoad) ProtoMessage()

func (*LoadReport_SliceLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_SliceLoad) Reset added in v0.2.0 

func (x *LoadReport_SliceLoad) Reset()

func (*LoadReport_SliceLoad) String added in v0.2.0 

func (x *LoadReport_SliceLoad) String() string

type LoadReport_SubsliceLoad added in v0.2.0 

type LoadReport_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
}

SubsliceLoad divides the load of a 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): In the future, we likely want to report hot keys as their own slice. Change SubsliceLoad to support that.

func (*LoadReport_SubsliceLoad) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use LoadReport_SubsliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SubsliceLoad) GetLoad added in v0.2.0 

func (x *LoadReport_SubsliceLoad) GetLoad() float64

func (*LoadReport_SubsliceLoad) GetStart added in v0.2.0 

func (x *LoadReport_SubsliceLoad) GetStart() uint64

func (*LoadReport_SubsliceLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_SubsliceLoad) ProtoMessage()

func (*LoadReport_SubsliceLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_SubsliceLoad) Reset added in v0.2.0 

func (x *LoadReport_SubsliceLoad) Reset()

func (*LoadReport_SubsliceLoad) String added in v0.2.0 

func (x *LoadReport_SubsliceLoad) String() string

type LogEntry 

type LogEntry struct {
	App        string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                   // application name
	Version    string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`                           // deployment id
	Component  string `protobuf:"bytes,3,opt,name=component,proto3" json:"component,omitempty"`                       // component name
	Node       string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`                                 // weavelet id
	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, error)
	File       string `protobuf:"bytes,7,opt,name=file,proto3" json:"file,omitempty"`                                 // source file
	Line       int32  `protobuf:"varint,8,opt,name=line,proto3" json:"line,omitempty"`                                // source line
	Msg        string `protobuf:"bytes,9,opt,name=msg,proto3" json:"msg,omitempty"`                                   // user provided message
	// 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"`                           // metric's unique id
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                        // name of the metric
	Typ    MetricType        `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"` // type of metric
	Help   string            `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`                        // metric's help message
	Labels map[string]string ``                                                                                     // metric labels
	/* 153-byte string literal not displayed */
	Bounds []float64 `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"` // histogram bucket bounds
	// 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"`                           // metric's unique id
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                        // name of the metric
	Typ    MetricType        `protobuf:"varint,3,opt,name=typ,proto3,enum=runtime.MetricType" json:"typ,omitempty"` // type of metric
	Help   string            `protobuf:"bytes,4,opt,name=help,proto3" json:"help,omitempty"`                        // metric's help message
	Labels map[string]string ``                                                                                     // metric labels
	/* 153-byte string literal not displayed */
	Bounds []float64 `protobuf:"fixed64,6,rep,packed,name=bounds,proto3" json:"bounds,omitempty"` // histogram bucket bounds
	Value  float64   `protobuf:"fixed64,7,opt,name=value,proto3" json:"value,omitempty"`          // value for counter and gauge, sum for histogram
	Counts []uint64  `protobuf:"varint,8,rep,packed,name=counts,proto3" json:"counts,omitempty"`  // histogram counts
	// contains filtered or unexported fields
}

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

TODO(mwhittaker): Move out of runtime.proto. It's not used by the pipe.

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 metric updates.

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 ProfileType 

type ProfileType int32

ProfileType specifies a type of profile. 

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 RoutingInfo 

type RoutingInfo struct {
	Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	// If true, perform method calls on the component locally. Replicas and
	// assignment are ignored. Currently, local must always be true or always be
	// false for a given component.
	Local bool `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"`
	// The addresses of the weavelets hosting a replica of the component. Every
	// address is of the form "<net>://<addr>" (e.g., "tcp://host:1234",
	// "unix:///tmp/unix.sock"). For non-local components, a weavelet will execute
	// method calls on one of these replicas.
	Replicas []string `protobuf:"bytes,3,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// Routing assignment, if the component is routed.
	Assignment *Assignment `protobuf:"bytes,4,opt,name=assignment,proto3" json:"assignment,omitempty"`
	// contains filtered or unexported fields
}

RoutingInfo contains routing information for a component. A weavelet uses a RoutingInfo to know where to send a remote method call.

func (*RoutingInfo) Descriptor deprecated 

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

Deprecated: Use RoutingInfo.ProtoReflect.Descriptor instead.

func (*RoutingInfo) GetAssignment added in v0.2.0 

func (x *RoutingInfo) GetAssignment() *Assignment

func (*RoutingInfo) GetComponent added in v0.2.0 

func (x *RoutingInfo) GetComponent() string

func (*RoutingInfo) GetLocal added in v0.2.0 

func (x *RoutingInfo) GetLocal() bool

func (*RoutingInfo) GetReplicas 

func (x *RoutingInfo) GetReplicas() []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 SemVer added in v0.2.0 

type SemVer struct {
	Major int64 `protobuf:"varint,1,opt,name=major,proto3" json:"major,omitempty"`
	Minor int64 `protobuf:"varint,2,opt,name=minor,proto3" json:"minor,omitempty"`
	Patch int64 `protobuf:"varint,3,opt,name=patch,proto3" json:"patch,omitempty"`
	// contains filtered or unexported fields
}

SemVer represents a [semantic version]1 of the form "<major>.<minor>.<patch>". For example, the semver "0.12.3" has major=0, minor=12, and patch=3.

func (*SemVer) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use SemVer.ProtoReflect.Descriptor instead.

func (*SemVer) GetMajor added in v0.2.0 

func (x *SemVer) GetMajor() int64

func (*SemVer) GetMinor added in v0.2.0 

func (x *SemVer) GetMinor() int64

func (*SemVer) GetPatch added in v0.2.0 

func (x *SemVer) GetPatch() int64

func (*SemVer) ProtoMessage added in v0.2.0 

func (*SemVer) ProtoMessage()

func (*SemVer) ProtoReflect added in v0.2.0 

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

func (*SemVer) Reset added in v0.2.0 

func (x *SemVer) Reset()

func (*SemVer) String added in v0.2.0 

func (x *SemVer) 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 event was recorded (micros 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 TraceSpans added in v0.2.0 

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

TraceSpans is a list of Span messages.

func (*TraceSpans) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use TraceSpans.ProtoReflect.Descriptor instead.

func (*TraceSpans) GetSpan added in v0.2.0 

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

func (*TraceSpans) ProtoMessage added in v0.2.0 

func (*TraceSpans) ProtoMessage()

func (*TraceSpans) ProtoReflect added in v0.2.0 

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

func (*TraceSpans) Reset added in v0.2.0 

func (x *TraceSpans) Reset()

func (*TraceSpans) String added in v0.2.0 

func (x *TraceSpans) String() string

type UpdateComponentsReply added in v0.2.0 

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

UpdateComponentsReply is a reply to an UpdateComponentsRequest.

func (*UpdateComponentsReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use UpdateComponentsReply.ProtoReflect.Descriptor instead.

func (*UpdateComponentsReply) ProtoMessage added in v0.2.0 

func (*UpdateComponentsReply) ProtoMessage()

func (*UpdateComponentsReply) ProtoReflect added in v0.2.0 

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

func (*UpdateComponentsReply) Reset added in v0.2.0 

func (x *UpdateComponentsReply) Reset()

func (*UpdateComponentsReply) String added in v0.2.0 

func (x *UpdateComponentsReply) String() string

type UpdateComponentsRequest added in v0.2.0 

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

UpdateComponentsRequest is a request from an envelope to the weavelet to update the set of components it should be running. Currently, the set of components must only ever increase over time.

func (*UpdateComponentsRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use UpdateComponentsRequest.ProtoReflect.Descriptor instead.

func (*UpdateComponentsRequest) GetComponents added in v0.2.0 

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

func (*UpdateComponentsRequest) ProtoMessage added in v0.2.0 

func (*UpdateComponentsRequest) ProtoMessage()

func (*UpdateComponentsRequest) ProtoReflect added in v0.2.0 

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

func (*UpdateComponentsRequest) Reset added in v0.2.0 

func (x *UpdateComponentsRequest) Reset()

func (*UpdateComponentsRequest) String added in v0.2.0 

func (x *UpdateComponentsRequest) String() string

type UpdateRoutingInfoReply added in v0.2.0 

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

UpdateRoutingInfoReply is a reply to an UpdateRoutingInfoRequest.

func (*UpdateRoutingInfoReply) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use UpdateRoutingInfoReply.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoReply) ProtoMessage added in v0.2.0 

func (*UpdateRoutingInfoReply) ProtoMessage()

func (*UpdateRoutingInfoReply) ProtoReflect added in v0.2.0 

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

func (*UpdateRoutingInfoReply) Reset added in v0.2.0 

func (x *UpdateRoutingInfoReply) Reset()

func (*UpdateRoutingInfoReply) String added in v0.2.0 

func (x *UpdateRoutingInfoReply) String() string

type UpdateRoutingInfoRequest added in v0.2.0 

type UpdateRoutingInfoRequest struct {
	RoutingInfo *RoutingInfo `protobuf:"bytes,1,opt,name=routing_info,json=routingInfo,proto3" json:"routing_info,omitempty"`
	// contains filtered or unexported fields
}

UpdateRoutingInfoRequest is a request from an envelope to the weavelet to update its routing information for a particular component.

func (*UpdateRoutingInfoRequest) Descriptor deprecated added in v0.2.0 

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

Deprecated: Use UpdateRoutingInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoRequest) GetRoutingInfo added in v0.2.0 

func (x *UpdateRoutingInfoRequest) GetRoutingInfo() *RoutingInfo

func (*UpdateRoutingInfoRequest) ProtoMessage added in v0.2.0 

func (*UpdateRoutingInfoRequest) ProtoMessage()

func (*UpdateRoutingInfoRequest) ProtoReflect added in v0.2.0 

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

func (*UpdateRoutingInfoRequest) Reset added in v0.2.0 

func (x *UpdateRoutingInfoRequest) Reset()

func (*UpdateRoutingInfoRequest) String added in v0.2.0 

func (x *UpdateRoutingInfoRequest) String() string

type WeaveletInfo added in v0.1.2 

type WeaveletInfo struct {

	// Internal TCP address of the weavelet. This address will be passed to other
	// weavelets as part of their RoutingInfo.
	DialAddr string `protobuf:"bytes,1,opt,name=dial_addr,json=dialAddr,proto3" json:"dial_addr,omitempty"`
	// Pid for the weavelet OS process.
	//
	// TODO(mwhittaker): Remove pid.
	Pid int64 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// The deployer API version of the weavelet.
	Version *SemVer `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

WeaveletInfo is the information provided by a weavelet to an envelope during the initial envelope-weavelet handshake.

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

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

Deprecated: Use WeaveletInfo.ProtoReflect.Descriptor instead.

func (*WeaveletInfo) GetDialAddr added in v0.2.0 

func (x *WeaveletInfo) GetDialAddr() string

func (*WeaveletInfo) GetPid added in v0.2.0 

func (x *WeaveletInfo) GetPid() int64

func (*WeaveletInfo) GetVersion added in v0.2.0 

func (x *WeaveletInfo) GetVersion() *SemVer

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 WeaveletMsg 

type WeaveletMsg struct {

	// A unique id for RPCs. An RPC request with positive id x expects a reply
	// with negative id -x. An unacknowledged RPC request has an id of 0.
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Handshake.
	WeaveletInfo *WeaveletInfo `protobuf:"bytes,2,opt,name=weavelet_info,json=weaveletInfo,proto3" json:"weavelet_info,omitempty"`
	// Weavelet initiated unacknowledged RPCs.
	LogEntry   *LogEntry   `protobuf:"bytes,3,opt,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
	TraceSpans *TraceSpans `protobuf:"bytes,4,opt,name=trace_spans,json=traceSpans,proto3" json:"trace_spans,omitempty"`
	// Envelope initiated RPC replies.
	Error                  string                  `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` // non-nil on error
	GetHealthReply         *GetHealthReply         `protobuf:"bytes,6,opt,name=get_health_reply,json=getHealthReply,proto3" json:"get_health_reply,omitempty"`
	GetMetricsReply        *GetMetricsReply        `protobuf:"bytes,7,opt,name=get_metrics_reply,json=getMetricsReply,proto3" json:"get_metrics_reply,omitempty"`
	GetLoadReply           *GetLoadReply           `protobuf:"bytes,8,opt,name=get_load_reply,json=getLoadReply,proto3" json:"get_load_reply,omitempty"`
	GetProfileReply        *GetProfileReply        `protobuf:"bytes,9,opt,name=get_profile_reply,json=getProfileReply,proto3" json:"get_profile_reply,omitempty"`
	UpdateRoutingInfoReply *UpdateRoutingInfoReply `` /* 132-byte string literal not displayed */
	UpdateComponentsReply  *UpdateComponentsReply  `` /* 127-byte string literal not displayed */
	// Weavelet initiated RPC requests.
	ActivateComponentRequest  *ActivateComponentRequest  `` /* 136-byte string literal not displayed */
	GetListenerAddressRequest *GetListenerAddressRequest `` /* 141-byte string literal not displayed */
	ExportListenerRequest     *ExportListenerRequest     `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

WeaveletMsg is a message sent by a weavelet to an envelope.

func (*WeaveletMsg) Descriptor deprecated 

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

Deprecated: Use WeaveletMsg.ProtoReflect.Descriptor instead.

func (*WeaveletMsg) GetActivateComponentRequest added in v0.2.0 

func (x *WeaveletMsg) GetActivateComponentRequest() *ActivateComponentRequest

func (*WeaveletMsg) GetError 

func (x *WeaveletMsg) GetError() string

func (*WeaveletMsg) GetExportListenerRequest added in v0.1.2 

func (x *WeaveletMsg) GetExportListenerRequest() *ExportListenerRequest

func (*WeaveletMsg) GetGetHealthReply added in v0.2.0 

func (x *WeaveletMsg) GetGetHealthReply() *GetHealthReply

func (*WeaveletMsg) GetGetListenerAddressRequest added in v0.2.0 

func (x *WeaveletMsg) GetGetListenerAddressRequest() *GetListenerAddressRequest

func (*WeaveletMsg) GetGetLoadReply added in v0.2.0 

func (x *WeaveletMsg) GetGetLoadReply() *GetLoadReply

func (*WeaveletMsg) GetGetMetricsReply added in v0.2.0 

func (x *WeaveletMsg) GetGetMetricsReply() *GetMetricsReply

func (*WeaveletMsg) GetGetProfileReply added in v0.2.0 

func (x *WeaveletMsg) GetGetProfileReply() *GetProfileReply

func (*WeaveletMsg) GetId 

func (x *WeaveletMsg) GetId() int64

func (*WeaveletMsg) GetLogEntry 

func (x *WeaveletMsg) GetLogEntry() *LogEntry

func (*WeaveletMsg) GetTraceSpans 

func (x *WeaveletMsg) GetTraceSpans() *TraceSpans

func (*WeaveletMsg) GetUpdateComponentsReply added in v0.2.0 

func (x *WeaveletMsg) GetUpdateComponentsReply() *UpdateComponentsReply

func (*WeaveletMsg) GetUpdateRoutingInfoReply added in v0.2.0 

func (x *WeaveletMsg) GetUpdateRoutingInfoReply() *UpdateRoutingInfoReply

func (*WeaveletMsg) GetWeaveletInfo added in v0.2.0 

func (x *WeaveletMsg) GetWeaveletInfo() *WeaveletInfo

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.