protos

type AppConfig struct {

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

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

type Assignment_Slice struct {

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

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

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

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

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

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

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

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

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

type Attribute_Value_Type int32

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

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

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

type ComponentsToStart struct {

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

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
}

type EnvelopeMsg struct {

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

type ExportListenerReply struct {

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

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

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

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

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

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

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

type HealthStatus int32

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

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

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

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

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

type MetricType int32

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
}

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
}

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

type ProfileType int32

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

type RoutingInfo struct {

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

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

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

type SpanKind int32

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

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
}

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

type Span_Resource struct {

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

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
}

type Span_Status_Code int32

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

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

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

type WeaveletLoadReport_ComponentLoad struct {

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

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

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

type WeaveletMsg struct {

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