syscall

package
v0.0.0-...-71fdcac Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2023 License: BSD-3-Clause Imports: 6 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	KernelErr_name = map[int32]string{
		0:  "NoError",
		1:  "LocateError",
		2:  "UnmarshalFailed",
		3:  "IdDispatch",
		4:  "NamespaceExhausted",
		5:  "NotFound",
		6:  "DataTooLarge",
		7:  "MarshalFailed",
		8:  "CallerUnavailable",
		9:  "ServiceAlreadyClosedOrExported",
		10: "ServiceAlreadyRequired",
		11: "DependencyCycle",
		12: "NetworkFailed",
		13: "NetworkConnectionLost",
		14: "DataTooSmall",
		15: "KernelConnectionFailed",
		16: "NSRetryFailed",
		17: "DecodeError",
		18: "ExecError",
		19: "KernelDependencyFailure",
		20: "AbortRequest",
		22: "EncodeError",
		23: "ClosedErr",
		24: "GuestReadFailed",
		25: "GuestWriteFailed",
		26: "BadId",
		27: "NotReady",
		28: "NotRequired",
		29: "RunTimeout",
		30: "ReadOneTimeout",
		31: "WriteTimeout",
		32: "BadCallId",
		33: "ChannelClosed",
		34: "ExitFailed",
	}
	KernelErr_value = map[string]int32{
		"NoError":                        0,
		"LocateError":                    1,
		"UnmarshalFailed":                2,
		"IdDispatch":                     3,
		"NamespaceExhausted":             4,
		"NotFound":                       5,
		"DataTooLarge":                   6,
		"MarshalFailed":                  7,
		"CallerUnavailable":              8,
		"ServiceAlreadyClosedOrExported": 9,
		"ServiceAlreadyRequired":         10,
		"DependencyCycle":                11,
		"NetworkFailed":                  12,
		"NetworkConnectionLost":          13,
		"DataTooSmall":                   14,
		"KernelConnectionFailed":         15,
		"NSRetryFailed":                  16,
		"DecodeError":                    17,
		"ExecError":                      18,
		"KernelDependencyFailure":        19,
		"AbortRequest":                   20,
		"EncodeError":                    22,
		"ClosedErr":                      23,
		"GuestReadFailed":                24,
		"GuestWriteFailed":               25,
		"BadId":                          26,
		"NotReady":                       27,
		"NotRequired":                    28,
		"RunTimeout":                     29,
		"ReadOneTimeout":                 30,
		"WriteTimeout":                   31,
		"BadCallId":                      32,
		"ChannelClosed":                  33,
		"ExitFailed":                     34,
	}
)

Enum value maps for KernelErr.

View Source 
var (
	MethodDirection_name = map[int32]string{
		0: "METHOD_DIRECTION_UNSPECIFIED",
		1: "METHOD_DIRECTION_IN",
		2: "METHOD_DIRECTION_OUT",
		3: "METHOD_DIRECTION_BOTH",
	}
	MethodDirection_value = map[string]int32{
		"METHOD_DIRECTION_UNSPECIFIED": 0,
		"METHOD_DIRECTION_IN":          1,
		"METHOD_DIRECTION_OUT":         2,
		"METHOD_DIRECTION_BOTH":        3,
	}
)

Enum value maps for MethodDirection.

View Source 
var File_syscall_v1_syscall_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BindMethodRequest 

type BindMethodRequest struct {
	HostId     *v1.IdRaw       `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	ServiceId  *v1.IdRaw       `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	MethodName string          `protobuf:"bytes,3,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	Direction  MethodDirection `protobuf:"varint,4,opt,name=direction,proto3,enum=syscall.v1.MethodDirection" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

BindMethodRequest is used to tell parigot that the given service_id (located at host_id) has an implementation for the given method name. This will create the mapping to a method_id, which is in the response. The direction parameter is either METHOD_DIRECTION_IN, OUT, or BOTH. IN means thath the method has no output parameter (the result is ignored), OUT means the method has no input parameters, and BOTH means that both input and output parameters are used.

func (*BindMethodRequest) Descriptor deprecated 

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

Deprecated: Use BindMethodRequest.ProtoReflect.Descriptor instead.

func (*BindMethodRequest) GetDirection 

func (x *BindMethodRequest) GetDirection() MethodDirection

func (*BindMethodRequest) GetHostId 

func (x *BindMethodRequest) GetHostId() *v1.IdRaw

func (*BindMethodRequest) GetMethodName 

func (x *BindMethodRequest) GetMethodName() string

func (*BindMethodRequest) GetServiceId 

func (x *BindMethodRequest) GetServiceId() *v1.IdRaw

func (*BindMethodRequest) ProtoMessage 

func (*BindMethodRequest) ProtoMessage()

func (*BindMethodRequest) ProtoReflect 

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

func (*BindMethodRequest) Reset 

func (x *BindMethodRequest) Reset()

func (*BindMethodRequest) String 

func (x *BindMethodRequest) String() string

type BindMethodResponse 

type BindMethodResponse struct {
	MethodId *v1.IdRaw `protobuf:"bytes,1,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"`
	// contains filtered or unexported fields
}

BindMethodResponse is the method_id of the service and method name provided in the request.

func (*BindMethodResponse) Descriptor deprecated 

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

Deprecated: Use BindMethodResponse.ProtoReflect.Descriptor instead.

func (*BindMethodResponse) GetMethodId 

func (x *BindMethodResponse) GetMethodId() *v1.IdRaw

func (*BindMethodResponse) ProtoMessage 

func (*BindMethodResponse) ProtoMessage()

func (*BindMethodResponse) ProtoReflect 

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

func (*BindMethodResponse) Reset 

func (x *BindMethodResponse) Reset()

func (*BindMethodResponse) String 

func (x *BindMethodResponse) String() string

type BlockUntilCallRequest 

type BlockUntilCallRequest struct {
	CanTimeout bool `protobuf:"varint,1,opt,name=can_timeout,json=canTimeout,proto3" json:"can_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUntilCallRequest) Descriptor deprecated 

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

Deprecated: Use BlockUntilCallRequest.ProtoReflect.Descriptor instead.

func (*BlockUntilCallRequest) GetCanTimeout 

func (x *BlockUntilCallRequest) GetCanTimeout() bool

func (*BlockUntilCallRequest) ProtoMessage 

func (*BlockUntilCallRequest) ProtoMessage()

func (*BlockUntilCallRequest) ProtoReflect 

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

func (*BlockUntilCallRequest) Reset 

func (x *BlockUntilCallRequest) Reset()

func (*BlockUntilCallRequest) String 

func (x *BlockUntilCallRequest) String() string

type BlockUntilCallResponse 

type BlockUntilCallResponse struct {
	Param    *anypb.Any `protobuf:"bytes,1,opt,name=param,proto3" json:"param,omitempty"`
	Method   *v1.IdRaw  `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Call     *v1.IdRaw  `protobuf:"bytes,3,opt,name=call,proto3" json:"call,omitempty"`
	TimedOut bool       `protobuf:"varint,4,opt,name=timed_out,json=timedOut,proto3" json:"timed_out,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUntilCallResponse) Descriptor deprecated 

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

Deprecated: Use BlockUntilCallResponse.ProtoReflect.Descriptor instead.

func (*BlockUntilCallResponse) GetCall 

func (x *BlockUntilCallResponse) GetCall() *v1.IdRaw

func (*BlockUntilCallResponse) GetMethod 

func (x *BlockUntilCallResponse) GetMethod() *v1.IdRaw

func (*BlockUntilCallResponse) GetParam 

func (x *BlockUntilCallResponse) GetParam() *anypb.Any

func (*BlockUntilCallResponse) GetTimedOut 

func (x *BlockUntilCallResponse) GetTimedOut() bool

func (*BlockUntilCallResponse) ProtoMessage 

func (*BlockUntilCallResponse) ProtoMessage()

func (*BlockUntilCallResponse) ProtoReflect 

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

func (*BlockUntilCallResponse) Reset 

func (x *BlockUntilCallResponse) Reset()

func (*BlockUntilCallResponse) String 

func (x *BlockUntilCallResponse) String() string

type DependencyExistsRequest 

type DependencyExistsRequest struct {
	SourceServiceId *v1.IdRaw              `protobuf:"bytes,1,opt,name=source_service_id,json=sourceServiceId,proto3" json:"source_service_id,omitempty"`
	DestServiceId   *v1.IdRaw              `protobuf:"bytes,2,opt,name=dest_service_id,json=destServiceId,proto3" json:"dest_service_id,omitempty"`
	ServiceName     *FullyQualifiedService `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// contains filtered or unexported fields
}

DependencyExistsRequest is used to check if there a dependency path from source to destination. Callers should use either a target service or a target service name, not both. The semantics are slightly different. When you ask about the name of a service, it is a question about what the service has declared with require calls. When you ask about a specific service you are asking if a dependency path between the two services exists and thus the dest service must be started before the source.

func (*DependencyExistsRequest) Descriptor deprecated 

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

Deprecated: Use DependencyExistsRequest.ProtoReflect.Descriptor instead.

func (*DependencyExistsRequest) GetDestServiceId 

func (x *DependencyExistsRequest) GetDestServiceId() *v1.IdRaw

func (*DependencyExistsRequest) GetServiceName 

func (x *DependencyExistsRequest) GetServiceName() *FullyQualifiedService

func (*DependencyExistsRequest) GetSourceServiceId 

func (x *DependencyExistsRequest) GetSourceServiceId() *v1.IdRaw

func (*DependencyExistsRequest) ProtoMessage 

func (*DependencyExistsRequest) ProtoMessage()

func (*DependencyExistsRequest) ProtoReflect 

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

func (*DependencyExistsRequest) Reset 

func (x *DependencyExistsRequest) Reset()

func (*DependencyExistsRequest) String 

func (x *DependencyExistsRequest) String() string

type DependencyExistsResponse 

type DependencyExistsResponse struct {
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

DependencyExistsResponse has the exists field set to true if there exists a sequence of dependencies that join source and dest (from the request).

func (*DependencyExistsResponse) Descriptor deprecated 

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

Deprecated: Use DependencyExistsResponse.ProtoReflect.Descriptor instead.

func (*DependencyExistsResponse) GetExists 

func (x *DependencyExistsResponse) GetExists() bool

func (*DependencyExistsResponse) ProtoMessage 

func (*DependencyExistsResponse) ProtoMessage()

func (*DependencyExistsResponse) ProtoReflect 

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

func (*DependencyExistsResponse) Reset 

func (x *DependencyExistsResponse) Reset()

func (*DependencyExistsResponse) String 

func (x *DependencyExistsResponse) String() string

type DispatchRequest 

type DispatchRequest struct {
	Bundle *MethodBundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Param  *anypb.Any    `protobuf:"bytes,3,opt,name=param,proto3" json:"param,omitempty"` // inside is another Request object, but we don't know its type
	// contains filtered or unexported fields
}

DispatchRequest is a request by a client to invoke a particular method with the parameters provided.

func (*DispatchRequest) Descriptor deprecated 

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

Deprecated: Use DispatchRequest.ProtoReflect.Descriptor instead.

func (*DispatchRequest) GetBundle 

func (x *DispatchRequest) GetBundle() *MethodBundle

func (*DispatchRequest) GetParam 

func (x *DispatchRequest) GetParam() *anypb.Any

func (*DispatchRequest) ProtoMessage 

func (*DispatchRequest) ProtoMessage()

func (*DispatchRequest) ProtoReflect 

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

func (*DispatchRequest) Reset 

func (x *DispatchRequest) Reset()

func (*DispatchRequest) String 

func (x *DispatchRequest) String() string

type DispatchResponse 

type DispatchResponse struct {
	CallId       *v1.IdRaw `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`                     // reserved for internal use
	TargetHostId *v1.IdRaw `protobuf:"bytes,2,opt,name=target_host_id,json=targetHostId,proto3" json:"target_host_id,omitempty"` // reserved for internal use
	// contains filtered or unexported fields
}

DispatchResponse sent by the server back to a client. This what is returned as the intermediate value to the caller, because the caller cannot block. This call_id value can be used on the client side to map to additional info about the call.

func (*DispatchResponse) Descriptor deprecated 

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

Deprecated: Use DispatchResponse.ProtoReflect.Descriptor instead.

func (*DispatchResponse) GetCallId 

func (x *DispatchResponse) GetCallId() *v1.IdRaw

func (*DispatchResponse) GetTargetHostId 

func (x *DispatchResponse) GetTargetHostId() *v1.IdRaw

func (*DispatchResponse) ProtoMessage 

func (*DispatchResponse) ProtoMessage()

func (*DispatchResponse) ProtoReflect 

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

func (*DispatchResponse) Reset 

func (x *DispatchResponse) Reset()

func (*DispatchResponse) String 

func (x *DispatchResponse) String() string

type ExitPair 

type ExitPair struct {
	ServiceId *v1.IdRaw `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Code      int32     `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

ExitPair is a structure that is a service that is requesting an exit and the exit code desired. The service can be empty if the caller wants the entire suite of services to be exited. Code will be in the "allowed" range of 0 to 192.

func (*ExitPair) Descriptor deprecated 

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

Deprecated: Use ExitPair.ProtoReflect.Descriptor instead.

func (*ExitPair) GetCode 

func (x *ExitPair) GetCode() int32

func (*ExitPair) GetServiceId 

func (x *ExitPair) GetServiceId() *v1.IdRaw

func (*ExitPair) ProtoMessage 

func (*ExitPair) ProtoMessage()

func (*ExitPair) ProtoReflect 

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

func (*ExitPair) Reset 

func (x *ExitPair) Reset()

func (*ExitPair) String 

func (x *ExitPair) String() string

type ExitRequest 

type ExitRequest struct {

	// For the code in the ExitPair, the valid values here are 0...192 and values>192
	// or <0 will be set to 192. The valid values for the service are a service id
	// (typically the service making this request) or an zero valued service, indicating
	// that the entire system should be brought down.
	Pair        *ExitPair `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair,omitempty"`
	CallId      *v1.IdRaw `protobuf:"bytes,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`       // reserved for internal use
	HostId      *v1.IdRaw `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`       // reserved for internal use
	MethodId    *v1.IdRaw `protobuf:"bytes,4,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"` // reserved for internal use
	ShutdownAll bool      `protobuf:"varint,5,opt,name=shutdown_all,json=shutdownAll,proto3" json:"shutdown_all,omitempty"`
	// contains filtered or unexported fields
}

ExitRequest is how you can request for your wasm program, or the whole system to exit. This will not terminate the process immediately as there may be other services running that need to be notified.

func (*ExitRequest) Descriptor deprecated 

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

Deprecated: Use ExitRequest.ProtoReflect.Descriptor instead.

func (*ExitRequest) GetCallId 

func (x *ExitRequest) GetCallId() *v1.IdRaw

func (*ExitRequest) GetHostId 

func (x *ExitRequest) GetHostId() *v1.IdRaw

func (*ExitRequest) GetMethodId 

func (x *ExitRequest) GetMethodId() *v1.IdRaw

func (*ExitRequest) GetPair 

func (x *ExitRequest) GetPair() *ExitPair

func (*ExitRequest) GetShutdownAll 

func (x *ExitRequest) GetShutdownAll() bool

func (*ExitRequest) ProtoMessage 

func (*ExitRequest) ProtoMessage()

func (*ExitRequest) ProtoReflect 

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

func (*ExitRequest) Reset 

func (x *ExitRequest) Reset()

func (*ExitRequest) String 

func (x *ExitRequest) String() string

type ExitResponse 

type ExitResponse struct {
	Pair *ExitPair `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair,omitempty"`
	// contains filtered or unexported fields
}

ExitResponse will not happen. The stack will unwind before this message could be received.

func (*ExitResponse) Descriptor deprecated 

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

Deprecated: Use ExitResponse.ProtoReflect.Descriptor instead.

func (*ExitResponse) GetPair 

func (x *ExitResponse) GetPair() *ExitPair

func (*ExitResponse) ProtoMessage 

func (*ExitResponse) ProtoMessage()

func (*ExitResponse) ProtoReflect 

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

func (*ExitResponse) Reset 

func (x *ExitResponse) Reset()

func (*ExitResponse) String 

func (x *ExitResponse) String() string

type ExportRequest 

type ExportRequest struct {
	ServiceId *v1.IdRaw                `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Service   []*FullyQualifiedService `protobuf:"bytes,2,rep,name=service,proto3" json:"service,omitempty"`
	HostId    *v1.IdRaw                `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

ExportRequest informs the kernel that the given service id implements the named services on the host given. Note that the services provided must be distinct.

func (*ExportRequest) Descriptor deprecated 

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

Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.

func (*ExportRequest) GetHostId 

func (x *ExportRequest) GetHostId() *v1.IdRaw

func (*ExportRequest) GetService 

func (x *ExportRequest) GetService() []*FullyQualifiedService

func (*ExportRequest) GetServiceId 

func (x *ExportRequest) GetServiceId() *v1.IdRaw

func (*ExportRequest) ProtoMessage 

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) ProtoReflect 

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

func (*ExportRequest) Reset 

func (x *ExportRequest) Reset()

func (*ExportRequest) String 

func (x *ExportRequest) String() string

type ExportResponse 

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

Nothing to return.

func (*ExportResponse) Descriptor deprecated 

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

Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.

func (*ExportResponse) ProtoMessage 

func (*ExportResponse) ProtoMessage()

func (*ExportResponse) ProtoReflect 

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

func (*ExportResponse) Reset 

func (x *ExportResponse) Reset()

func (*ExportResponse) String 

func (x *ExportResponse) String() string

type FullyQualifiedService 

type FullyQualifiedService struct {
	PackagePath string `protobuf:"bytes,1,opt,name=package_path,json=packagePath,proto3" json:"package_path,omitempty"`
	Service     string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

FullyQualified service is the complete (protobuf) name of a service as a a string. This is typically something like "foo.v1" for the package and the service name is "Foo". These are the names used by the export, require, and locate calls.

func (*FullyQualifiedService) Descriptor deprecated 

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

Deprecated: Use FullyQualifiedService.ProtoReflect.Descriptor instead.

func (*FullyQualifiedService) GetPackagePath 

func (x *FullyQualifiedService) GetPackagePath() string

func (*FullyQualifiedService) GetService 

func (x *FullyQualifiedService) GetService() string

func (*FullyQualifiedService) ProtoMessage 

func (*FullyQualifiedService) ProtoMessage()

func (*FullyQualifiedService) ProtoReflect 

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

func (*FullyQualifiedService) Reset 

func (x *FullyQualifiedService) Reset()

func (*FullyQualifiedService) String 

func (x *FullyQualifiedService) String() string

type HostBinding 

type HostBinding struct {
	ServiceId *v1.IdRaw `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	HostId    *v1.IdRaw `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

HostBinding is the mapping between a service and a host. Note that a given host may be bound to many services, but a single service is always bound to exactly one host.

func (*HostBinding) Descriptor deprecated 

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

Deprecated: Use HostBinding.ProtoReflect.Descriptor instead.

func (*HostBinding) GetHostId 

func (x *HostBinding) GetHostId() *v1.IdRaw

func (*HostBinding) GetServiceId 

func (x *HostBinding) GetServiceId() *v1.IdRaw

func (*HostBinding) ProtoMessage 

func (*HostBinding) ProtoMessage()

func (*HostBinding) ProtoReflect 

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

func (*HostBinding) Reset 

func (x *HostBinding) Reset()

func (*HostBinding) String 

func (x *HostBinding) String() string

type KernelErr 

type KernelErr int32
const (
	KernelErr_NoError KernelErr = 0
	// LocateError is return when the kernel cannot find the requested
	// service, given by a package name and service name pair.
	KernelErr_LocateError KernelErr = 1
	// UnmarshalFailed is used to indicate that in unmarshaling
	// a request or result, the protobuf layer returned an error.
	KernelErr_UnmarshalFailed KernelErr = 2
	// IdDispatch means that a dispatch call failed due to an
	// MethodId or ServiceId was not found.  This is also used when
	// binding a method if the name is invalid.
	KernelErr_IdDispatch KernelErr = 3
	// NamespaceExhausted is returned when the kernel can no
	// along accept additional packages, services, or methods.  This is used
	// primarily to thwart attempts at DOS attacks.
	KernelErr_NamespaceExhausted KernelErr = 4
	// NotFound means that a package, service, or method that was requested
	// could not be found.
	KernelErr_NotFound KernelErr = 5
	// DataTooLarge means that the size of some part of method call was bigger
	// than the buffer allocated to receive it.  This could be a problem either on
	// the call side or the return side.
	KernelErr_DataTooLarge KernelErr = 6
	// Marshal means that a marshal of a protobuf has failed.
	KernelErr_MarshalFailed KernelErr = 7
	// CallerUnavailable means that the kernel could not find the original caller
	// that requested the computation for which results have been provided.
	// It is most likely because the caller was killed, exited or timed out.
	KernelErr_CallerUnavailable KernelErr = 8
	// KernelServiceAlreadyClosedOrExported means that some process has already
	// reported the service in question as closed or has already expressed that it is
	// exporting (implementing this service).  This is very likely a case where there
	// are two servers that think they are or should be implementing the same service.
	KernelErr_ServiceAlreadyClosedOrExported KernelErr = 9
	// ServiceAlreadyRequired means that this same process has already
	// required the given service.
	KernelErr_ServiceAlreadyRequired KernelErr = 10
	// DependencyCycle means that no deterministic startup ordering
	// exists for the set of exports and requires in use.  In other words,
	// you must refactor your program so that you do not have a cyle to make
	// it come up cleanly.
	KernelErr_DependencyCycle KernelErr = 11
	// NetworkFailed means that we successfully connected to the nameserver, but failed
	// during the communication process itself.
	KernelErr_NetworkFailed KernelErr = 12
	// NetworkConnectionLost means that our internal connection to the remote nameserver
	// was either still working but has lost "sync" in the protocol or the connection has
	// become entirely broken.  The kernel will close the connection to remote nameserver
	// and reestablish it after this error.
	KernelErr_NetworkConnectionLost KernelErr = 13
	// DataTooSmall means that the kernel was speaking some protocol with a remote server,
	// such as a remote nameserver, and data read from the remote said was smaller than the protocol
	// dictated, e.g. it did not contain a checksum after a data block.
	KernelErr_DataTooSmall KernelErr = 14
	// ConnectionFailed means that the attempt to open a connection to a remote
	// service has failed to connect.
	KernelErr_KernelConnectionFailed KernelErr = 15
	// NSRetryFailed means that we tried twice to reach the nameserver with
	// the given request, but both times could not do so.
	KernelErr_NSRetryFailed KernelErr = 16
	// DecodeError indicates that an attempt to extract a protobuf object
	// from an encoded set of bytes has failed.  Typically, this means that
	// the encoder was not called.
	KernelErr_DecodeError KernelErr = 17
	// ExecError means that we received a response from the implenter of a particular
	// service's function and the execution of that function failed.
	KernelErr_ExecError KernelErr = 18
	// DependencyFailure means that the dependency infrastructure has failed.  This is different
	// than when a user creates bad set of depedencies (KernelDependencyCycle). This
	// an internal to the kernel error.
	KernelErr_KernelDependencyFailure KernelErr = 19
	// AbortRequest indicates that the program that receives this error
	// should exit because the nameserver has asked it to do so.  This
	// means that some _other_ program has failed to start correctly, so this
	// deployment cannot succeed.
	KernelErr_AbortRequest KernelErr = 20
	// EncodeError indicates that an attempt encode a protobuf
	// with header and CRC has failed.
	KernelErr_EncodeError KernelErr = 22
	// ClosedErr indicates that that object is now closed.  This is used
	// as a signal when writing data between the guest and host.
	KernelErr_ClosedErr KernelErr = 23
	// GuestReadFailed indicates that we did not successfully read
	// from guest memory. This is usually caused by the proposed address
	// to read from being out of bounds.
	KernelErr_GuestReadFailed KernelErr = 24
	// GuestWriteFailed indicates that we did not successfully write
	// to guest memory. This is usually caused by the proposed address
	// for writing to being out of bounds.
	KernelErr_GuestWriteFailed KernelErr = 25
	// BadId indicates that you passed the zero value or the empty value of a
	// an id type into a system call.  This usually means that you did not
	// properly initialize a protobuf.
	KernelErr_BadId KernelErr = 26
	// NotReady that the service that was trying
	// to start was aborted because it returned false from Ready().
	// Usually this error indicates that the program has no way to
	// continue running.
	KernelErr_NotReady KernelErr = 27
	// NotRequired that a service has tried to Locate() another service
	// that that the first service did not Require() previously.
	KernelErr_NotRequired KernelErr = 28
	// RunTimeout means that the programs timeout has expired when waiting
	// for all the required dependencies to be fulfilled.
	KernelErr_RunTimeout KernelErr = 29
	// ReadOneTimeout means that the program was trying to request
	// a service/method pair to invoke, but the request timed out.
	KernelErr_ReadOneTimeout KernelErr = 30
	// WriteTimeout means that the program was trying to send
	// a request to another service, but timed out before it could do so.
	KernelErr_WriteTimeout KernelErr = 31
	// BadCallId is returned when trying to match up the results
	// and the call of a function resulting in a promise. It is returned
	// if either there is no such cid registered yet or the cid
	// is already in use.
	KernelErr_BadCallId KernelErr = 32
	// ChannelClosed indicates that one of the internal channels used in
	// waiting for input has been closed unexpectedly.
	// is already in use.
	KernelErr_ChannelClosed KernelErr = 33
	// ExitFailed means that we were tyring to send an orderly shutdown but
	// could not reach all the of the hosts that we needed to notify.
	KernelErr_ExitFailed KernelErr = 34
)

func (KernelErr) Descriptor 

func (KernelErr) Descriptor() protoreflect.EnumDescriptor

func (KernelErr) Enum 

func (x KernelErr) Enum() *KernelErr

func (KernelErr) EnumDescriptor deprecated 

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

Deprecated: Use KernelErr.Descriptor instead.

func (KernelErr) Number 

func (x KernelErr) Number() protoreflect.EnumNumber

func (KernelErr) String 

func (x KernelErr) String() string

func (KernelErr) Type 

func (KernelErr) Type() protoreflect.EnumType

type LaunchRequest 

type LaunchRequest struct {
	ServiceId *v1.IdRaw `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	CallId    *v1.IdRaw `protobuf:"bytes,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`       // reserved for internal use
	HostId    *v1.IdRaw `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`       // reserved for internal use
	MethodId  *v1.IdRaw `protobuf:"bytes,4,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"` // reserved for internal use
	// contains filtered or unexported fields
}

LaunchRequest is used to block a service until its depnedencies are ready. It returns a future to the guest that can be used to take action once launch is completed.

func (*LaunchRequest) Descriptor deprecated 

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

Deprecated: Use LaunchRequest.ProtoReflect.Descriptor instead.

func (*LaunchRequest) GetCallId 

func (x *LaunchRequest) GetCallId() *v1.IdRaw

func (*LaunchRequest) GetHostId 

func (x *LaunchRequest) GetHostId() *v1.IdRaw

func (*LaunchRequest) GetMethodId 

func (x *LaunchRequest) GetMethodId() *v1.IdRaw

func (*LaunchRequest) GetServiceId 

func (x *LaunchRequest) GetServiceId() *v1.IdRaw

func (*LaunchRequest) ProtoMessage 

func (*LaunchRequest) ProtoMessage()

func (*LaunchRequest) ProtoReflect 

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

func (*LaunchRequest) Reset 

func (x *LaunchRequest) Reset()

func (*LaunchRequest) String 

func (x *LaunchRequest) String() string

type LaunchResponse 

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

LaunchResponse has nothing in it because the action will be handled by a future created as a result of LaunchRequest.

func (*LaunchResponse) Descriptor deprecated 

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

Deprecated: Use LaunchResponse.ProtoReflect.Descriptor instead.

func (*LaunchResponse) ProtoMessage 

func (*LaunchResponse) ProtoMessage()

func (*LaunchResponse) ProtoReflect 

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

func (*LaunchResponse) Reset 

func (x *LaunchResponse) Reset()

func (*LaunchResponse) String 

func (x *LaunchResponse) String() string

type LocateRequest 

type LocateRequest struct {
	PackageName string `protobuf:"bytes,1,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// called_by is only needed for true clients. If you are doing a call to
	// locate with a service that you did not and could not have known beforehand
	// you should leave this empty.
	CalledBy *v1.IdRaw `protobuf:"bytes,3,opt,name=called_by,json=calledBy,proto3" json:"called_by,omitempty"`
	// contains filtered or unexported fields
}

LocateRequest is a read from the kernel of the service id associated with a package, service pair.

func (*LocateRequest) Descriptor deprecated 

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

Deprecated: Use LocateRequest.ProtoReflect.Descriptor instead.

func (*LocateRequest) GetCalledBy 

func (x *LocateRequest) GetCalledBy() *v1.IdRaw

func (*LocateRequest) GetPackageName 

func (x *LocateRequest) GetPackageName() string

func (*LocateRequest) GetServiceName 

func (x *LocateRequest) GetServiceName() string

func (*LocateRequest) ProtoMessage 

func (*LocateRequest) ProtoMessage()

func (*LocateRequest) ProtoReflect 

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

func (*LocateRequest) Reset 

func (x *LocateRequest) Reset()

func (*LocateRequest) String 

func (x *LocateRequest) String() string

type LocateResponse 

type LocateResponse struct {
	HostId    *v1.IdRaw        `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	ServiceId *v1.IdRaw        `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Binding   []*MethodBinding `protobuf:"bytes,3,rep,name=binding,proto3" json:"binding,omitempty"`
	// contains filtered or unexported fields
}

LocateResponse hands back the service Id of the package_name and service_name supplied in the request. A service id can be thought of as a (network hostname,port) pair that defines which service's "location".

func (*LocateResponse) Descriptor deprecated 

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

Deprecated: Use LocateResponse.ProtoReflect.Descriptor instead.

func (*LocateResponse) GetBinding 

func (x *LocateResponse) GetBinding() []*MethodBinding

func (*LocateResponse) GetHostId 

func (x *LocateResponse) GetHostId() *v1.IdRaw

func (*LocateResponse) GetServiceId 

func (x *LocateResponse) GetServiceId() *v1.IdRaw

func (*LocateResponse) ProtoMessage 

func (*LocateResponse) ProtoMessage()

func (*LocateResponse) ProtoReflect 

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

func (*LocateResponse) Reset 

func (x *LocateResponse) Reset()

func (*LocateResponse) String 

func (x *LocateResponse) String() string

type MethodBinding 

type MethodBinding struct {
	MethodName string    `protobuf:"bytes,1,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	MethodId   *v1.IdRaw `protobuf:"bytes,2,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MethodBinding) Descriptor deprecated 

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

Deprecated: Use MethodBinding.ProtoReflect.Descriptor instead.

func (*MethodBinding) GetMethodId 

func (x *MethodBinding) GetMethodId() *v1.IdRaw

func (*MethodBinding) GetMethodName 

func (x *MethodBinding) GetMethodName() string

func (*MethodBinding) ProtoMessage 

func (*MethodBinding) ProtoMessage()

func (*MethodBinding) ProtoReflect 

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

func (*MethodBinding) Reset 

func (x *MethodBinding) Reset()

func (*MethodBinding) String 

func (x *MethodBinding) String() string

type MethodBundle 

type MethodBundle struct {
	HostId    *v1.IdRaw `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	ServiceId *v1.IdRaw `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	MethodId  *v1.IdRaw `protobuf:"bytes,3,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"`
	CallId    *v1.IdRaw `protobuf:"bytes,4,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	// contains filtered or unexported fields
}

MessageBundle tells the receiver all the necessary info to make a call on a method. Note that when this is sent to a particular server, the HostId is the host id of the _caller_ not the place where the service is implemented.

func (*MethodBundle) Descriptor deprecated 

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

Deprecated: Use MethodBundle.ProtoReflect.Descriptor instead.

func (*MethodBundle) GetCallId 

func (x *MethodBundle) GetCallId() *v1.IdRaw

func (*MethodBundle) GetHostId 

func (x *MethodBundle) GetHostId() *v1.IdRaw

func (*MethodBundle) GetMethodId 

func (x *MethodBundle) GetMethodId() *v1.IdRaw

func (*MethodBundle) GetServiceId 

func (x *MethodBundle) GetServiceId() *v1.IdRaw

func (*MethodBundle) ProtoMessage 

func (*MethodBundle) ProtoMessage()

func (*MethodBundle) ProtoReflect 

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

func (*MethodBundle) Reset 

func (x *MethodBundle) Reset()

func (*MethodBundle) String 

func (x *MethodBundle) String() string

type MethodDirection 

type MethodDirection int32
const (
	MethodDirection_METHOD_DIRECTION_UNSPECIFIED MethodDirection = 0
	MethodDirection_METHOD_DIRECTION_IN          MethodDirection = 1
	MethodDirection_METHOD_DIRECTION_OUT         MethodDirection = 2
	MethodDirection_METHOD_DIRECTION_BOTH        MethodDirection = 3
)

func (MethodDirection) Descriptor 

func (MethodDirection) Descriptor() protoreflect.EnumDescriptor

func (MethodDirection) Enum 

func (x MethodDirection) Enum() *MethodDirection

func (MethodDirection) EnumDescriptor deprecated 

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

Deprecated: Use MethodDirection.Descriptor instead.

func (MethodDirection) Number 

func (x MethodDirection) Number() protoreflect.EnumNumber

func (MethodDirection) String 

func (x MethodDirection) String() string

func (MethodDirection) Type 

func (MethodDirection) Type() protoreflect.EnumType

type ReadOneRequest 

type ReadOneRequest struct {
	TimeoutInMillis int32     `protobuf:"varint,1,opt,name=timeout_in_millis,json=timeoutInMillis,proto3" json:"timeout_in_millis,omitempty"`
	HostId          *v1.IdRaw `protobuf:"bytes,2,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	// contains filtered or unexported fields
}

ReadOneRequest gives a set of service/method pairs that should be considered for a read. The ReadOne operation returns a single service/method pair that has received a call. If the timeout expires, only the timeout bool is returned. If the timeout value is 0, then an instanteous sample is returned. If the timeout value is negative, it means wait forever. In addition to potential calls on the service who requests this read, it is also possible that the return value represents a completed call from a previous point in the execution of the calling program.

func (*ReadOneRequest) Descriptor deprecated 

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

Deprecated: Use ReadOneRequest.ProtoReflect.Descriptor instead.

func (*ReadOneRequest) GetHostId 

func (x *ReadOneRequest) GetHostId() *v1.IdRaw

func (*ReadOneRequest) GetTimeoutInMillis 

func (x *ReadOneRequest) GetTimeoutInMillis() int32

func (*ReadOneRequest) ProtoMessage 

func (*ReadOneRequest) ProtoMessage()

func (*ReadOneRequest) ProtoReflect 

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

func (*ReadOneRequest) Reset 

func (x *ReadOneRequest) Reset()

func (*ReadOneRequest) String 

func (x *ReadOneRequest) String() string

type ReadOneResponse 

type ReadOneResponse struct {
	Timeout       bool          `protobuf:"varint,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Bundle        *MethodBundle `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	ParamOrResult *anypb.Any    `protobuf:"bytes,3,opt,name=param_or_result,json=paramOrResult,proto3" json:"param_or_result,omitempty"`
	ResultErr     int32         `protobuf:"varint,4,opt,name=result_err,json=resultErr,proto3" json:"result_err,omitempty"`
	Resolved      *ResolvedCall `protobuf:"bytes,5,opt,name=resolved,proto3" json:"resolved,omitempty"`
	Exit          *ExitPair     `protobuf:"bytes,6,opt,name=exit,proto3" json:"exit,omitempty"`
	// contains filtered or unexported fields
}

ReadOneResponse is returned when the control is turned over to parigot for a period of time via a call to ReadOne. ReadOneResponse returns timeout = true if a timeout has occurred. If timeout is true, all the other fields should be ignored. There are two types of results and these are mutually exclusive.

If resolved is not nil, then this a notification that a call made by this program have completed. The resolved field holds information about the completed call, and that data needs to be matched with the appropriate call ids and the promises resolved.

If resolved is nil, then the call is a call on a service and method exposed by this server. In that case the pair indicates the method and service being invoked, and the param and call id should be to create a matching ReturnValueRequest.

Note that if the method denoted by the pair does not take input, the value of param should be ignored and it may be nil.

func (*ReadOneResponse) Descriptor deprecated 

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

Deprecated: Use ReadOneResponse.ProtoReflect.Descriptor instead.

func (*ReadOneResponse) GetBundle 

func (x *ReadOneResponse) GetBundle() *MethodBundle

func (*ReadOneResponse) GetExit 

func (x *ReadOneResponse) GetExit() *ExitPair

func (*ReadOneResponse) GetParamOrResult 

func (x *ReadOneResponse) GetParamOrResult() *anypb.Any

func (*ReadOneResponse) GetResolved 

func (x *ReadOneResponse) GetResolved() *ResolvedCall

func (*ReadOneResponse) GetResultErr 

func (x *ReadOneResponse) GetResultErr() int32

func (*ReadOneResponse) GetTimeout 

func (x *ReadOneResponse) GetTimeout() bool

func (*ReadOneResponse) ProtoMessage 

func (*ReadOneResponse) ProtoMessage()

func (*ReadOneResponse) ProtoReflect 

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

func (*ReadOneResponse) Reset 

func (x *ReadOneResponse) Reset()

func (*ReadOneResponse) String 

func (x *ReadOneResponse) String() string

type RegisterRequest 

type RegisterRequest struct {
	HostId    *v1.IdRaw `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	DebugName string    `protobuf:"bytes,2,opt,name=debug_name,json=debugName,proto3" json:"debug_name,omitempty"`
	// contains filtered or unexported fields
}

Register informs the kernel you are one of the running services and you want a service id.

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetDebugName 

func (x *RegisterRequest) GetDebugName() string

func (*RegisterRequest) GetHostId 

func (x *RegisterRequest) GetHostId() *v1.IdRaw

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	ServiceId         *v1.IdRaw `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	ExistedPreviously bool      `protobuf:"varint,2,opt,name=existed_previously,json=existedPreviously,proto3" json:"existed_previously,omitempty"`
	// contains filtered or unexported fields
}

RegisterResponse indicates if the registering caller has created the new service or not.

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetExistedPreviously 

func (x *RegisterResponse) GetExistedPreviously() bool

func (*RegisterResponse) GetServiceId 

func (x *RegisterResponse) GetServiceId() *v1.IdRaw

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type RequireRequest 

type RequireRequest struct {
	Dest   []*FullyQualifiedService `protobuf:"bytes,1,rep,name=dest,proto3" json:"dest,omitempty"`
	Source *v1.IdRaw                `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

Require establishes that the source given is going to import the service given by dest. It is not required that the source locate the dest, although if one does call locate, a check is done to insure require was called previously. This check is done to prevent a common programming mistake.

func (*RequireRequest) Descriptor deprecated 

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

Deprecated: Use RequireRequest.ProtoReflect.Descriptor instead.

func (*RequireRequest) GetDest 

func (x *RequireRequest) GetDest() []*FullyQualifiedService

func (*RequireRequest) GetSource 

func (x *RequireRequest) GetSource() *v1.IdRaw

func (*RequireRequest) ProtoMessage 

func (*RequireRequest) ProtoMessage()

func (*RequireRequest) ProtoReflect 

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

func (*RequireRequest) Reset 

func (x *RequireRequest) Reset()

func (*RequireRequest) String 

func (x *RequireRequest) String() string

type RequireResponse 

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

RequireResponse is currently empty.

func (*RequireResponse) Descriptor deprecated 

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

Deprecated: Use RequireResponse.ProtoReflect.Descriptor instead.

func (*RequireResponse) ProtoMessage 

func (*RequireResponse) ProtoMessage()

func (*RequireResponse) ProtoReflect 

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

func (*RequireResponse) Reset 

func (x *RequireResponse) Reset()

func (*RequireResponse) String 

func (x *RequireResponse) String() string

type ResolvedCall 

type ResolvedCall struct {
	HostId      *v1.IdRaw  `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	CallId      *v1.IdRaw  `protobuf:"bytes,2,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	MethodId    *v1.IdRaw  `protobuf:"bytes,3,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"`
	Result      *anypb.Any `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	ResultError int32      `protobuf:"varint,5,opt,name=result_error,json=resultError,proto3" json:"result_error,omitempty"`
	// contains filtered or unexported fields
}

ResolvedCall is used to hold the output of a service/method call while we are waiting for the future to be resolved. Note that the host_id here is the host id of the SENDER of this message, so the place that the result was calculated.

func (*ResolvedCall) Descriptor deprecated 

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

Deprecated: Use ResolvedCall.ProtoReflect.Descriptor instead.

func (*ResolvedCall) GetCallId 

func (x *ResolvedCall) GetCallId() *v1.IdRaw

func (*ResolvedCall) GetHostId 

func (x *ResolvedCall) GetHostId() *v1.IdRaw

func (*ResolvedCall) GetMethodId 

func (x *ResolvedCall) GetMethodId() *v1.IdRaw

func (*ResolvedCall) GetResult 

func (x *ResolvedCall) GetResult() *anypb.Any

func (*ResolvedCall) GetResultError 

func (x *ResolvedCall) GetResultError() int32

func (*ResolvedCall) ProtoMessage 

func (*ResolvedCall) ProtoMessage()

func (*ResolvedCall) ProtoReflect 

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

func (*ResolvedCall) Reset 

func (x *ResolvedCall) Reset()

func (*ResolvedCall) String 

func (x *ResolvedCall) String() string

type ReturnValueRequest 

type ReturnValueRequest struct {
	Bundle      *MethodBundle `protobuf:"bytes,1,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Result      *anypb.Any    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	ResultError int32         `protobuf:"varint,3,opt,name=result_error,json=resultError,proto3" json:"result_error,omitempty"`
	// contains filtered or unexported fields
}

ReturnValueRequest is used to return the result of a function back to the caller. It is the result information of a call to a service/method function.

func (*ReturnValueRequest) Descriptor deprecated 

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

Deprecated: Use ReturnValueRequest.ProtoReflect.Descriptor instead.

func (*ReturnValueRequest) GetBundle 

func (x *ReturnValueRequest) GetBundle() *MethodBundle

func (*ReturnValueRequest) GetResult 

func (x *ReturnValueRequest) GetResult() *anypb.Any

func (*ReturnValueRequest) GetResultError 

func (x *ReturnValueRequest) GetResultError() int32

func (*ReturnValueRequest) ProtoMessage 

func (*ReturnValueRequest) ProtoMessage()

func (*ReturnValueRequest) ProtoReflect 

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

func (*ReturnValueRequest) Reset 

func (x *ReturnValueRequest) Reset()

func (*ReturnValueRequest) String 

func (x *ReturnValueRequest) String() string

type ReturnValueResponse 

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

ReturnValueResponse is currently empty.

func (*ReturnValueResponse) Descriptor deprecated 

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

Deprecated: Use ReturnValueResponse.ProtoReflect.Descriptor instead.

func (*ReturnValueResponse) ProtoMessage 

func (*ReturnValueResponse) ProtoMessage()

func (*ReturnValueResponse) ProtoReflect 

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

func (*ReturnValueResponse) Reset 

func (x *ReturnValueResponse) Reset()

func (*ReturnValueResponse) String 

func (x *ReturnValueResponse) String() string

type ServiceByIdRequest 

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

ServiceByIdRequest looks up the given service by its string representation. This is probably only useful for passing service objects over the wire.

func (*ServiceByIdRequest) Descriptor deprecated 

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

Deprecated: Use ServiceByIdRequest.ProtoReflect.Descriptor instead.

func (*ServiceByIdRequest) GetServiceId 

func (x *ServiceByIdRequest) GetServiceId() string

func (*ServiceByIdRequest) ProtoMessage 

func (*ServiceByIdRequest) ProtoMessage()

func (*ServiceByIdRequest) ProtoReflect 

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

func (*ServiceByIdRequest) Reset 

func (x *ServiceByIdRequest) Reset()

func (*ServiceByIdRequest) String 

func (x *ServiceByIdRequest) String() string

type ServiceByIdResponse 

type ServiceByIdResponse struct {
	Binding *HostBinding `protobuf:"bytes,1,opt,name=binding,proto3" json:"binding,omitempty"`
	// contains filtered or unexported fields
}

ServiceByIdResponse returns host binding for the service or nothing.

func (*ServiceByIdResponse) Descriptor deprecated 

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

Deprecated: Use ServiceByIdResponse.ProtoReflect.Descriptor instead.

func (*ServiceByIdResponse) GetBinding 

func (x *ServiceByIdResponse) GetBinding() *HostBinding

func (*ServiceByIdResponse) ProtoMessage 

func (*ServiceByIdResponse) ProtoMessage()

func (*ServiceByIdResponse) ProtoReflect 

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

func (*ServiceByIdResponse) Reset 

func (x *ServiceByIdResponse) Reset()

func (*ServiceByIdResponse) String 

func (x *ServiceByIdResponse) String() string

type ServiceByNameRequest 

type ServiceByNameRequest struct {
	Fqs *FullyQualifiedService `protobuf:"bytes,1,opt,name=fqs,proto3" json:"fqs,omitempty"`
	// contains filtered or unexported fields
}

ServiceByName looks up the given service and returns all the host bindings associated with it. This does change the internal data structures, only reports on them.

func (*ServiceByNameRequest) Descriptor deprecated 

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

Deprecated: Use ServiceByNameRequest.ProtoReflect.Descriptor instead.

func (*ServiceByNameRequest) GetFqs 

func (x *ServiceByNameRequest) GetFqs() *FullyQualifiedService

func (*ServiceByNameRequest) ProtoMessage 

func (*ServiceByNameRequest) ProtoMessage()

func (*ServiceByNameRequest) ProtoReflect 

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

func (*ServiceByNameRequest) Reset 

func (x *ServiceByNameRequest) Reset()

func (*ServiceByNameRequest) String 

func (x *ServiceByNameRequest) String() string

type ServiceByNameResponse 

type ServiceByNameResponse struct {
	Binding []*HostBinding `protobuf:"bytes,1,rep,name=binding,proto3" json:"binding,omitempty"`
	// contains filtered or unexported fields
}

ServiceByNameResponse returns the list, possibly empty, that has all the host bindings for the named service.

func (*ServiceByNameResponse) Descriptor deprecated 

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

Deprecated: Use ServiceByNameResponse.ProtoReflect.Descriptor instead.

func (*ServiceByNameResponse) GetBinding 

func (x *ServiceByNameResponse) GetBinding() []*HostBinding

func (*ServiceByNameResponse) ProtoMessage 

func (*ServiceByNameResponse) ProtoMessage()

func (*ServiceByNameResponse) ProtoReflect 

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

func (*ServiceByNameResponse) Reset 

func (x *ServiceByNameResponse) Reset()

func (*ServiceByNameResponse) String 

func (x *ServiceByNameResponse) String() string

type ServiceMethodCall 

type ServiceMethodCall struct {
	ServiceId *v1.IdRaw `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	MethodId  *v1.IdRaw `protobuf:"bytes,2,opt,name=method_id,json=methodId,proto3" json:"method_id,omitempty"`
	// contains filtered or unexported fields
}

ServiceMethodCall is the structure that holds "what's been called" in a service.

func (*ServiceMethodCall) Descriptor deprecated 

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

Deprecated: Use ServiceMethodCall.ProtoReflect.Descriptor instead.

func (*ServiceMethodCall) GetMethodId 

func (x *ServiceMethodCall) GetMethodId() *v1.IdRaw

func (*ServiceMethodCall) GetServiceId 

func (x *ServiceMethodCall) GetServiceId() *v1.IdRaw

func (*ServiceMethodCall) ProtoMessage 

func (*ServiceMethodCall) ProtoMessage()

func (*ServiceMethodCall) ProtoReflect 

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

func (*ServiceMethodCall) Reset 

func (x *ServiceMethodCall) Reset()

func (*ServiceMethodCall) String 

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