protos

package
v0.4.2 Latest Latest
Warning

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

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

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 (
	Span_Kind_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "INTERNAL",
		2: "SERVER",
		3: "CLIENT",
		4: "PRODUCER",
		5: "CONSUMER",
	}
	Span_Kind_value = map[string]int32{
		"UNSPECIFIED": 0,
		"INTERNAL":    1,
		"SERVER":      2,
		"CLIENT":      3,
		"PRODUCER":    4,
		"CONSUMER":    5,
	}
)

Enum value maps for Span_Kind.

View Source 
var (
	Span_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",
	}
	Span_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 Span_Attribute_Value_Type.

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

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

ActivateComponentReply is a reply to an ActivateComponentRequest.

func (*ActivateComponentReply) Descriptor deprecated 

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

Deprecated: Use ActivateComponentReply.ProtoReflect.Descriptor instead.

func (*ActivateComponentReply) ProtoMessage 

func (*ActivateComponentReply) ProtoMessage()

func (*ActivateComponentReply) ProtoReflect 

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

func (*ActivateComponentReply) Reset 

func (x *ActivateComponentReply) Reset()

func (*ActivateComponentReply) String 

func (x *ActivateComponentReply) String() string

type ActivateComponentRequest 

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 

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

Deprecated: Use ActivateComponentRequest.ProtoReflect.Descriptor instead.

func (*ActivateComponentRequest) GetComponent 

func (x *ActivateComponentRequest) GetComponent() string

func (*ActivateComponentRequest) GetRouted 

func (x *ActivateComponentRequest) GetRouted() bool

func (*ActivateComponentRequest) ProtoMessage 

func (*ActivateComponentRequest) ProtoMessage()

func (*ActivateComponentRequest) ProtoReflect 

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

func (*ActivateComponentRequest) Reset 

func (x *ActivateComponentRequest) Reset()

func (*ActivateComponentRequest) String 

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 

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 ComponentGroup 

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 

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

Deprecated: Use ComponentGroup.ProtoReflect.Descriptor instead.

func (*ComponentGroup) GetComponents 

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

func (*ComponentGroup) ProtoMessage 

func (*ComponentGroup) ProtoMessage()

func (*ComponentGroup) ProtoReflect 

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

func (*ComponentGroup) Reset 

func (x *ComponentGroup) Reset()

func (*ComponentGroup) String 

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

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 

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"`
	// 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 

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

Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.

func (*ExportListenerRequest) GetAddress 

func (x *ExportListenerRequest) GetAddress() string

func (*ExportListenerRequest) GetListener 

func (x *ExportListenerRequest) GetListener() string

func (*ExportListenerRequest) ProtoMessage 

func (*ExportListenerRequest) ProtoMessage()

func (*ExportListenerRequest) ProtoReflect 

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

func (*ExportListenerRequest) Reset 

func (x *ExportListenerRequest) Reset()

func (*ExportListenerRequest) String 

func (x *ExportListenerRequest) String() string

type GetHealthReply 

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 

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

Deprecated: Use GetHealthReply.ProtoReflect.Descriptor instead.

func (*GetHealthReply) GetStatus 

func (x *GetHealthReply) GetStatus() HealthStatus

func (*GetHealthReply) ProtoMessage 

func (*GetHealthReply) ProtoMessage()

func (*GetHealthReply) ProtoReflect 

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

func (*GetHealthReply) Reset 

func (x *GetHealthReply) Reset()

func (*GetHealthReply) String 

func (x *GetHealthReply) String() string

type GetHealthRequest 

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

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

func (*GetHealthRequest) Descriptor deprecated 

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

Deprecated: Use GetHealthRequest.ProtoReflect.Descriptor instead.

func (*GetHealthRequest) ProtoMessage 

func (*GetHealthRequest) ProtoMessage()

func (*GetHealthRequest) ProtoReflect 

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

func (*GetHealthRequest) Reset 

func (x *GetHealthRequest) Reset()

func (*GetHealthRequest) String 

func (x *GetHealthRequest) String() string

type GetListenerAddressReply 

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 

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

Deprecated: Use GetListenerAddressReply.ProtoReflect.Descriptor instead.

func (*GetListenerAddressReply) GetAddress 

func (x *GetListenerAddressReply) GetAddress() string

func (*GetListenerAddressReply) ProtoMessage 

func (*GetListenerAddressReply) ProtoMessage()

func (*GetListenerAddressReply) ProtoReflect 

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

func (*GetListenerAddressReply) Reset 

func (x *GetListenerAddressReply) Reset()

func (*GetListenerAddressReply) String 

func (x *GetListenerAddressReply) String() string

type GetListenerAddressRequest 

type GetListenerAddressRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // listener name
	// 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 

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

Deprecated: Use GetListenerAddressRequest.ProtoReflect.Descriptor instead.

func (*GetListenerAddressRequest) GetName 

func (x *GetListenerAddressRequest) GetName() string

func (*GetListenerAddressRequest) ProtoMessage 

func (*GetListenerAddressRequest) ProtoMessage()

func (*GetListenerAddressRequest) ProtoReflect 

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

func (*GetListenerAddressRequest) Reset 

func (x *GetListenerAddressRequest) Reset()

func (*GetListenerAddressRequest) String 

func (x *GetListenerAddressRequest) String() string

type GetLoadReply 

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 

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

Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.

func (*GetLoadReply) GetLoad 

func (x *GetLoadReply) GetLoad() *LoadReport

func (*GetLoadReply) ProtoMessage 

func (*GetLoadReply) ProtoMessage()

func (*GetLoadReply) ProtoReflect 

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

func (*GetLoadReply) Reset 

func (x *GetLoadReply) Reset()

func (*GetLoadReply) String 

func (x *GetLoadReply) String() string

type GetLoadRequest 

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 

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

Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.

func (*GetLoadRequest) ProtoMessage 

func (*GetLoadRequest) ProtoMessage()

func (*GetLoadRequest) ProtoReflect 

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

func (*GetLoadRequest) Reset 

func (x *GetLoadRequest) Reset()

func (*GetLoadRequest) String 

func (x *GetLoadRequest) String() string

type GetMetricsReply 

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 

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

Deprecated: Use GetMetricsReply.ProtoReflect.Descriptor instead.

func (*GetMetricsReply) GetUpdate 

func (x *GetMetricsReply) GetUpdate() *MetricUpdate

func (*GetMetricsReply) ProtoMessage 

func (*GetMetricsReply) ProtoMessage()

func (*GetMetricsReply) ProtoReflect 

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

func (*GetMetricsReply) Reset 

func (x *GetMetricsReply) Reset()

func (*GetMetricsReply) String 

func (x *GetMetricsReply) String() string

type GetMetricsRequest 

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 

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect 

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

func (*GetMetricsRequest) Reset 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String 

func (x *GetMetricsRequest) String() string

type GetProfileReply 

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 

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

Deprecated: Use GetProfileReply.ProtoReflect.Descriptor instead.

func (*GetProfileReply) GetData 

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

func (*GetProfileReply) ProtoMessage 

func (*GetProfileReply) ProtoMessage()

func (*GetProfileReply) ProtoReflect 

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

func (*GetProfileReply) Reset 

func (x *GetProfileReply) Reset()

func (*GetProfileReply) String 

func (x *GetProfileReply) String() string

type GetProfileRequest 

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. Some profile types only support a single profile request at a time and an error will be returned if another profile request is active.

func (*GetProfileRequest) Descriptor deprecated 

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

Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetProfileRequest) GetCpuDurationNs 

func (x *GetProfileRequest) GetCpuDurationNs() int64

func (*GetProfileRequest) GetProfileType 

func (x *GetProfileRequest) GetProfileType() ProfileType

func (*GetProfileRequest) ProtoMessage 

func (*GetProfileRequest) ProtoMessage()

func (*GetProfileRequest) ProtoReflect 

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

func (*GetProfileRequest) Reset 

func (x *GetProfileRequest) Reset()

func (*GetProfileRequest) String 

func (x *GetProfileRequest) String() string

type GetSelfCertificateReply 

type GetSelfCertificateReply struct {

	// PEM-encoded blocks containing (1) the certificate identifying the
	// weavelet and (2) the corresponding private key. Used for enforcing mTLS
	// security across components.
	Cert []byte `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"` // certificate identifying the weavelet
	Key  []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`   // private key corresponding to cert
	// contains filtered or unexported fields
}

GetSelfCertificateReply is a reply to a GetSelfCertificateRequest.

func (*GetSelfCertificateReply) Descriptor deprecated 

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

Deprecated: Use GetSelfCertificateReply.ProtoReflect.Descriptor instead.

func (*GetSelfCertificateReply) GetCert 

func (x *GetSelfCertificateReply) GetCert() []byte

func (*GetSelfCertificateReply) GetKey 

func (x *GetSelfCertificateReply) GetKey() []byte

func (*GetSelfCertificateReply) ProtoMessage 

func (*GetSelfCertificateReply) ProtoMessage()

func (*GetSelfCertificateReply) ProtoReflect 

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

func (*GetSelfCertificateReply) Reset 

func (x *GetSelfCertificateReply) Reset()

func (*GetSelfCertificateReply) String 

func (x *GetSelfCertificateReply) String() string

type GetSelfCertificateRequest 

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

GetSelfCertificateRequest is a request from a weavelet for its certificate and the corresponding private key.

func (*GetSelfCertificateRequest) Descriptor deprecated 

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

Deprecated: Use GetSelfCertificateRequest.ProtoReflect.Descriptor instead.

func (*GetSelfCertificateRequest) ProtoMessage 

func (*GetSelfCertificateRequest) ProtoMessage()

func (*GetSelfCertificateRequest) ProtoReflect 

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

func (*GetSelfCertificateRequest) Reset 

func (x *GetSelfCertificateRequest) Reset()

func (*GetSelfCertificateRequest) String 

func (x *GetSelfCertificateRequest) 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 InitWeaveletReply 

type InitWeaveletReply 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"`
	// The deployer API version of the weavelet.
	Version *SemVer `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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

func (*InitWeaveletReply) Descriptor deprecated 

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

Deprecated: Use InitWeaveletReply.ProtoReflect.Descriptor instead.

func (*InitWeaveletReply) GetDialAddr 

func (x *InitWeaveletReply) GetDialAddr() string

func (*InitWeaveletReply) GetVersion 

func (x *InitWeaveletReply) GetVersion() *SemVer

func (*InitWeaveletReply) ProtoMessage 

func (*InitWeaveletReply) ProtoMessage()

func (*InitWeaveletReply) ProtoReflect 

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

func (*InitWeaveletReply) Reset 

func (x *InitWeaveletReply) Reset()

func (*InitWeaveletReply) String 

func (x *InitWeaveletReply) String() string

type InitWeaveletRequest 

type InitWeaveletRequest struct {
	Sections map[string]string `` // See AppConfig.Sections.
	/* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

InitWeaveletRequest holds the initialization info passed to the weavelet by the envelope.

func (*InitWeaveletRequest) Descriptor deprecated 

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

Deprecated: Use InitWeaveletRequest.ProtoReflect.Descriptor instead.

func (*InitWeaveletRequest) GetSections 

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

func (*InitWeaveletRequest) ProtoMessage 

func (*InitWeaveletRequest) ProtoMessage()

func (*InitWeaveletRequest) ProtoReflect 

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

func (*InitWeaveletRequest) Reset 

func (x *InitWeaveletRequest) Reset()

func (*InitWeaveletRequest) String 

func (x *InitWeaveletRequest) String() string

type LoadReport 

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 

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

Deprecated: Use LoadReport.ProtoReflect.Descriptor instead.

func (*LoadReport) GetLoads 

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

func (*LoadReport) ProtoMessage 

func (*LoadReport) ProtoMessage()

func (*LoadReport) ProtoReflect 

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

func (*LoadReport) Reset 

func (x *LoadReport) Reset()

func (*LoadReport) String 

func (x *LoadReport) String() string

type LoadReport_ComponentLoad 

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 

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

Deprecated: Use LoadReport_ComponentLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_ComponentLoad) GetLoad 

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

func (*LoadReport_ComponentLoad) GetVersion 

func (x *LoadReport_ComponentLoad) GetVersion() uint64

func (*LoadReport_ComponentLoad) ProtoMessage 

func (*LoadReport_ComponentLoad) ProtoMessage()

func (*LoadReport_ComponentLoad) ProtoReflect 

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

func (*LoadReport_ComponentLoad) Reset 

func (x *LoadReport_ComponentLoad) Reset()

func (*LoadReport_ComponentLoad) String 

func (x *LoadReport_ComponentLoad) String() string

type LoadReport_SliceLoad 

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 

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

Deprecated: Use LoadReport_SliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SliceLoad) GetEnd 

func (x *LoadReport_SliceLoad) GetEnd() uint64

func (*LoadReport_SliceLoad) GetLoad 

func (x *LoadReport_SliceLoad) GetLoad() float64

func (*LoadReport_SliceLoad) GetSize 

func (x *LoadReport_SliceLoad) GetSize() uint64

func (*LoadReport_SliceLoad) GetSplits 

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

func (*LoadReport_SliceLoad) GetStart 

func (x *LoadReport_SliceLoad) GetStart() uint64

func (*LoadReport_SliceLoad) ProtoMessage 

func (*LoadReport_SliceLoad) ProtoMessage()

func (*LoadReport_SliceLoad) ProtoReflect 

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

func (*LoadReport_SliceLoad) Reset 

func (x *LoadReport_SliceLoad) Reset()

func (*LoadReport_SliceLoad) String 

func (x *LoadReport_SliceLoad) String() string

type LoadReport_SubsliceLoad 

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 

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

Deprecated: Use LoadReport_SubsliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SubsliceLoad) GetLoad 

func (x *LoadReport_SubsliceLoad) GetLoad() float64

func (*LoadReport_SubsliceLoad) GetStart 

func (x *LoadReport_SubsliceLoad) GetStart() uint64

func (*LoadReport_SubsliceLoad) ProtoMessage 

func (*LoadReport_SubsliceLoad) ProtoMessage()

func (*LoadReport_SubsliceLoad) ProtoReflect 

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

func (*LoadReport_SubsliceLoad) Reset 

func (x *LoadReport_SubsliceLoad) Reset()

func (*LoadReport_SubsliceLoad) String 

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 LogEntryBatch 

type LogEntryBatch struct {
	Entries []*LogEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

LogEntryBatch is a list of log entries.

func (*LogEntryBatch) Descriptor deprecated 

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

Deprecated: Use LogEntryBatch.ProtoReflect.Descriptor instead.

func (*LogEntryBatch) GetEntries 

func (x *LogEntryBatch) GetEntries() []*LogEntry

func (*LogEntryBatch) ProtoMessage 

func (*LogEntryBatch) ProtoMessage()

func (*LogEntryBatch) ProtoReflect 

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

func (*LogEntryBatch) Reset 

func (x *LogEntryBatch) Reset()

func (*LogEntryBatch) String 

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

func (x *RoutingInfo) GetAssignment() *Assignment

func (*RoutingInfo) GetComponent 

func (x *RoutingInfo) GetComponent() string

func (*RoutingInfo) GetLocal 

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 

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 

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

Deprecated: Use SemVer.ProtoReflect.Descriptor instead.

func (*SemVer) GetMajor 

func (x *SemVer) GetMajor() int64

func (*SemVer) GetMinor 

func (x *SemVer) GetMinor() int64

func (*SemVer) GetPatch 

func (x *SemVer) GetPatch() int64

func (*SemVer) ProtoMessage 

func (*SemVer) ProtoMessage()

func (*SemVer) ProtoReflect 

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

func (*SemVer) Reset 

func (x *SemVer) Reset()

func (*SemVer) String 

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, 16 bytes long.
	SpanId       []byte            `protobuf:"bytes,3,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`                     // Unique span id, 8 bytes long.
	ParentSpanId []byte            `protobuf:"bytes,4,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"` // Parent span id, 8 bytes long
	Kind         Span_Kind         `protobuf:"varint,5,opt,name=kind,proto3,enum=runtime.Span_Kind" json:"kind,omitempty"`
	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   []*Span_Attribute `protobuf:"bytes,8,rep,name=attributes,proto3" json:"attributes,omitempty"`
	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
	Scope        *Span_Scope       `protobuf:"bytes,18,opt,name=scope,proto3" json:"scope,omitempty"`
	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 [1].

[1]: https://opentelemetry.io/docs/concepts/signals/traces/#spans TODO(spetrovic): Rename to TraceSpan.

func (*Span) Descriptor deprecated 

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetAttributes 

func (x *Span) GetAttributes() []*Span_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() Span_Kind

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) GetScope 

func (x *Span) GetScope() *Span_Scope

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 Span_Attribute 

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

Span attributes.

func (*Span_Attribute) Descriptor deprecated 

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

Deprecated: Use Span_Attribute.ProtoReflect.Descriptor instead.

func (*Span_Attribute) GetKey 

func (x *Span_Attribute) GetKey() string

func (*Span_Attribute) GetValue 

func (x *Span_Attribute) GetValue() *Span_Attribute_Value

func (*Span_Attribute) ProtoMessage 

func (*Span_Attribute) ProtoMessage()

func (*Span_Attribute) ProtoReflect 

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

func (*Span_Attribute) Reset 

func (x *Span_Attribute) Reset()

func (*Span_Attribute) String 

func (x *Span_Attribute) String() string

type Span_Attribute_Value 

type Span_Attribute_Value struct {
	Type Span_Attribute_Value_Type `protobuf:"varint,1,opt,name=type,proto3,enum=runtime.Span_Attribute_Value_Type" json:"type,omitempty"` // Attribute type
	// Types that are assignable to Value:
	//
	//	*Span_Attribute_Value_Num
	//	*Span_Attribute_Value_Str
	//	*Span_Attribute_Value_Nums
	//	*Span_Attribute_Value_Strs
	Value isSpan_Attribute_Value_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Span_Attribute_Value) Descriptor deprecated 

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

Deprecated: Use Span_Attribute_Value.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value) GetNum 

func (x *Span_Attribute_Value) GetNum() uint64

func (*Span_Attribute_Value) GetNums 

func (x *Span_Attribute_Value) GetNums() *Span_Attribute_Value_NumberList

func (*Span_Attribute_Value) GetStr 

func (x *Span_Attribute_Value) GetStr() string

func (*Span_Attribute_Value) GetStrs 

func (x *Span_Attribute_Value) GetStrs() *Span_Attribute_Value_StringList

func (*Span_Attribute_Value) GetType 

func (x *Span_Attribute_Value) GetType() Span_Attribute_Value_Type

func (*Span_Attribute_Value) GetValue 

func (m *Span_Attribute_Value) GetValue() isSpan_Attribute_Value_Value

func (*Span_Attribute_Value) ProtoMessage 

func (*Span_Attribute_Value) ProtoMessage()

func (*Span_Attribute_Value) ProtoReflect 

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

func (*Span_Attribute_Value) Reset 

func (x *Span_Attribute_Value) Reset()

func (*Span_Attribute_Value) String 

func (x *Span_Attribute_Value) String() string

type Span_Attribute_Value_Num 

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

type Span_Attribute_Value_NumberList 

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

func (*Span_Attribute_Value_NumberList) Descriptor deprecated 

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

Deprecated: Use Span_Attribute_Value_NumberList.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value_NumberList) GetNums 

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

func (*Span_Attribute_Value_NumberList) ProtoMessage 

func (*Span_Attribute_Value_NumberList) ProtoMessage()

func (*Span_Attribute_Value_NumberList) ProtoReflect 

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

func (*Span_Attribute_Value_NumberList) Reset 

func (x *Span_Attribute_Value_NumberList) Reset()

func (*Span_Attribute_Value_NumberList) String 

func (x *Span_Attribute_Value_NumberList) String() string

type Span_Attribute_Value_Nums 

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

type Span_Attribute_Value_Str 

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

type Span_Attribute_Value_StringList 

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

func (*Span_Attribute_Value_StringList) Descriptor deprecated 

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

Deprecated: Use Span_Attribute_Value_StringList.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value_StringList) GetStrs 

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

func (*Span_Attribute_Value_StringList) ProtoMessage 

func (*Span_Attribute_Value_StringList) ProtoMessage()

func (*Span_Attribute_Value_StringList) ProtoReflect 

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

func (*Span_Attribute_Value_StringList) Reset 

func (x *Span_Attribute_Value_StringList) Reset()

func (*Span_Attribute_Value_StringList) String 

func (x *Span_Attribute_Value_StringList) String() string

type Span_Attribute_Value_Strs 

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

type Span_Attribute_Value_Type 

type Span_Attribute_Value_Type int32

Type describes the type of the value. 

const (
	Span_Attribute_Value_INVALID     Span_Attribute_Value_Type = 0 // Used when no value is set
	Span_Attribute_Value_BOOL        Span_Attribute_Value_Type = 1
	Span_Attribute_Value_INT64       Span_Attribute_Value_Type = 2
	Span_Attribute_Value_FLOAT64     Span_Attribute_Value_Type = 3
	Span_Attribute_Value_STRING      Span_Attribute_Value_Type = 4
	Span_Attribute_Value_BOOLLIST    Span_Attribute_Value_Type = 5
	Span_Attribute_Value_INT64LIST   Span_Attribute_Value_Type = 6
	Span_Attribute_Value_FLOAT64LIST Span_Attribute_Value_Type = 7
	Span_Attribute_Value_STRINGLIST  Span_Attribute_Value_Type = 8
)

func (Span_Attribute_Value_Type) Descriptor 

func (Span_Attribute_Value_Type) Descriptor() protoreflect.EnumDescriptor

func (Span_Attribute_Value_Type) Enum 

func (x Span_Attribute_Value_Type) Enum() *Span_Attribute_Value_Type

func (Span_Attribute_Value_Type) EnumDescriptor deprecated 

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

Deprecated: Use Span_Attribute_Value_Type.Descriptor instead.

func (Span_Attribute_Value_Type) Number 

func (x Span_Attribute_Value_Type) Number() protoreflect.EnumNumber

func (Span_Attribute_Value_Type) String 

func (x Span_Attribute_Value_Type) String() string

func (Span_Attribute_Value_Type) Type 

func (Span_Attribute_Value_Type) 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 []*Span_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() []*Span_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_Kind 

type Span_Kind int32

Span's role in the trace. 

const (
	Span_UNSPECIFIED Span_Kind = 0
	Span_INTERNAL    Span_Kind = 1
	Span_SERVER      Span_Kind = 2
	Span_CLIENT      Span_Kind = 3
	Span_PRODUCER    Span_Kind = 4
	Span_CONSUMER    Span_Kind = 5
)

func (Span_Kind) Descriptor 

func (Span_Kind) Descriptor() protoreflect.EnumDescriptor

func (Span_Kind) Enum 

func (x Span_Kind) Enum() *Span_Kind

func (Span_Kind) EnumDescriptor deprecated 

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

Deprecated: Use Span_Kind.Descriptor instead.

func (Span_Kind) Number 

func (x Span_Kind) Number() protoreflect.EnumNumber

func (Span_Kind) String 

func (x Span_Kind) String() string

func (Span_Kind) Type 

func (Span_Kind) Type() protoreflect.EnumType

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 []*Span_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() []*Span_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 []*Span_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() []*Span_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_Scope 

type Span_Scope 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 scope
	SchemaUrl string `protobuf:"bytes,3,opt,name=schema_url,json=schemaUrl,proto3" json:"schema_url,omitempty"` // Schema url of the telemetry emitted by scope
	// contains filtered or unexported fields
}

Scope stores information about the instrumentation scope that created the span.

func (*Span_Scope) Descriptor deprecated 

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

Deprecated: Use Span_Scope.ProtoReflect.Descriptor instead.

func (*Span_Scope) GetName 

func (x *Span_Scope) GetName() string

func (*Span_Scope) GetSchemaUrl 

func (x *Span_Scope) GetSchemaUrl() string

func (*Span_Scope) GetVersion 

func (x *Span_Scope) GetVersion() string

func (*Span_Scope) ProtoMessage 

func (*Span_Scope) ProtoMessage()

func (*Span_Scope) ProtoReflect 

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

func (*Span_Scope) Reset 

func (x *Span_Scope) Reset()

func (*Span_Scope) String 

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

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 

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

Deprecated: Use TraceSpans.ProtoReflect.Descriptor instead.

func (*TraceSpans) GetSpan 

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

func (*TraceSpans) ProtoMessage 

func (*TraceSpans) ProtoMessage()

func (*TraceSpans) ProtoReflect 

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

func (*TraceSpans) Reset 

func (x *TraceSpans) Reset()

func (*TraceSpans) String 

func (x *TraceSpans) String() string

type UpdateComponentsReply 

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

UpdateComponentsReply is a reply to an UpdateComponentsRequest.

func (*UpdateComponentsReply) Descriptor deprecated 

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

Deprecated: Use UpdateComponentsReply.ProtoReflect.Descriptor instead.

func (*UpdateComponentsReply) ProtoMessage 

func (*UpdateComponentsReply) ProtoMessage()

func (*UpdateComponentsReply) ProtoReflect 

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

func (*UpdateComponentsReply) Reset 

func (x *UpdateComponentsReply) Reset()

func (*UpdateComponentsReply) String 

func (x *UpdateComponentsReply) String() string

type UpdateComponentsRequest 

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 

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

Deprecated: Use UpdateComponentsRequest.ProtoReflect.Descriptor instead.

func (*UpdateComponentsRequest) GetComponents 

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

func (*UpdateComponentsRequest) ProtoMessage 

func (*UpdateComponentsRequest) ProtoMessage()

func (*UpdateComponentsRequest) ProtoReflect 

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

func (*UpdateComponentsRequest) Reset 

func (x *UpdateComponentsRequest) Reset()

func (*UpdateComponentsRequest) String 

func (x *UpdateComponentsRequest) String() string

type UpdateRoutingInfoReply 

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

UpdateRoutingInfoReply is a reply to an UpdateRoutingInfoRequest.

func (*UpdateRoutingInfoReply) Descriptor deprecated 

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

Deprecated: Use UpdateRoutingInfoReply.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoReply) ProtoMessage 

func (*UpdateRoutingInfoReply) ProtoMessage()

func (*UpdateRoutingInfoReply) ProtoReflect 

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

func (*UpdateRoutingInfoReply) Reset 

func (x *UpdateRoutingInfoReply) Reset()

func (*UpdateRoutingInfoReply) String 

func (x *UpdateRoutingInfoReply) String() string

type UpdateRoutingInfoRequest 

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 

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

Deprecated: Use UpdateRoutingInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoRequest) GetRoutingInfo 

func (x *UpdateRoutingInfoRequest) GetRoutingInfo() *RoutingInfo

func (*UpdateRoutingInfoRequest) ProtoMessage 

func (*UpdateRoutingInfoRequest) ProtoMessage()

func (*UpdateRoutingInfoRequest) ProtoReflect 

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

func (*UpdateRoutingInfoRequest) Reset 

func (x *UpdateRoutingInfoRequest) Reset()

func (*UpdateRoutingInfoRequest) String 

func (x *UpdateRoutingInfoRequest) String() string

type VerifyClientCertificateReply 

type VerifyClientCertificateReply struct {

	// The set of components hosted by the weavelet that the client is allowed to
	// invoke methods on.
	Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

VerifyClientCertificateReply is a reply to a VerifyClientCertificateRequest. If the client certificate cannot be verified, an error should be returned rather than an empty reply.

func (*VerifyClientCertificateReply) Descriptor deprecated 

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

Deprecated: Use VerifyClientCertificateReply.ProtoReflect.Descriptor instead.

func (*VerifyClientCertificateReply) GetComponents 

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

func (*VerifyClientCertificateReply) ProtoMessage 

func (*VerifyClientCertificateReply) ProtoMessage()

func (*VerifyClientCertificateReply) ProtoReflect 

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

func (*VerifyClientCertificateReply) Reset 

func (x *VerifyClientCertificateReply) Reset()

func (*VerifyClientCertificateReply) String 

func (x *VerifyClientCertificateReply) String() string

type VerifyClientCertificateRequest 

type VerifyClientCertificateRequest struct {

	// Client's certificate chain. Each certificate in the chain is represented as
	// a DER-encoded ASN.1 structure.
	CertChain [][]byte `protobuf:"bytes,1,rep,name=cert_chain,json=certChain,proto3" json:"cert_chain,omitempty"`
	// contains filtered or unexported fields
}

VerifyClientCertificateRequest is a request from a weavelet to verify the identity of a client that is attempting to connect to the weavelet.

func (*VerifyClientCertificateRequest) Descriptor deprecated 

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

Deprecated: Use VerifyClientCertificateRequest.ProtoReflect.Descriptor instead.

func (*VerifyClientCertificateRequest) GetCertChain 

func (x *VerifyClientCertificateRequest) GetCertChain() [][]byte

func (*VerifyClientCertificateRequest) ProtoMessage 

func (*VerifyClientCertificateRequest) ProtoMessage()

func (*VerifyClientCertificateRequest) ProtoReflect 

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

func (*VerifyClientCertificateRequest) Reset 

func (x *VerifyClientCertificateRequest) Reset()

func (*VerifyClientCertificateRequest) String 

func (x *VerifyClientCertificateRequest) String() string

type VerifyServerCertificateReply 

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

VerifyServerCertificateReply is a reply to a VerifyServerCertificateRequest.

func (*VerifyServerCertificateReply) Descriptor deprecated 

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

Deprecated: Use VerifyServerCertificateReply.ProtoReflect.Descriptor instead.

func (*VerifyServerCertificateReply) ProtoMessage 

func (*VerifyServerCertificateReply) ProtoMessage()

func (*VerifyServerCertificateReply) ProtoReflect 

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

func (*VerifyServerCertificateReply) Reset 

func (x *VerifyServerCertificateReply) Reset()

func (*VerifyServerCertificateReply) String 

func (x *VerifyServerCertificateReply) String() string

type VerifyServerCertificateRequest 

type VerifyServerCertificateRequest struct {

	// Server's certificate chain. Each certificate in the chain is represented as
	// a DER-encoded ASN.1 structure.
	CertChain [][]byte `protobuf:"bytes,1,rep,name=cert_chain,json=certChain,proto3" json:"cert_chain,omitempty"`
	// Name of the component the server is meant to be hosting.
	TargetComponent string `protobuf:"bytes,2,opt,name=target_component,json=targetComponent,proto3" json:"target_component,omitempty"`
	// contains filtered or unexported fields
}

VerifyServerCertificateRequest is a request from a weavelet to verify the identity of the server it is attempting to connect to.

func (*VerifyServerCertificateRequest) Descriptor deprecated 

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

Deprecated: Use VerifyServerCertificateRequest.ProtoReflect.Descriptor instead.

func (*VerifyServerCertificateRequest) GetCertChain 

func (x *VerifyServerCertificateRequest) GetCertChain() [][]byte

func (*VerifyServerCertificateRequest) GetTargetComponent 

func (x *VerifyServerCertificateRequest) GetTargetComponent() string

func (*VerifyServerCertificateRequest) ProtoMessage 

func (*VerifyServerCertificateRequest) ProtoMessage()

func (*VerifyServerCertificateRequest) ProtoReflect 

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

func (*VerifyServerCertificateRequest) Reset 

func (x *VerifyServerCertificateRequest) Reset()

func (*VerifyServerCertificateRequest) String 

func (x *VerifyServerCertificateRequest) String() string

type WeaveletArgs 

type WeaveletArgs 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
	RunMain      bool   `protobuf:"varint,7,opt,name=run_main,json=runMain,proto3" json:"run_main,omitempty"`               // run the main function?
	// Should weavelets establish mTLS connections with each other?
	Mtls bool `protobuf:"varint,8,opt,name=mtls,proto3" json:"mtls,omitempty"`
	// Address on which the weavelet's internal network listener should listen on
	// (e.g., "localhost:12345", ":0"). If the address is empty, it defaults to
	// ":0", like net.Listen.
	//
	// Note that for some deployers, the internal network listener can listen on
	// an arbitrary port (don't set the port number). However, for deployers where
	// listeners are prestarted (e.g., Kubernetes deployers), the port number
	// should be propagated from the deployer.
	InternalAddress string `protobuf:"bytes,10,opt,name=internal_address,json=internalAddress,proto3" json:"internal_address,omitempty"`
	// Unix domain socket path where weavelet should serve Control component
	// method calls.
	ControlSocket string                   `protobuf:"bytes,13,opt,name=control_socket,json=controlSocket,proto3" json:"control_socket,omitempty"`
	Redirects     []*WeaveletArgs_Redirect `protobuf:"bytes,12,rep,name=redirects,proto3" json:"redirects,omitempty"`
	// contains filtered or unexported fields
}

WeaveletArgs is the information provided by an envelope to a weavelet when the weavelet is created.

func (*WeaveletArgs) Descriptor deprecated 

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

Deprecated: Use WeaveletArgs.ProtoReflect.Descriptor instead.

func (*WeaveletArgs) GetApp 

func (x *WeaveletArgs) GetApp() string

func (*WeaveletArgs) GetControlSocket 

func (x *WeaveletArgs) GetControlSocket() string

func (*WeaveletArgs) GetDeploymentId 

func (x *WeaveletArgs) GetDeploymentId() string

func (*WeaveletArgs) GetId 

func (x *WeaveletArgs) GetId() string

func (*WeaveletArgs) GetInternalAddress 

func (x *WeaveletArgs) GetInternalAddress() string

func (*WeaveletArgs) GetMtls 

func (x *WeaveletArgs) GetMtls() bool

func (*WeaveletArgs) GetRedirects 

func (x *WeaveletArgs) GetRedirects() []*WeaveletArgs_Redirect

func (*WeaveletArgs) GetRunMain 

func (x *WeaveletArgs) GetRunMain() bool

func (*WeaveletArgs) ProtoMessage 

func (*WeaveletArgs) ProtoMessage()

func (*WeaveletArgs) ProtoReflect 

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

func (*WeaveletArgs) Reset 

func (x *WeaveletArgs) Reset()

func (*WeaveletArgs) String 

func (x *WeaveletArgs) String() string

type WeaveletArgs_Redirect 

type WeaveletArgs_Redirect struct {
	Component string `protobuf:"bytes,1,opt,name=component,proto3" json:"component,omitempty"`
	Target    string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Address   string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

A redirect entry instructs the weavelet to direct calls made to component to be instead sent to the component named target at the specified address.

func (*WeaveletArgs_Redirect) Descriptor deprecated 

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

Deprecated: Use WeaveletArgs_Redirect.ProtoReflect.Descriptor instead.

func (*WeaveletArgs_Redirect) GetAddress 

func (x *WeaveletArgs_Redirect) GetAddress() string

func (*WeaveletArgs_Redirect) GetComponent 

func (x *WeaveletArgs_Redirect) GetComponent() string

func (*WeaveletArgs_Redirect) GetTarget 

func (x *WeaveletArgs_Redirect) GetTarget() string

func (*WeaveletArgs_Redirect) ProtoMessage 

func (*WeaveletArgs_Redirect) ProtoMessage()

func (*WeaveletArgs_Redirect) ProtoReflect 

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

func (*WeaveletArgs_Redirect) Reset 

func (x *WeaveletArgs_Redirect) Reset()

func (*WeaveletArgs_Redirect) String 

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