protos

package
v0.5.22 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

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 GetAntipodeAgentInfoReply added in v0.4.85

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

GetAntipodeAgentInfoReply is a reply to a GetAntipodeAgentInfoRequest.

func (*GetAntipodeAgentInfoReply) Descriptor deprecated added in v0.4.85

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

Deprecated: Use GetAntipodeAgentInfoReply.ProtoReflect.Descriptor instead.

func (*GetAntipodeAgentInfoReply) GetDatastore added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetDatastore() string

func (*GetAntipodeAgentInfoReply) GetDatastoreType added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetDatastoreType() string

func (*GetAntipodeAgentInfoReply) GetHost added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetHost() string

func (*GetAntipodeAgentInfoReply) GetPassword added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetPassword() string

func (*GetAntipodeAgentInfoReply) GetPort added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetPort() string

func (*GetAntipodeAgentInfoReply) GetQueue added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetQueue() string

func (*GetAntipodeAgentInfoReply) GetUser added in v0.4.85

func (x *GetAntipodeAgentInfoReply) GetUser() string

func (*GetAntipodeAgentInfoReply) ProtoMessage added in v0.4.85

func (*GetAntipodeAgentInfoReply) ProtoMessage()

func (*GetAntipodeAgentInfoReply) ProtoReflect added in v0.4.85

func (*GetAntipodeAgentInfoReply) Reset added in v0.4.85

func (x *GetAntipodeAgentInfoReply) Reset()

func (*GetAntipodeAgentInfoReply) String added in v0.4.85

func (x *GetAntipodeAgentInfoReply) String() string

type GetAntipodeAgentInfoRequest added in v0.4.85

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

GetAntipodeAgentInfoRequest is a request from a weavelet for the information the weavelet needs to initialize an antipode agent.

func (*GetAntipodeAgentInfoRequest) Descriptor deprecated added in v0.4.85

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

Deprecated: Use GetAntipodeAgentInfoRequest.ProtoReflect.Descriptor instead.

func (*GetAntipodeAgentInfoRequest) GetName added in v0.4.85

func (x *GetAntipodeAgentInfoRequest) GetName() string

func (*GetAntipodeAgentInfoRequest) ProtoMessage added in v0.4.85

func (*GetAntipodeAgentInfoRequest) ProtoMessage()

func (*GetAntipodeAgentInfoRequest) ProtoReflect added in v0.4.85

func (*GetAntipodeAgentInfoRequest) Reset added in v0.4.85

func (x *GetAntipodeAgentInfoRequest) Reset()

func (*GetAntipodeAgentInfoRequest) String added in v0.4.85

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

func (x HealthStatus) Enum() *HealthStatus

func (HealthStatus) EnumDescriptor deprecated

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

Deprecated: Use HealthStatus.Descriptor instead.

func (HealthStatus) Number

func (HealthStatus) String

func (x HealthStatus) String() string

func (HealthStatus) Type

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

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

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 (*Span_Attribute_Value) GetStr

func (x *Span_Attribute_Value) GetStr() string

func (*Span_Attribute_Value) GetStrs

func (*Span_Attribute_Value) GetType

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 (*Span_Attribute_Value_NumberList) Reset

func (*Span_Attribute_Value_NumberList) 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 (*Span_Attribute_Value_StringList) Reset

func (*Span_Attribute_Value_StringList) 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) Enum

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 (Span_Attribute_Value_Type) String

func (x Span_Attribute_Value_Type) String() string

func (Span_Attribute_Value_Type) Type

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

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

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 (Span_Status_Code) String

func (x Span_Status_Code) String() string

func (Span_Status_Code) Type

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 (*VerifyClientCertificateReply) Reset

func (x *VerifyClientCertificateReply) Reset()

func (*VerifyClientCertificateReply) 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 (*VerifyClientCertificateRequest) Reset

func (x *VerifyClientCertificateRequest) Reset()

func (*VerifyClientCertificateRequest) 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 (*VerifyServerCertificateReply) Reset

func (x *VerifyServerCertificateReply) Reset()

func (*VerifyServerCertificateReply) 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 (*VerifyServerCertificateRequest) Reset

func (x *VerifyServerCertificateRequest) Reset()

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL