protos

package
v0.21.2 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2023 License: Apache-2.0 Imports: 4 Imported by: 5

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

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

ActivateComponentReply is a reply to an ActivateComponentRequest.

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

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

Deprecated: Use ActivateComponentReply.ProtoReflect.Descriptor instead.

func (*ActivateComponentReply) ProtoMessage added in v0.2.0 

func (*ActivateComponentReply) ProtoMessage()

func (*ActivateComponentReply) ProtoReflect added in v0.2.0 

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

func (*ActivateComponentReply) Reset added in v0.2.0 

func (x *ActivateComponentReply) Reset()

func (*ActivateComponentReply) String added in v0.2.0 

func (x *ActivateComponentReply) String() string

type ActivateComponentRequest added in v0.2.0 

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

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

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

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

Deprecated: Use ActivateComponentRequest.ProtoReflect.Descriptor instead.

func (*ActivateComponentRequest) GetComponent added in v0.2.0 

func (x *ActivateComponentRequest) GetComponent() string

func (*ActivateComponentRequest) GetRouted added in v0.2.0 

func (x *ActivateComponentRequest) GetRouted() bool

func (*ActivateComponentRequest) ProtoMessage added in v0.2.0 

func (*ActivateComponentRequest) ProtoMessage()

func (*ActivateComponentRequest) ProtoReflect added in v0.2.0 

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

func (*ActivateComponentRequest) Reset added in v0.2.0 

func (x *ActivateComponentRequest) Reset()

func (*ActivateComponentRequest) String added in v0.2.0 

func (x *ActivateComponentRequest) String() string

type AppConfig 

type AppConfig struct {

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

AppConfig holds configuration for a Service Weaver application.

func (*AppConfig) Descriptor deprecated 

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

Deprecated: Use AppConfig.ProtoReflect.Descriptor instead.

func (*AppConfig) GetArgs 

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

func (*AppConfig) GetBinary 

func (x *AppConfig) GetBinary() string

func (*AppConfig) GetColocate added in v0.2.0 

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

func (*AppConfig) GetEnv 

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

func (*AppConfig) GetName 

func (x *AppConfig) GetName() string

func (*AppConfig) GetRolloutNanos 

func (x *AppConfig) GetRolloutNanos() int64

func (*AppConfig) GetSections 

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

func (*AppConfig) ProtoMessage 

func (*AppConfig) ProtoMessage()

func (*AppConfig) ProtoReflect 

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

func (*AppConfig) Reset 

func (x *AppConfig) Reset()

func (*AppConfig) String 

func (x *AppConfig) String() string

type Assignment 

type Assignment struct {
	Slices []*Assignment_Slice `protobuf:"bytes,1,rep,name=slices,proto3" json:"slices,omitempty"`
	// The assignment for a component can change over time. Every one of these
	// assignments is given a monotonically increasing version. Versions are
	// unique for a given component, but not unique across components.
	Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Assignment) Descriptor deprecated 

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

Deprecated: Use Assignment.ProtoReflect.Descriptor instead.

func (*Assignment) GetSlices 

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

func (*Assignment) GetVersion 

func (x *Assignment) GetVersion() uint64

func (*Assignment) ProtoMessage 

func (*Assignment) ProtoMessage()

func (*Assignment) ProtoReflect 

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

func (*Assignment) Reset 

func (x *Assignment) Reset()

func (*Assignment) String 

func (x *Assignment) String() string

type Assignment_Slice 

type Assignment_Slice struct {

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

A slice of the key space and the replicas to which it is assigned.

func (*Assignment_Slice) Descriptor deprecated 

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

Deprecated: Use Assignment_Slice.ProtoReflect.Descriptor instead.

func (*Assignment_Slice) GetReplicas 

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

func (*Assignment_Slice) GetStart 

func (x *Assignment_Slice) GetStart() uint64

func (*Assignment_Slice) ProtoMessage 

func (*Assignment_Slice) ProtoMessage()

func (*Assignment_Slice) ProtoReflect 

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

func (*Assignment_Slice) Reset 

func (x *Assignment_Slice) Reset()

func (*Assignment_Slice) String 

func (x *Assignment_Slice) String() string

type ComponentGroup added in v0.1.2 

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

A group of components.

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

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

Deprecated: Use ComponentGroup.ProtoReflect.Descriptor instead.

func (*ComponentGroup) GetComponents added in v0.1.2 

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

func (*ComponentGroup) ProtoMessage added in v0.1.2 

func (*ComponentGroup) ProtoMessage()

func (*ComponentGroup) ProtoReflect added in v0.1.2 

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

func (*ComponentGroup) Reset added in v0.1.2 

func (x *ComponentGroup) Reset()

func (*ComponentGroup) String added in v0.1.2 

func (x *ComponentGroup) String() string

type Deployment 

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

Deployment holds internal information necessary for an application deployment.

TODO(mwhittaker): Delete this proto.

func (*Deployment) Descriptor deprecated 

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

Deprecated: Use Deployment.ProtoReflect.Descriptor instead.

func (*Deployment) GetApp 

func (x *Deployment) GetApp() *AppConfig

func (*Deployment) GetId 

func (x *Deployment) GetId() string

func (*Deployment) GetSingleProcess 

func (x *Deployment) GetSingleProcess() bool

func (*Deployment) ProtoMessage 

func (*Deployment) ProtoMessage()

func (*Deployment) ProtoReflect 

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

func (*Deployment) Reset 

func (x *Deployment) Reset()

func (*Deployment) String 

func (x *Deployment) String() string

type EnvelopeInfo added in v0.2.0 

type EnvelopeInfo struct {
	App          string            `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`                                       // app name
	DeploymentId string            `protobuf:"bytes,2,opt,name=deployment_id,json=deploymentId,proto3" json:"deployment_id,omitempty"` // globally unique deployment id
	Id           string            `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`                                         // globally unique weavelet id
	Sections     map[string]string ``                                                                                                  // See AppConfig.Sections.
	/* 157-byte string literal not displayed */
	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"`
	// contains filtered or unexported fields
}

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

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

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

Deprecated: Use EnvelopeInfo.ProtoReflect.Descriptor instead.

func (*EnvelopeInfo) GetApp added in v0.2.0 

func (x *EnvelopeInfo) GetApp() string

func (*EnvelopeInfo) GetDeploymentId added in v0.2.0 

func (x *EnvelopeInfo) GetDeploymentId() string

func (*EnvelopeInfo) GetId added in v0.2.0 

func (x *EnvelopeInfo) GetId() string

func (*EnvelopeInfo) GetInternalAddress added in v0.20.0 

func (x *EnvelopeInfo) GetInternalAddress() string

func (*EnvelopeInfo) GetMtls added in v0.12.0 

func (x *EnvelopeInfo) GetMtls() bool

func (*EnvelopeInfo) GetRunMain added in v0.2.0 

func (x *EnvelopeInfo) GetRunMain() bool

func (*EnvelopeInfo) GetSections added in v0.2.0 

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

func (*EnvelopeInfo) ProtoMessage added in v0.2.0 

func (*EnvelopeInfo) ProtoMessage()

func (*EnvelopeInfo) ProtoReflect added in v0.2.0 

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

func (*EnvelopeInfo) Reset added in v0.2.0 

func (x *EnvelopeInfo) Reset()

func (*EnvelopeInfo) String added in v0.2.0 

func (x *EnvelopeInfo) String() string

type EnvelopeMsg 

type EnvelopeMsg struct {

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

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

func (*EnvelopeMsg) Descriptor deprecated 

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

Deprecated: Use EnvelopeMsg.ProtoReflect.Descriptor instead.

func (*EnvelopeMsg) GetActivateComponentReply added in v0.2.0 

func (x *EnvelopeMsg) GetActivateComponentReply() *ActivateComponentReply

func (*EnvelopeMsg) GetEnvelopeInfo added in v0.2.0 

func (x *EnvelopeMsg) GetEnvelopeInfo() *EnvelopeInfo

func (*EnvelopeMsg) GetError 

func (x *EnvelopeMsg) GetError() string

func (*EnvelopeMsg) GetExportListenerReply 

func (x *EnvelopeMsg) GetExportListenerReply() *ExportListenerReply

func (*EnvelopeMsg) GetGetHealthRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetHealthRequest() *GetHealthRequest

func (*EnvelopeMsg) GetGetListenerAddressReply added in v0.2.0 

func (x *EnvelopeMsg) GetGetListenerAddressReply() *GetListenerAddressReply

func (*EnvelopeMsg) GetGetLoadRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetLoadRequest() *GetLoadRequest

func (*EnvelopeMsg) GetGetMetricsRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetMetricsRequest() *GetMetricsRequest

func (*EnvelopeMsg) GetGetProfileRequest added in v0.2.0 

func (x *EnvelopeMsg) GetGetProfileRequest() *GetProfileRequest

func (*EnvelopeMsg) GetGetSelfCertificateReply added in v0.12.0 

func (x *EnvelopeMsg) GetGetSelfCertificateReply() *GetSelfCertificateReply

func (*EnvelopeMsg) GetId 

func (x *EnvelopeMsg) GetId() int64

func (*EnvelopeMsg) GetUpdateComponentsRequest added in v0.2.0 

func (x *EnvelopeMsg) GetUpdateComponentsRequest() *UpdateComponentsRequest

func (*EnvelopeMsg) GetUpdateRoutingInfoRequest added in v0.2.0 

func (x *EnvelopeMsg) GetUpdateRoutingInfoRequest() *UpdateRoutingInfoRequest

func (*EnvelopeMsg) GetVerifyClientCertificateReply added in v0.6.0 

func (x *EnvelopeMsg) GetVerifyClientCertificateReply() *VerifyClientCertificateReply

func (*EnvelopeMsg) GetVerifyServerCertificateReply added in v0.6.0 

func (x *EnvelopeMsg) GetVerifyServerCertificateReply() *VerifyServerCertificateReply

func (*EnvelopeMsg) ProtoMessage 

func (*EnvelopeMsg) ProtoMessage()

func (*EnvelopeMsg) ProtoReflect 

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

func (*EnvelopeMsg) Reset 

func (x *EnvelopeMsg) Reset()

func (*EnvelopeMsg) String 

func (x *EnvelopeMsg) String() string

type ExportListenerReply 

type ExportListenerReply struct {

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

ExportListenerReply is a reply to an ExportListenerRequest.

func (*ExportListenerReply) Descriptor deprecated 

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

Deprecated: Use ExportListenerReply.ProtoReflect.Descriptor instead.

func (*ExportListenerReply) GetError added in v0.1.2 

func (x *ExportListenerReply) GetError() string

func (*ExportListenerReply) GetProxyAddress 

func (x *ExportListenerReply) GetProxyAddress() string

func (*ExportListenerReply) ProtoMessage 

func (*ExportListenerReply) ProtoMessage()

func (*ExportListenerReply) ProtoReflect 

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

func (*ExportListenerReply) Reset 

func (x *ExportListenerReply) Reset()

func (*ExportListenerReply) String 

func (x *ExportListenerReply) String() string

type ExportListenerRequest added in v0.1.2 

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

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

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

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

Deprecated: Use ExportListenerRequest.ProtoReflect.Descriptor instead.

func (*ExportListenerRequest) GetAddress added in v0.2.0 

func (x *ExportListenerRequest) GetAddress() string

func (*ExportListenerRequest) GetListener added in v0.1.2 

func (x *ExportListenerRequest) GetListener() string

func (*ExportListenerRequest) ProtoMessage added in v0.1.2 

func (*ExportListenerRequest) ProtoMessage()

func (*ExportListenerRequest) ProtoReflect added in v0.1.2 

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

func (*ExportListenerRequest) Reset added in v0.1.2 

func (x *ExportListenerRequest) Reset()

func (*ExportListenerRequest) String added in v0.1.2 

func (x *ExportListenerRequest) String() string

type GetHealthReply added in v0.2.0 

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

GetHealthReply is a reply to a GetHealthRequest.

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

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

Deprecated: Use GetHealthReply.ProtoReflect.Descriptor instead.

func (*GetHealthReply) GetStatus added in v0.2.0 

func (x *GetHealthReply) GetStatus() HealthStatus

func (*GetHealthReply) ProtoMessage added in v0.2.0 

func (*GetHealthReply) ProtoMessage()

func (*GetHealthReply) ProtoReflect added in v0.2.0 

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

func (*GetHealthReply) Reset added in v0.2.0 

func (x *GetHealthReply) Reset()

func (*GetHealthReply) String added in v0.2.0 

func (x *GetHealthReply) String() string

type GetHealthRequest added in v0.2.0 

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

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

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

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

Deprecated: Use GetHealthRequest.ProtoReflect.Descriptor instead.

func (*GetHealthRequest) ProtoMessage added in v0.2.0 

func (*GetHealthRequest) ProtoMessage()

func (*GetHealthRequest) ProtoReflect added in v0.2.0 

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

func (*GetHealthRequest) Reset added in v0.2.0 

func (x *GetHealthRequest) Reset()

func (*GetHealthRequest) String added in v0.2.0 

func (x *GetHealthRequest) String() string

type GetListenerAddressReply added in v0.2.0 

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

GetListenerAddressReply is a reply to a GetListenerAddressRequest.

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

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

Deprecated: Use GetListenerAddressReply.ProtoReflect.Descriptor instead.

func (*GetListenerAddressReply) GetAddress added in v0.2.0 

func (x *GetListenerAddressReply) GetAddress() string

func (*GetListenerAddressReply) ProtoMessage added in v0.2.0 

func (*GetListenerAddressReply) ProtoMessage()

func (*GetListenerAddressReply) ProtoReflect added in v0.2.0 

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

func (*GetListenerAddressReply) Reset added in v0.2.0 

func (x *GetListenerAddressReply) Reset()

func (*GetListenerAddressReply) String added in v0.2.0 

func (x *GetListenerAddressReply) String() string

type GetListenerAddressRequest added in v0.2.0 

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

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

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

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

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

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

Deprecated: Use GetListenerAddressRequest.ProtoReflect.Descriptor instead.

func (*GetListenerAddressRequest) GetName added in v0.2.0 

func (x *GetListenerAddressRequest) GetName() string

func (*GetListenerAddressRequest) ProtoMessage added in v0.2.0 

func (*GetListenerAddressRequest) ProtoMessage()

func (*GetListenerAddressRequest) ProtoReflect added in v0.2.0 

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

func (*GetListenerAddressRequest) Reset added in v0.2.0 

func (x *GetListenerAddressRequest) Reset()

func (*GetListenerAddressRequest) String added in v0.2.0 

func (x *GetListenerAddressRequest) String() string

type GetLoadReply added in v0.2.0 

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

GetLoadReply is a reply to a GetLoadRequest.

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

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

Deprecated: Use GetLoadReply.ProtoReflect.Descriptor instead.

func (*GetLoadReply) GetLoad added in v0.2.0 

func (x *GetLoadReply) GetLoad() *LoadReport

func (*GetLoadReply) ProtoMessage added in v0.2.0 

func (*GetLoadReply) ProtoMessage()

func (*GetLoadReply) ProtoReflect added in v0.2.0 

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

func (*GetLoadReply) Reset added in v0.2.0 

func (x *GetLoadReply) Reset()

func (*GetLoadReply) String added in v0.2.0 

func (x *GetLoadReply) String() string

type GetLoadRequest added in v0.2.0 

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

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

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

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

Deprecated: Use GetLoadRequest.ProtoReflect.Descriptor instead.

func (*GetLoadRequest) ProtoMessage added in v0.2.0 

func (*GetLoadRequest) ProtoMessage()

func (*GetLoadRequest) ProtoReflect added in v0.2.0 

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

func (*GetLoadRequest) Reset added in v0.2.0 

func (x *GetLoadRequest) Reset()

func (*GetLoadRequest) String added in v0.2.0 

func (x *GetLoadRequest) String() string

type GetMetricsReply added in v0.2.0 

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

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

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

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

Deprecated: Use GetMetricsReply.ProtoReflect.Descriptor instead.

func (*GetMetricsReply) GetUpdate added in v0.2.0 

func (x *GetMetricsReply) GetUpdate() *MetricUpdate

func (*GetMetricsReply) ProtoMessage added in v0.2.0 

func (*GetMetricsReply) ProtoMessage()

func (*GetMetricsReply) ProtoReflect added in v0.2.0 

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

func (*GetMetricsReply) Reset added in v0.2.0 

func (x *GetMetricsReply) Reset()

func (*GetMetricsReply) String added in v0.2.0 

func (x *GetMetricsReply) String() string

type GetMetricsRequest added in v0.2.0 

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

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

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

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

Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetMetricsRequest) ProtoMessage added in v0.2.0 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) ProtoReflect added in v0.2.0 

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

func (*GetMetricsRequest) Reset added in v0.2.0 

func (x *GetMetricsRequest) Reset()

func (*GetMetricsRequest) String added in v0.2.0 

func (x *GetMetricsRequest) String() string

type GetProfileReply added in v0.2.0 

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

GetProfileReply is a reply to a GetProfileRequest.

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

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

Deprecated: Use GetProfileReply.ProtoReflect.Descriptor instead.

func (*GetProfileReply) GetData added in v0.2.0 

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

func (*GetProfileReply) ProtoMessage added in v0.2.0 

func (*GetProfileReply) ProtoMessage()

func (*GetProfileReply) ProtoReflect added in v0.2.0 

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

func (*GetProfileReply) Reset added in v0.2.0 

func (x *GetProfileReply) Reset()

func (*GetProfileReply) String added in v0.2.0 

func (x *GetProfileReply) String() string

type GetProfileRequest added in v0.2.0 

type GetProfileRequest struct {

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

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

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

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

Deprecated: Use GetProfileRequest.ProtoReflect.Descriptor instead.

func (*GetProfileRequest) GetCpuDurationNs added in v0.2.0 

func (x *GetProfileRequest) GetCpuDurationNs() int64

func (*GetProfileRequest) GetProfileType added in v0.2.0 

func (x *GetProfileRequest) GetProfileType() ProfileType

func (*GetProfileRequest) ProtoMessage added in v0.2.0 

func (*GetProfileRequest) ProtoMessage()

func (*GetProfileRequest) ProtoReflect added in v0.2.0 

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

func (*GetProfileRequest) Reset added in v0.2.0 

func (x *GetProfileRequest) Reset()

func (*GetProfileRequest) String added in v0.2.0 

func (x *GetProfileRequest) String() string

type GetSelfCertificateReply added in v0.12.0 

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

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

Deprecated: Use GetSelfCertificateReply.ProtoReflect.Descriptor instead.

func (*GetSelfCertificateReply) GetCert added in v0.12.0 

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

func (*GetSelfCertificateReply) GetKey added in v0.12.0 

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

func (*GetSelfCertificateReply) ProtoMessage added in v0.12.0 

func (*GetSelfCertificateReply) ProtoMessage()

func (*GetSelfCertificateReply) ProtoReflect added in v0.12.0 

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

func (*GetSelfCertificateReply) Reset added in v0.12.0 

func (x *GetSelfCertificateReply) Reset()

func (*GetSelfCertificateReply) String added in v0.12.0 

func (x *GetSelfCertificateReply) String() string

type GetSelfCertificateRequest added in v0.12.0 

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

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

Deprecated: Use GetSelfCertificateRequest.ProtoReflect.Descriptor instead.

func (*GetSelfCertificateRequest) ProtoMessage added in v0.12.0 

func (*GetSelfCertificateRequest) ProtoMessage()

func (*GetSelfCertificateRequest) ProtoReflect added in v0.12.0 

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

func (*GetSelfCertificateRequest) Reset added in v0.12.0 

func (x *GetSelfCertificateRequest) Reset()

func (*GetSelfCertificateRequest) String added in v0.12.0 

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

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

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

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

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

Deprecated: Use LoadReport.ProtoReflect.Descriptor instead.

func (*LoadReport) GetLoads added in v0.2.0 

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

func (*LoadReport) ProtoMessage added in v0.2.0 

func (*LoadReport) ProtoMessage()

func (*LoadReport) ProtoReflect added in v0.2.0 

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

func (*LoadReport) Reset added in v0.2.0 

func (x *LoadReport) Reset()

func (*LoadReport) String added in v0.2.0 

func (x *LoadReport) String() string

type LoadReport_ComponentLoad added in v0.2.0 

type LoadReport_ComponentLoad struct {

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

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

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

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

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

Deprecated: Use LoadReport_ComponentLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_ComponentLoad) GetLoad added in v0.2.0 

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

func (*LoadReport_ComponentLoad) GetVersion added in v0.2.0 

func (x *LoadReport_ComponentLoad) GetVersion() uint64

func (*LoadReport_ComponentLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_ComponentLoad) ProtoMessage()

func (*LoadReport_ComponentLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_ComponentLoad) Reset added in v0.2.0 

func (x *LoadReport_ComponentLoad) Reset()

func (*LoadReport_ComponentLoad) String added in v0.2.0 

func (x *LoadReport_ComponentLoad) String() string

type LoadReport_SliceLoad added in v0.2.0 

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

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

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

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

Deprecated: Use LoadReport_SliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SliceLoad) GetEnd added in v0.2.0 

func (x *LoadReport_SliceLoad) GetEnd() uint64

func (*LoadReport_SliceLoad) GetLoad added in v0.2.0 

func (x *LoadReport_SliceLoad) GetLoad() float64

func (*LoadReport_SliceLoad) GetSize added in v0.2.0 

func (x *LoadReport_SliceLoad) GetSize() uint64

func (*LoadReport_SliceLoad) GetSplits added in v0.2.0 

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

func (*LoadReport_SliceLoad) GetStart added in v0.2.0 

func (x *LoadReport_SliceLoad) GetStart() uint64

func (*LoadReport_SliceLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_SliceLoad) ProtoMessage()

func (*LoadReport_SliceLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_SliceLoad) Reset added in v0.2.0 

func (x *LoadReport_SliceLoad) Reset()

func (*LoadReport_SliceLoad) String added in v0.2.0 

func (x *LoadReport_SliceLoad) String() string

type LoadReport_SubsliceLoad added in v0.2.0 

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

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

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

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

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

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

Deprecated: Use LoadReport_SubsliceLoad.ProtoReflect.Descriptor instead.

func (*LoadReport_SubsliceLoad) GetLoad added in v0.2.0 

func (x *LoadReport_SubsliceLoad) GetLoad() float64

func (*LoadReport_SubsliceLoad) GetStart added in v0.2.0 

func (x *LoadReport_SubsliceLoad) GetStart() uint64

func (*LoadReport_SubsliceLoad) ProtoMessage added in v0.2.0 

func (*LoadReport_SubsliceLoad) ProtoMessage()

func (*LoadReport_SubsliceLoad) ProtoReflect added in v0.2.0 

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

func (*LoadReport_SubsliceLoad) Reset added in v0.2.0 

func (x *LoadReport_SubsliceLoad) Reset()

func (*LoadReport_SubsliceLoad) String added in v0.2.0 

func (x *LoadReport_SubsliceLoad) String() string

type LogEntry 

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

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

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetApp 

func (x *LogEntry) GetApp() string

func (*LogEntry) GetAttrs 

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

func (*LogEntry) GetComponent 

func (x *LogEntry) GetComponent() string

func (*LogEntry) GetFile 

func (x *LogEntry) GetFile() string

func (*LogEntry) GetLevel 

func (x *LogEntry) GetLevel() string

func (*LogEntry) GetLine 

func (x *LogEntry) GetLine() int32

func (*LogEntry) GetMsg 

func (x *LogEntry) GetMsg() string

func (*LogEntry) GetNode 

func (x *LogEntry) GetNode() string

func (*LogEntry) GetTimeMicros 

func (x *LogEntry) GetTimeMicros() int64

func (*LogEntry) GetVersion 

func (x *LogEntry) GetVersion() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type MetricDef 

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

MetricDef is the definition of a new metric.

func (*MetricDef) Descriptor deprecated 

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

Deprecated: Use MetricDef.ProtoReflect.Descriptor instead.

func (*MetricDef) GetBounds 

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

func (*MetricDef) GetHelp 

func (x *MetricDef) GetHelp() string

func (*MetricDef) GetId 

func (x *MetricDef) GetId() uint64

func (*MetricDef) GetLabels 

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

func (*MetricDef) GetName 

func (x *MetricDef) GetName() string

func (*MetricDef) GetTyp 

func (x *MetricDef) GetTyp() MetricType

func (*MetricDef) ProtoMessage 

func (*MetricDef) ProtoMessage()

func (*MetricDef) ProtoReflect 

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

func (*MetricDef) Reset 

func (x *MetricDef) Reset()

func (*MetricDef) String 

func (x *MetricDef) String() string

type MetricSnapshot 

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

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

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

func (*MetricSnapshot) Descriptor deprecated 

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

Deprecated: Use MetricSnapshot.ProtoReflect.Descriptor instead.

func (*MetricSnapshot) GetBounds 

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

func (*MetricSnapshot) GetCounts 

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

func (*MetricSnapshot) GetHelp 

func (x *MetricSnapshot) GetHelp() string

func (*MetricSnapshot) GetId 

func (x *MetricSnapshot) GetId() uint64

func (*MetricSnapshot) GetLabels 

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

func (*MetricSnapshot) GetName 

func (x *MetricSnapshot) GetName() string

func (*MetricSnapshot) GetTyp 

func (x *MetricSnapshot) GetTyp() MetricType

func (*MetricSnapshot) GetValue 

func (x *MetricSnapshot) GetValue() float64

func (*MetricSnapshot) ProtoMessage 

func (*MetricSnapshot) ProtoMessage()

func (*MetricSnapshot) ProtoReflect 

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

func (*MetricSnapshot) Reset 

func (x *MetricSnapshot) Reset()

func (*MetricSnapshot) String 

func (x *MetricSnapshot) String() string

type MetricType 

type MetricType int32

MetricType specifies a particular kind of metric. 

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

func (MetricType) Descriptor 

func (MetricType) Descriptor() protoreflect.EnumDescriptor

func (MetricType) Enum 

func (x MetricType) Enum() *MetricType

func (MetricType) EnumDescriptor deprecated 

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

Deprecated: Use MetricType.Descriptor instead.

func (MetricType) Number 

func (x MetricType) Number() protoreflect.EnumNumber

func (MetricType) String 

func (x MetricType) String() string

func (MetricType) Type 

func (MetricType) Type() protoreflect.EnumType

type MetricUpdate 

type MetricUpdate struct {

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

MetricUpdate contains metric updates.

func (*MetricUpdate) Descriptor deprecated 

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

Deprecated: Use MetricUpdate.ProtoReflect.Descriptor instead.

func (*MetricUpdate) GetDefs 

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

func (*MetricUpdate) GetValues 

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

func (*MetricUpdate) ProtoMessage 

func (*MetricUpdate) ProtoMessage()

func (*MetricUpdate) ProtoReflect 

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

func (*MetricUpdate) Reset 

func (x *MetricUpdate) Reset()

func (*MetricUpdate) String 

func (x *MetricUpdate) String() string

type MetricValue 

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

MetricValue is the value associated with a metric.

func (*MetricValue) Descriptor deprecated 

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

Deprecated: Use MetricValue.ProtoReflect.Descriptor instead.

func (*MetricValue) GetCounts 

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

func (*MetricValue) GetId 

func (x *MetricValue) GetId() uint64

func (*MetricValue) GetValue 

func (x *MetricValue) GetValue() float64

func (*MetricValue) ProtoMessage 

func (*MetricValue) ProtoMessage()

func (*MetricValue) ProtoReflect 

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

func (*MetricValue) Reset 

func (x *MetricValue) Reset()

func (*MetricValue) String 

func (x *MetricValue) String() string

type ProfileType 

type ProfileType int32

ProfileType specifies a type of profile. 

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

func (ProfileType) Descriptor 

func (ProfileType) Descriptor() protoreflect.EnumDescriptor

func (ProfileType) Enum 

func (x ProfileType) Enum() *ProfileType

func (ProfileType) EnumDescriptor deprecated 

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

Deprecated: Use ProfileType.Descriptor instead.

func (ProfileType) Number 

func (x ProfileType) Number() protoreflect.EnumNumber

func (ProfileType) String 

func (x ProfileType) String() string

func (ProfileType) Type 

func (ProfileType) Type() protoreflect.EnumType

type RoutingInfo 

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

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

func (*RoutingInfo) Descriptor deprecated 

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

Deprecated: Use RoutingInfo.ProtoReflect.Descriptor instead.

func (*RoutingInfo) GetAssignment added in v0.2.0 

func (x *RoutingInfo) GetAssignment() *Assignment

func (*RoutingInfo) GetComponent added in v0.2.0 

func (x *RoutingInfo) GetComponent() string

func (*RoutingInfo) GetLocal added in v0.2.0 

func (x *RoutingInfo) GetLocal() bool

func (*RoutingInfo) GetReplicas 

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

func (*RoutingInfo) ProtoMessage 

func (*RoutingInfo) ProtoMessage()

func (*RoutingInfo) ProtoReflect 

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

func (*RoutingInfo) Reset 

func (x *RoutingInfo) Reset()

func (*RoutingInfo) String 

func (x *RoutingInfo) String() string

type SemVer added in v0.2.0 

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

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

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

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

Deprecated: Use SemVer.ProtoReflect.Descriptor instead.

func (*SemVer) GetMajor added in v0.2.0 

func (x *SemVer) GetMajor() int64

func (*SemVer) GetMinor added in v0.2.0 

func (x *SemVer) GetMinor() int64

func (*SemVer) GetPatch added in v0.2.0 

func (x *SemVer) GetPatch() int64

func (*SemVer) ProtoMessage added in v0.2.0 

func (*SemVer) ProtoMessage()

func (*SemVer) ProtoReflect added in v0.2.0 

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

func (*SemVer) Reset added in v0.2.0 

func (x *SemVer) Reset()

func (*SemVer) String added in v0.2.0 

func (x *SemVer) String() string

type Span 

type Span struct {
	Name         string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                       // Span name
	TraceId      []byte            `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`                  // Span trace id, 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 added in v0.14.0 

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

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

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

Deprecated: Use Span_Attribute.ProtoReflect.Descriptor instead.

func (*Span_Attribute) GetKey added in v0.18.0 

func (x *Span_Attribute) GetKey() string

func (*Span_Attribute) GetValue added in v0.18.0 

func (x *Span_Attribute) GetValue() *Span_Attribute_Value

func (*Span_Attribute) ProtoMessage added in v0.18.0 

func (*Span_Attribute) ProtoMessage()

func (*Span_Attribute) ProtoReflect added in v0.18.0 

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

func (*Span_Attribute) Reset added in v0.18.0 

func (x *Span_Attribute) Reset()

func (*Span_Attribute) String added in v0.18.0 

func (x *Span_Attribute) String() string

type Span_Attribute_Value added in v0.18.0 

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

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

Deprecated: Use Span_Attribute_Value.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value) GetNum added in v0.18.0 

func (x *Span_Attribute_Value) GetNum() uint64

func (*Span_Attribute_Value) GetNums added in v0.18.0 

func (x *Span_Attribute_Value) GetNums() *Span_Attribute_Value_NumberList

func (*Span_Attribute_Value) GetStr added in v0.18.0 

func (x *Span_Attribute_Value) GetStr() string

func (*Span_Attribute_Value) GetStrs added in v0.18.0 

func (x *Span_Attribute_Value) GetStrs() *Span_Attribute_Value_StringList

func (*Span_Attribute_Value) GetType added in v0.18.0 

func (x *Span_Attribute_Value) GetType() Span_Attribute_Value_Type

func (*Span_Attribute_Value) GetValue added in v0.18.0 

func (m *Span_Attribute_Value) GetValue() isSpan_Attribute_Value_Value

func (*Span_Attribute_Value) ProtoMessage added in v0.18.0 

func (*Span_Attribute_Value) ProtoMessage()

func (*Span_Attribute_Value) ProtoReflect added in v0.18.0 

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

func (*Span_Attribute_Value) Reset added in v0.18.0 

func (x *Span_Attribute_Value) Reset()

func (*Span_Attribute_Value) String added in v0.18.0 

func (x *Span_Attribute_Value) String() string

type Span_Attribute_Value_Num added in v0.18.0 

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

type Span_Attribute_Value_NumberList added in v0.18.0 

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

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

Deprecated: Use Span_Attribute_Value_NumberList.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value_NumberList) GetNums added in v0.18.0 

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

func (*Span_Attribute_Value_NumberList) ProtoMessage added in v0.18.0 

func (*Span_Attribute_Value_NumberList) ProtoMessage()

func (*Span_Attribute_Value_NumberList) ProtoReflect added in v0.18.0 

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

func (*Span_Attribute_Value_NumberList) Reset added in v0.18.0 

func (x *Span_Attribute_Value_NumberList) Reset()

func (*Span_Attribute_Value_NumberList) String added in v0.18.0 

func (x *Span_Attribute_Value_NumberList) String() string

type Span_Attribute_Value_Nums added in v0.18.0 

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

type Span_Attribute_Value_Str added in v0.18.0 

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

type Span_Attribute_Value_StringList added in v0.18.0 

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

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

Deprecated: Use Span_Attribute_Value_StringList.ProtoReflect.Descriptor instead.

func (*Span_Attribute_Value_StringList) GetStrs added in v0.18.0 

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

func (*Span_Attribute_Value_StringList) ProtoMessage added in v0.18.0 

func (*Span_Attribute_Value_StringList) ProtoMessage()

func (*Span_Attribute_Value_StringList) ProtoReflect added in v0.18.0 

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

func (*Span_Attribute_Value_StringList) Reset added in v0.18.0 

func (x *Span_Attribute_Value_StringList) Reset()

func (*Span_Attribute_Value_StringList) String added in v0.18.0 

func (x *Span_Attribute_Value_StringList) String() string

type Span_Attribute_Value_Strs added in v0.18.0 

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

type Span_Attribute_Value_Type added in v0.18.0 

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

func (Span_Attribute_Value_Type) Descriptor() protoreflect.EnumDescriptor

func (Span_Attribute_Value_Type) Enum added in v0.18.0 

func (x Span_Attribute_Value_Type) Enum() *Span_Attribute_Value_Type

func (Span_Attribute_Value_Type) EnumDescriptor deprecated added in v0.18.0 

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

Deprecated: Use Span_Attribute_Value_Type.Descriptor instead.

func (Span_Attribute_Value_Type) Number added in v0.18.0 

func (x Span_Attribute_Value_Type) Number() protoreflect.EnumNumber

func (Span_Attribute_Value_Type) String added in v0.18.0 

func (x Span_Attribute_Value_Type) String() string

func (Span_Attribute_Value_Type) Type added in v0.18.0 

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

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

func (Span_Kind) Descriptor() protoreflect.EnumDescriptor

func (Span_Kind) Enum added in v0.18.0 

func (x Span_Kind) Enum() *Span_Kind

func (Span_Kind) EnumDescriptor deprecated added in v0.18.0 

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

Deprecated: Use Span_Kind.Descriptor instead.

func (Span_Kind) Number added in v0.18.0 

func (x Span_Kind) Number() protoreflect.EnumNumber

func (Span_Kind) String added in v0.18.0 

func (x Span_Kind) String() string

func (Span_Kind) Type added in v0.18.0 

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

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

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

Deprecated: Use Span_Scope.ProtoReflect.Descriptor instead.

func (*Span_Scope) GetName added in v0.14.0 

func (x *Span_Scope) GetName() string

func (*Span_Scope) GetSchemaUrl added in v0.14.0 

func (x *Span_Scope) GetSchemaUrl() string

func (*Span_Scope) GetVersion added in v0.14.0 

func (x *Span_Scope) GetVersion() string

func (*Span_Scope) ProtoMessage added in v0.14.0 

func (*Span_Scope) ProtoMessage()

func (*Span_Scope) ProtoReflect added in v0.14.0 

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

func (*Span_Scope) Reset added in v0.14.0 

func (x *Span_Scope) Reset()

func (*Span_Scope) String added in v0.14.0 

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

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

TraceSpans is a list of Span messages.

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

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

Deprecated: Use TraceSpans.ProtoReflect.Descriptor instead.

func (*TraceSpans) GetSpan added in v0.2.0 

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

func (*TraceSpans) ProtoMessage added in v0.2.0 

func (*TraceSpans) ProtoMessage()

func (*TraceSpans) ProtoReflect added in v0.2.0 

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

func (*TraceSpans) Reset added in v0.2.0 

func (x *TraceSpans) Reset()

func (*TraceSpans) String added in v0.2.0 

func (x *TraceSpans) String() string

type UpdateComponentsReply added in v0.2.0 

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

UpdateComponentsReply is a reply to an UpdateComponentsRequest.

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

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

Deprecated: Use UpdateComponentsReply.ProtoReflect.Descriptor instead.

func (*UpdateComponentsReply) ProtoMessage added in v0.2.0 

func (*UpdateComponentsReply) ProtoMessage()

func (*UpdateComponentsReply) ProtoReflect added in v0.2.0 

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

func (*UpdateComponentsReply) Reset added in v0.2.0 

func (x *UpdateComponentsReply) Reset()

func (*UpdateComponentsReply) String added in v0.2.0 

func (x *UpdateComponentsReply) String() string

type UpdateComponentsRequest added in v0.2.0 

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

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

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

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

Deprecated: Use UpdateComponentsRequest.ProtoReflect.Descriptor instead.

func (*UpdateComponentsRequest) GetComponents added in v0.2.0 

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

func (*UpdateComponentsRequest) ProtoMessage added in v0.2.0 

func (*UpdateComponentsRequest) ProtoMessage()

func (*UpdateComponentsRequest) ProtoReflect added in v0.2.0 

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

func (*UpdateComponentsRequest) Reset added in v0.2.0 

func (x *UpdateComponentsRequest) Reset()

func (*UpdateComponentsRequest) String added in v0.2.0 

func (x *UpdateComponentsRequest) String() string

type UpdateRoutingInfoReply added in v0.2.0 

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

UpdateRoutingInfoReply is a reply to an UpdateRoutingInfoRequest.

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

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

Deprecated: Use UpdateRoutingInfoReply.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoReply) ProtoMessage added in v0.2.0 

func (*UpdateRoutingInfoReply) ProtoMessage()

func (*UpdateRoutingInfoReply) ProtoReflect added in v0.2.0 

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

func (*UpdateRoutingInfoReply) Reset added in v0.2.0 

func (x *UpdateRoutingInfoReply) Reset()

func (*UpdateRoutingInfoReply) String added in v0.2.0 

func (x *UpdateRoutingInfoReply) String() string

type UpdateRoutingInfoRequest added in v0.2.0 

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

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

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

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

Deprecated: Use UpdateRoutingInfoRequest.ProtoReflect.Descriptor instead.

func (*UpdateRoutingInfoRequest) GetRoutingInfo added in v0.2.0 

func (x *UpdateRoutingInfoRequest) GetRoutingInfo() *RoutingInfo

func (*UpdateRoutingInfoRequest) ProtoMessage added in v0.2.0 

func (*UpdateRoutingInfoRequest) ProtoMessage()

func (*UpdateRoutingInfoRequest) ProtoReflect added in v0.2.0 

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

func (*UpdateRoutingInfoRequest) Reset added in v0.2.0 

func (x *UpdateRoutingInfoRequest) Reset()

func (*UpdateRoutingInfoRequest) String added in v0.2.0 

func (x *UpdateRoutingInfoRequest) String() string

type VerifyClientCertificateReply added in v0.6.0 

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

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

Deprecated: Use VerifyClientCertificateReply.ProtoReflect.Descriptor instead.

func (*VerifyClientCertificateReply) GetComponents added in v0.6.0 

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

func (*VerifyClientCertificateReply) ProtoMessage added in v0.6.0 

func (*VerifyClientCertificateReply) ProtoMessage()

func (*VerifyClientCertificateReply) ProtoReflect added in v0.6.0 

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

func (*VerifyClientCertificateReply) Reset added in v0.6.0 

func (x *VerifyClientCertificateReply) Reset()

func (*VerifyClientCertificateReply) String added in v0.6.0 

func (x *VerifyClientCertificateReply) String() string

type VerifyClientCertificateRequest added in v0.6.0 

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

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

Deprecated: Use VerifyClientCertificateRequest.ProtoReflect.Descriptor instead.

func (*VerifyClientCertificateRequest) GetCertChain added in v0.6.0 

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

func (*VerifyClientCertificateRequest) ProtoMessage added in v0.6.0 

func (*VerifyClientCertificateRequest) ProtoMessage()

func (*VerifyClientCertificateRequest) ProtoReflect added in v0.6.0 

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

func (*VerifyClientCertificateRequest) Reset added in v0.6.0 

func (x *VerifyClientCertificateRequest) Reset()

func (*VerifyClientCertificateRequest) String added in v0.6.0 

func (x *VerifyClientCertificateRequest) String() string

type VerifyServerCertificateReply added in v0.6.0 

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

VerifyServerCertificateReply is a reply to a VerifyServerCertificateRequest.

func (*VerifyServerCertificateReply) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use VerifyServerCertificateReply.ProtoReflect.Descriptor instead.

func (*VerifyServerCertificateReply) ProtoMessage added in v0.6.0 

func (*VerifyServerCertificateReply) ProtoMessage()

func (*VerifyServerCertificateReply) ProtoReflect added in v0.6.0 

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

func (*VerifyServerCertificateReply) Reset added in v0.6.0 

func (x *VerifyServerCertificateReply) Reset()

func (*VerifyServerCertificateReply) String added in v0.6.0 

func (x *VerifyServerCertificateReply) String() string

type VerifyServerCertificateRequest added in v0.6.0 

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

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

Deprecated: Use VerifyServerCertificateRequest.ProtoReflect.Descriptor instead.

func (*VerifyServerCertificateRequest) GetCertChain added in v0.6.0 

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

func (*VerifyServerCertificateRequest) GetTargetComponent added in v0.6.0 

func (x *VerifyServerCertificateRequest) GetTargetComponent() string

func (*VerifyServerCertificateRequest) ProtoMessage added in v0.6.0 

func (*VerifyServerCertificateRequest) ProtoMessage()

func (*VerifyServerCertificateRequest) ProtoReflect added in v0.6.0 

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

func (*VerifyServerCertificateRequest) Reset added in v0.6.0 

func (x *VerifyServerCertificateRequest) Reset()

func (*VerifyServerCertificateRequest) String added in v0.6.0 

func (x *VerifyServerCertificateRequest) String() string

type WeaveletInfo added in v0.1.2 

type WeaveletInfo struct {

	// Internal TCP address of the weavelet. This address will be passed to other
	// weavelets as part of their RoutingInfo.
	DialAddr string `protobuf:"bytes,1,opt,name=dial_addr,json=dialAddr,proto3" json:"dial_addr,omitempty"`
	// The deployer API version of the weavelet.
	Version *SemVer `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

Deprecated: Use WeaveletInfo.ProtoReflect.Descriptor instead.

func (*WeaveletInfo) GetDialAddr added in v0.2.0 

func (x *WeaveletInfo) GetDialAddr() string

func (*WeaveletInfo) GetVersion added in v0.2.0 

func (x *WeaveletInfo) GetVersion() *SemVer

func (*WeaveletInfo) ProtoMessage added in v0.1.2 

func (*WeaveletInfo) ProtoMessage()

func (*WeaveletInfo) ProtoReflect added in v0.1.2 

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

func (*WeaveletInfo) Reset added in v0.1.2 

func (x *WeaveletInfo) Reset()

func (*WeaveletInfo) String added in v0.1.2 

func (x *WeaveletInfo) String() string

type WeaveletMsg 

type WeaveletMsg struct {

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

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

func (*WeaveletMsg) Descriptor deprecated 

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

Deprecated: Use WeaveletMsg.ProtoReflect.Descriptor instead.

func (*WeaveletMsg) GetActivateComponentRequest added in v0.2.0 

func (x *WeaveletMsg) GetActivateComponentRequest() *ActivateComponentRequest

func (*WeaveletMsg) GetError 

func (x *WeaveletMsg) GetError() string

func (*WeaveletMsg) GetExportListenerRequest added in v0.1.2 

func (x *WeaveletMsg) GetExportListenerRequest() *ExportListenerRequest

func (*WeaveletMsg) GetGetHealthReply added in v0.2.0 

func (x *WeaveletMsg) GetGetHealthReply() *GetHealthReply

func (*WeaveletMsg) GetGetListenerAddressRequest added in v0.2.0 

func (x *WeaveletMsg) GetGetListenerAddressRequest() *GetListenerAddressRequest

func (*WeaveletMsg) GetGetLoadReply added in v0.2.0 

func (x *WeaveletMsg) GetGetLoadReply() *GetLoadReply

func (*WeaveletMsg) GetGetMetricsReply added in v0.2.0 

func (x *WeaveletMsg) GetGetMetricsReply() *GetMetricsReply

func (*WeaveletMsg) GetGetProfileReply added in v0.2.0 

func (x *WeaveletMsg) GetGetProfileReply() *GetProfileReply

func (*WeaveletMsg) GetGetSelfCertificateRequest added in v0.12.0 

func (x *WeaveletMsg) GetGetSelfCertificateRequest() *GetSelfCertificateRequest

func (*WeaveletMsg) GetId 

func (x *WeaveletMsg) GetId() int64

func (*WeaveletMsg) GetLogEntry 

func (x *WeaveletMsg) GetLogEntry() *LogEntry

func (*WeaveletMsg) GetTraceSpans 

func (x *WeaveletMsg) GetTraceSpans() *TraceSpans

func (*WeaveletMsg) GetUpdateComponentsReply added in v0.2.0 

func (x *WeaveletMsg) GetUpdateComponentsReply() *UpdateComponentsReply

func (*WeaveletMsg) GetUpdateRoutingInfoReply added in v0.2.0 

func (x *WeaveletMsg) GetUpdateRoutingInfoReply() *UpdateRoutingInfoReply

func (*WeaveletMsg) GetVerifyClientCertificateRequest added in v0.6.0 

func (x *WeaveletMsg) GetVerifyClientCertificateRequest() *VerifyClientCertificateRequest

func (*WeaveletMsg) GetVerifyServerCertificateRequest added in v0.6.0 

func (x *WeaveletMsg) GetVerifyServerCertificateRequest() *VerifyServerCertificateRequest

func (*WeaveletMsg) GetWeaveletInfo added in v0.2.0 

func (x *WeaveletMsg) GetWeaveletInfo() *WeaveletInfo

func (*WeaveletMsg) ProtoMessage 

func (*WeaveletMsg) ProtoMessage()

func (*WeaveletMsg) ProtoReflect 

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

func (*WeaveletMsg) Reset 

func (x *WeaveletMsg) Reset()

func (*WeaveletMsg) String 

func (x *WeaveletMsg) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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