rpc

package
v0.0.2-0...-1b30d8d Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2019 License: MIT Imports: 6 Imported by: 6

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BindingInfo_Direction_name = map[int32]string{
	0: "in",
	1: "out",
	2: "inout",
}
View Source 
var BindingInfo_Direction_value = map[string]int32{
	"in":    0,
	"out":   1,
	"inout": 2,
}
View Source 
var FileChangeEventRequest_Type_name = map[int32]string{
	0:  "Unknown",
	1:  "Created",
	2:  "Deleted",
	4:  "Changed",
	8:  "Renamed",
	15: "All",
}
View Source 
var FileChangeEventRequest_Type_value = map[string]int32{
	"Unknown": 0,
	"Created": 1,
	"Deleted": 2,
	"Changed": 4,
	"Renamed": 8,
	"All":     15,
}
View Source 
var RpcLog_Level_name = map[int32]string{
	0: "Trace",
	1: "Debug",
	2: "Information",
	3: "Warning",
	4: "Error",
	5: "Critical",
	6: "None",
}
View Source 
var RpcLog_Level_value = map[string]int32{
	"Trace":       0,
	"Debug":       1,
	"Information": 2,
	"Warning":     3,
	"Error":       4,
	"Critical":    5,
	"None":        6,
}
View Source 
var StatusResult_Status_name = map[int32]string{
	0: "Failure",
	1: "Success",
	2: "Cancelled",
}
View Source 
var StatusResult_Status_value = map[string]int32{
	"Failure":   0,
	"Success":   1,
	"Cancelled": 2,
}
View Source 
var WorkerActionResponse_Action_name = map[int32]string{
	0: "Restart",
	1: "Reload",
}
View Source 
var WorkerActionResponse_Action_value = map[string]int32{
	"Restart": 0,
	"Reload":  1,
}

Functions

func RegisterFunctionRpcServer 

func RegisterFunctionRpcServer(s *grpc.Server, srv FunctionRpcServer)

Types

type BindingInfo 

type BindingInfo struct {
	// Type of binding (e.g. HttpTrigger)
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Direction of the given binding
	Direction            BindingInfo_Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=AzureFunctionsRpcMessages.BindingInfo_Direction" json:"direction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Used to describe a given binding on load

func (*BindingInfo) Descriptor 

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

func (*BindingInfo) GetDirection 

func (m *BindingInfo) GetDirection() BindingInfo_Direction

func (*BindingInfo) GetType 

func (m *BindingInfo) GetType() string

func (*BindingInfo) ProtoMessage 

func (*BindingInfo) ProtoMessage()

func (*BindingInfo) Reset 

func (m *BindingInfo) Reset()

func (*BindingInfo) String 

func (m *BindingInfo) String() string

func (*BindingInfo) XXX_DiscardUnknown 

func (m *BindingInfo) XXX_DiscardUnknown()

func (*BindingInfo) XXX_Marshal 

func (m *BindingInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindingInfo) XXX_Merge 

func (dst *BindingInfo) XXX_Merge(src proto.Message)

func (*BindingInfo) XXX_Size 

func (m *BindingInfo) XXX_Size() int

func (*BindingInfo) XXX_Unmarshal 

func (m *BindingInfo) XXX_Unmarshal(b []byte) error

type BindingInfo_Direction 

type BindingInfo_Direction int32

Indicates whether it is an input or output binding (or a fancy inout binding) 

const (
	BindingInfo_in    BindingInfo_Direction = 0
	BindingInfo_out   BindingInfo_Direction = 1
	BindingInfo_inout BindingInfo_Direction = 2
)

func (BindingInfo_Direction) EnumDescriptor 

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

func (BindingInfo_Direction) String 

func (x BindingInfo_Direction) String() string

type FileChangeEventRequest 

type FileChangeEventRequest struct {
	// type for this event
	Type FileChangeEventRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=AzureFunctionsRpcMessages.FileChangeEventRequest_Type" json:"type,omitempty"`
	// full file path for the file change notification
	FullPath string `protobuf:"bytes,2,opt,name=full_path,json=fullPath,proto3" json:"full_path,omitempty"`
	// Name of the function affected
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Host notifies worker of file content change

func (*FileChangeEventRequest) Descriptor 

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

func (*FileChangeEventRequest) GetFullPath 

func (m *FileChangeEventRequest) GetFullPath() string

func (*FileChangeEventRequest) GetName 

func (m *FileChangeEventRequest) GetName() string

func (*FileChangeEventRequest) GetType 

func (m *FileChangeEventRequest) GetType() FileChangeEventRequest_Type

func (*FileChangeEventRequest) ProtoMessage 

func (*FileChangeEventRequest) ProtoMessage()

func (*FileChangeEventRequest) Reset 

func (m *FileChangeEventRequest) Reset()

func (*FileChangeEventRequest) String 

func (m *FileChangeEventRequest) String() string

func (*FileChangeEventRequest) XXX_DiscardUnknown 

func (m *FileChangeEventRequest) XXX_DiscardUnknown()

func (*FileChangeEventRequest) XXX_Marshal 

func (m *FileChangeEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileChangeEventRequest) XXX_Merge 

func (dst *FileChangeEventRequest) XXX_Merge(src proto.Message)

func (*FileChangeEventRequest) XXX_Size 

func (m *FileChangeEventRequest) XXX_Size() int

func (*FileChangeEventRequest) XXX_Unmarshal 

func (m *FileChangeEventRequest) XXX_Unmarshal(b []byte) error

type FileChangeEventRequest_Type 

type FileChangeEventRequest_Type int32

Types of File change operations (See link for more info: https://msdn.microsoft.com/en-us/library/t6xf43e0(v=vs.110).aspx) 

const (
	FileChangeEventRequest_Unknown FileChangeEventRequest_Type = 0
	FileChangeEventRequest_Created FileChangeEventRequest_Type = 1
	FileChangeEventRequest_Deleted FileChangeEventRequest_Type = 2
	FileChangeEventRequest_Changed FileChangeEventRequest_Type = 4
	FileChangeEventRequest_Renamed FileChangeEventRequest_Type = 8
	FileChangeEventRequest_All     FileChangeEventRequest_Type = 15
)

func (FileChangeEventRequest_Type) EnumDescriptor 

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

func (FileChangeEventRequest_Type) String 

func (x FileChangeEventRequest_Type) String() string

type FunctionLoadRequest 

type FunctionLoadRequest struct {
	// unique function identifier (avoid name collisions, facilitate reload case)
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Metadata for the request
	Metadata             *RpcFunctionMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Host tells the worker to load a Function

func (*FunctionLoadRequest) Descriptor 

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

func (*FunctionLoadRequest) GetFunctionId 

func (m *FunctionLoadRequest) GetFunctionId() string

func (*FunctionLoadRequest) GetMetadata 

func (m *FunctionLoadRequest) GetMetadata() *RpcFunctionMetadata

func (*FunctionLoadRequest) ProtoMessage 

func (*FunctionLoadRequest) ProtoMessage()

func (*FunctionLoadRequest) Reset 

func (m *FunctionLoadRequest) Reset()

func (*FunctionLoadRequest) String 

func (m *FunctionLoadRequest) String() string

func (*FunctionLoadRequest) XXX_DiscardUnknown 

func (m *FunctionLoadRequest) XXX_DiscardUnknown()

func (*FunctionLoadRequest) XXX_Marshal 

func (m *FunctionLoadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FunctionLoadRequest) XXX_Merge 

func (dst *FunctionLoadRequest) XXX_Merge(src proto.Message)

func (*FunctionLoadRequest) XXX_Size 

func (m *FunctionLoadRequest) XXX_Size() int

func (*FunctionLoadRequest) XXX_Unmarshal 

func (m *FunctionLoadRequest) XXX_Unmarshal(b []byte) error

type FunctionLoadResponse 

type FunctionLoadResponse struct {
	// unique function identifier
	FunctionId string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Result of load operation
	Result               *StatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Worker tells host result of reload

func (*FunctionLoadResponse) Descriptor 

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

func (*FunctionLoadResponse) GetFunctionId 

func (m *FunctionLoadResponse) GetFunctionId() string

func (*FunctionLoadResponse) GetResult 

func (m *FunctionLoadResponse) GetResult() *StatusResult

func (*FunctionLoadResponse) ProtoMessage 

func (*FunctionLoadResponse) ProtoMessage()

func (*FunctionLoadResponse) Reset 

func (m *FunctionLoadResponse) Reset()

func (*FunctionLoadResponse) String 

func (m *FunctionLoadResponse) String() string

func (*FunctionLoadResponse) XXX_DiscardUnknown 

func (m *FunctionLoadResponse) XXX_DiscardUnknown()

func (*FunctionLoadResponse) XXX_Marshal 

func (m *FunctionLoadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FunctionLoadResponse) XXX_Merge 

func (dst *FunctionLoadResponse) XXX_Merge(src proto.Message)

func (*FunctionLoadResponse) XXX_Size 

func (m *FunctionLoadResponse) XXX_Size() int

func (*FunctionLoadResponse) XXX_Unmarshal 

func (m *FunctionLoadResponse) XXX_Unmarshal(b []byte) error

type FunctionRpcClient 

type FunctionRpcClient interface {
	EventStream(ctx context.Context, opts ...grpc.CallOption) (FunctionRpc_EventStreamClient, error)
}

FunctionRpcClient is the client API for FunctionRpc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFunctionRpcClient 

func NewFunctionRpcClient(cc *grpc.ClientConn) FunctionRpcClient

type FunctionRpcServer 

type FunctionRpcServer interface {
	EventStream(FunctionRpc_EventStreamServer) error
}

FunctionRpcServer is the server API for FunctionRpc service.

type FunctionRpc_EventStreamClient 

type FunctionRpc_EventStreamClient interface {
	Send(*StreamingMessage) error
	Recv() (*StreamingMessage, error)
	grpc.ClientStream
}

type FunctionRpc_EventStreamServer 

type FunctionRpc_EventStreamServer interface {
	Send(*StreamingMessage) error
	Recv() (*StreamingMessage, error)
	grpc.ServerStream
}

type InvocationCancel 

type InvocationCancel struct {
	// Unique id for invocation
	InvocationId string `protobuf:"bytes,2,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// Time period before force shutdown
	GracePeriod          *duration.Duration `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Host requests worker to cancel invocation

func (*InvocationCancel) Descriptor 

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

func (*InvocationCancel) GetGracePeriod 

func (m *InvocationCancel) GetGracePeriod() *duration.Duration

func (*InvocationCancel) GetInvocationId 

func (m *InvocationCancel) GetInvocationId() string

func (*InvocationCancel) ProtoMessage 

func (*InvocationCancel) ProtoMessage()

func (*InvocationCancel) Reset 

func (m *InvocationCancel) Reset()

func (*InvocationCancel) String 

func (m *InvocationCancel) String() string

func (*InvocationCancel) XXX_DiscardUnknown 

func (m *InvocationCancel) XXX_DiscardUnknown()

func (*InvocationCancel) XXX_Marshal 

func (m *InvocationCancel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InvocationCancel) XXX_Merge 

func (dst *InvocationCancel) XXX_Merge(src proto.Message)

func (*InvocationCancel) XXX_Size 

func (m *InvocationCancel) XXX_Size() int

func (*InvocationCancel) XXX_Unmarshal 

func (m *InvocationCancel) XXX_Unmarshal(b []byte) error

type InvocationRequest 

type InvocationRequest struct {
	// Unique id for each invocation
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// Unique id for each Function
	FunctionId string `protobuf:"bytes,2,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	// Input bindings (include trigger)
	InputData []*ParameterBinding `protobuf:"bytes,3,rep,name=input_data,json=inputData,proto3" json:"input_data,omitempty"`
	// binding metadata from trigger
	TriggerMetadata      map[string]*TypedData `` /* 194-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Host requests worker to invoke a Function

func (*InvocationRequest) Descriptor 

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

func (*InvocationRequest) GetFunctionId 

func (m *InvocationRequest) GetFunctionId() string

func (*InvocationRequest) GetInputData 

func (m *InvocationRequest) GetInputData() []*ParameterBinding

func (*InvocationRequest) GetInvocationId 

func (m *InvocationRequest) GetInvocationId() string

func (*InvocationRequest) GetTriggerMetadata 

func (m *InvocationRequest) GetTriggerMetadata() map[string]*TypedData

func (*InvocationRequest) ProtoMessage 

func (*InvocationRequest) ProtoMessage()

func (*InvocationRequest) Reset 

func (m *InvocationRequest) Reset()

func (*InvocationRequest) String 

func (m *InvocationRequest) String() string

func (*InvocationRequest) XXX_DiscardUnknown 

func (m *InvocationRequest) XXX_DiscardUnknown()

func (*InvocationRequest) XXX_Marshal 

func (m *InvocationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InvocationRequest) XXX_Merge 

func (dst *InvocationRequest) XXX_Merge(src proto.Message)

func (*InvocationRequest) XXX_Size 

func (m *InvocationRequest) XXX_Size() int

func (*InvocationRequest) XXX_Unmarshal 

func (m *InvocationRequest) XXX_Unmarshal(b []byte) error

type InvocationResponse 

type InvocationResponse struct {
	// Unique id for invocation
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// Output binding data
	OutputData []*ParameterBinding `protobuf:"bytes,2,rep,name=output_data,json=outputData,proto3" json:"output_data,omitempty"`
	// data returned from Function (for $return and triggers with return support)
	ReturnValue *TypedData `protobuf:"bytes,4,opt,name=return_value,json=returnValue,proto3" json:"return_value,omitempty"`
	// Status of the invocation (success/failure/canceled)
	Result               *StatusResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Worker responds with status of Invocation

func (*InvocationResponse) Descriptor 

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

func (*InvocationResponse) GetInvocationId 

func (m *InvocationResponse) GetInvocationId() string

func (*InvocationResponse) GetOutputData 

func (m *InvocationResponse) GetOutputData() []*ParameterBinding

func (*InvocationResponse) GetResult 

func (m *InvocationResponse) GetResult() *StatusResult

func (*InvocationResponse) GetReturnValue 

func (m *InvocationResponse) GetReturnValue() *TypedData

func (*InvocationResponse) ProtoMessage 

func (*InvocationResponse) ProtoMessage()

func (*InvocationResponse) Reset 

func (m *InvocationResponse) Reset()

func (*InvocationResponse) String 

func (m *InvocationResponse) String() string

func (*InvocationResponse) XXX_DiscardUnknown 

func (m *InvocationResponse) XXX_DiscardUnknown()

func (*InvocationResponse) XXX_Marshal 

func (m *InvocationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InvocationResponse) XXX_Merge 

func (dst *InvocationResponse) XXX_Merge(src proto.Message)

func (*InvocationResponse) XXX_Size 

func (m *InvocationResponse) XXX_Size() int

func (*InvocationResponse) XXX_Unmarshal 

func (m *InvocationResponse) XXX_Unmarshal(b []byte) error

type ParameterBinding 

type ParameterBinding struct {
	// Name for the binding
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Data for the binding
	Data                 *TypedData `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Used to describe a given binding on invocation

func (*ParameterBinding) Descriptor 

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

func (*ParameterBinding) GetData 

func (m *ParameterBinding) GetData() *TypedData

func (*ParameterBinding) GetName 

func (m *ParameterBinding) GetName() string

func (*ParameterBinding) ProtoMessage 

func (*ParameterBinding) ProtoMessage()

func (*ParameterBinding) Reset 

func (m *ParameterBinding) Reset()

func (*ParameterBinding) String 

func (m *ParameterBinding) String() string

func (*ParameterBinding) XXX_DiscardUnknown 

func (m *ParameterBinding) XXX_DiscardUnknown()

func (*ParameterBinding) XXX_Marshal 

func (m *ParameterBinding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParameterBinding) XXX_Merge 

func (dst *ParameterBinding) XXX_Merge(src proto.Message)

func (*ParameterBinding) XXX_Size 

func (m *ParameterBinding) XXX_Size() int

func (*ParameterBinding) XXX_Unmarshal 

func (m *ParameterBinding) XXX_Unmarshal(b []byte) error

type RpcException 

type RpcException struct {
	// Source of the exception
	Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	// Stack trace for the exception
	StackTrace string `protobuf:"bytes,1,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	// Textual message describing hte exception
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Encapsulates an Exception

func (*RpcException) Descriptor 

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

func (*RpcException) GetMessage 

func (m *RpcException) GetMessage() string

func (*RpcException) GetSource 

func (m *RpcException) GetSource() string

func (*RpcException) GetStackTrace 

func (m *RpcException) GetStackTrace() string

func (*RpcException) ProtoMessage 

func (*RpcException) ProtoMessage()

func (*RpcException) Reset 

func (m *RpcException) Reset()

func (*RpcException) String 

func (m *RpcException) String() string

func (*RpcException) XXX_DiscardUnknown 

func (m *RpcException) XXX_DiscardUnknown()

func (*RpcException) XXX_Marshal 

func (m *RpcException) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcException) XXX_Merge 

func (dst *RpcException) XXX_Merge(src proto.Message)

func (*RpcException) XXX_Size 

func (m *RpcException) XXX_Size() int

func (*RpcException) XXX_Unmarshal 

func (m *RpcException) XXX_Unmarshal(b []byte) error

type RpcFunctionMetadata 

type RpcFunctionMetadata struct {
	// TODO: do we want the host's name - the language worker might do a better job of assignment than the host
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// base directory for the Function
	Directory string `protobuf:"bytes,1,opt,name=directory,proto3" json:"directory,omitempty"`
	// Script file specified
	ScriptFile string `protobuf:"bytes,2,opt,name=script_file,json=scriptFile,proto3" json:"script_file,omitempty"`
	// Entry point specified
	EntryPoint string `protobuf:"bytes,3,opt,name=entry_point,json=entryPoint,proto3" json:"entry_point,omitempty"`
	// Bindings info
	Bindings             map[string]*BindingInfo `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Information on how a Function should be loaded and its bindings

func (*RpcFunctionMetadata) Descriptor 

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

func (*RpcFunctionMetadata) GetBindings 

func (m *RpcFunctionMetadata) GetBindings() map[string]*BindingInfo

func (*RpcFunctionMetadata) GetDirectory 

func (m *RpcFunctionMetadata) GetDirectory() string

func (*RpcFunctionMetadata) GetEntryPoint 

func (m *RpcFunctionMetadata) GetEntryPoint() string

func (*RpcFunctionMetadata) GetName 

func (m *RpcFunctionMetadata) GetName() string

func (*RpcFunctionMetadata) GetScriptFile 

func (m *RpcFunctionMetadata) GetScriptFile() string

func (*RpcFunctionMetadata) ProtoMessage 

func (*RpcFunctionMetadata) ProtoMessage()

func (*RpcFunctionMetadata) Reset 

func (m *RpcFunctionMetadata) Reset()

func (*RpcFunctionMetadata) String 

func (m *RpcFunctionMetadata) String() string

func (*RpcFunctionMetadata) XXX_DiscardUnknown 

func (m *RpcFunctionMetadata) XXX_DiscardUnknown()

func (*RpcFunctionMetadata) XXX_Marshal 

func (m *RpcFunctionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcFunctionMetadata) XXX_Merge 

func (dst *RpcFunctionMetadata) XXX_Merge(src proto.Message)

func (*RpcFunctionMetadata) XXX_Size 

func (m *RpcFunctionMetadata) XXX_Size() int

func (*RpcFunctionMetadata) XXX_Unmarshal 

func (m *RpcFunctionMetadata) XXX_Unmarshal(b []byte) error

type RpcHttp 

type RpcHttp struct {
	Method                   string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url                      string            `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers                  map[string]string `` /* 155-byte string literal not displayed */
	Body                     *TypedData        `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	Params                   map[string]string `` /* 154-byte string literal not displayed */
	StatusCode               string            `protobuf:"bytes,12,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Query                    map[string]string `` /* 152-byte string literal not displayed */
	EnableContentNegotiation bool              `` /* 137-byte string literal not displayed */
	RawBody                  *TypedData        `protobuf:"bytes,17,opt,name=rawBody,proto3" json:"rawBody,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}          `json:"-"`
	XXX_unrecognized         []byte            `json:"-"`
	XXX_sizecache            int32             `json:"-"`
}

TODO - solidify this or remove it

func (*RpcHttp) Descriptor 

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

func (*RpcHttp) GetBody 

func (m *RpcHttp) GetBody() *TypedData

func (*RpcHttp) GetEnableContentNegotiation 

func (m *RpcHttp) GetEnableContentNegotiation() bool

func (*RpcHttp) GetHeaders 

func (m *RpcHttp) GetHeaders() map[string]string

func (*RpcHttp) GetMethod 

func (m *RpcHttp) GetMethod() string

func (*RpcHttp) GetParams 

func (m *RpcHttp) GetParams() map[string]string

func (*RpcHttp) GetQuery 

func (m *RpcHttp) GetQuery() map[string]string

func (*RpcHttp) GetRawBody 

func (m *RpcHttp) GetRawBody() *TypedData

func (*RpcHttp) GetStatusCode 

func (m *RpcHttp) GetStatusCode() string

func (*RpcHttp) GetUrl 

func (m *RpcHttp) GetUrl() string

func (*RpcHttp) ProtoMessage 

func (*RpcHttp) ProtoMessage()

func (*RpcHttp) Reset 

func (m *RpcHttp) Reset()

func (*RpcHttp) String 

func (m *RpcHttp) String() string

func (*RpcHttp) XXX_DiscardUnknown 

func (m *RpcHttp) XXX_DiscardUnknown()

func (*RpcHttp) XXX_Marshal 

func (m *RpcHttp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcHttp) XXX_Merge 

func (dst *RpcHttp) XXX_Merge(src proto.Message)

func (*RpcHttp) XXX_Size 

func (m *RpcHttp) XXX_Size() int

func (*RpcHttp) XXX_Unmarshal 

func (m *RpcHttp) XXX_Unmarshal(b []byte) error

type RpcLog 

type RpcLog struct {
	// Unique id for invocation (if exists)
	InvocationId string `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`
	// TOD: This should be an enum
	// Category for the log (startup, load, invocation, etc.)
	Category string `protobuf:"bytes,2,opt,name=category,proto3" json:"category,omitempty"`
	// Level for the given log message
	Level RpcLog_Level `protobuf:"varint,3,opt,name=level,proto3,enum=AzureFunctionsRpcMessages.RpcLog_Level" json:"level,omitempty"`
	// Message for the given log
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// Id for the even associated with this log (if exists)
	EventId string `protobuf:"bytes,5,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Exception (if exists)
	Exception *RpcException `protobuf:"bytes,6,opt,name=exception,proto3" json:"exception,omitempty"`
	// json serialized property bag, or could use a type scheme like map<string, TypedData>
	Properties           string   `protobuf:"bytes,7,opt,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Used to send logs back to the Host

func (*RpcLog) Descriptor 

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

func (*RpcLog) GetCategory 

func (m *RpcLog) GetCategory() string

func (*RpcLog) GetEventId 

func (m *RpcLog) GetEventId() string

func (*RpcLog) GetException 

func (m *RpcLog) GetException() *RpcException

func (*RpcLog) GetInvocationId 

func (m *RpcLog) GetInvocationId() string

func (*RpcLog) GetLevel 

func (m *RpcLog) GetLevel() RpcLog_Level

func (*RpcLog) GetMessage 

func (m *RpcLog) GetMessage() string

func (*RpcLog) GetProperties 

func (m *RpcLog) GetProperties() string

func (*RpcLog) ProtoMessage 

func (*RpcLog) ProtoMessage()

func (*RpcLog) Reset 

func (m *RpcLog) Reset()

func (*RpcLog) String 

func (m *RpcLog) String() string

func (*RpcLog) XXX_DiscardUnknown 

func (m *RpcLog) XXX_DiscardUnknown()

func (*RpcLog) XXX_Marshal 

func (m *RpcLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpcLog) XXX_Merge 

func (dst *RpcLog) XXX_Merge(src proto.Message)

func (*RpcLog) XXX_Size 

func (m *RpcLog) XXX_Size() int

func (*RpcLog) XXX_Unmarshal 

func (m *RpcLog) XXX_Unmarshal(b []byte) error

type RpcLog_Level 

type RpcLog_Level int32

Matching ILogger semantics https://github.com/aspnet/Logging/blob/9506ccc3f3491488fe88010ef8b9eb64594abf95/src/Microsoft.Extensions.Logging/Logger.cs Level for the Log 

const (
	RpcLog_Trace       RpcLog_Level = 0
	RpcLog_Debug       RpcLog_Level = 1
	RpcLog_Information RpcLog_Level = 2
	RpcLog_Warning     RpcLog_Level = 3
	RpcLog_Error       RpcLog_Level = 4
	RpcLog_Critical    RpcLog_Level = 5
	RpcLog_None        RpcLog_Level = 6
)

func (RpcLog_Level) EnumDescriptor 

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

func (RpcLog_Level) String 

func (x RpcLog_Level) String() string

type StartStream 

type StartStream struct {
	// id of the worker
	WorkerId             string   `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Worker sends the host information identifying itself

func (*StartStream) Descriptor 

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

func (*StartStream) GetWorkerId 

func (m *StartStream) GetWorkerId() string

func (*StartStream) ProtoMessage 

func (*StartStream) ProtoMessage()

func (*StartStream) Reset 

func (m *StartStream) Reset()

func (*StartStream) String 

func (m *StartStream) String() string

func (*StartStream) XXX_DiscardUnknown 

func (m *StartStream) XXX_DiscardUnknown()

func (*StartStream) XXX_Marshal 

func (m *StartStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartStream) XXX_Merge 

func (dst *StartStream) XXX_Merge(src proto.Message)

func (*StartStream) XXX_Size 

func (m *StartStream) XXX_Size() int

func (*StartStream) XXX_Unmarshal 

func (m *StartStream) XXX_Unmarshal(b []byte) error

type StatusResult 

type StatusResult struct {
	// Status for the given result
	Status StatusResult_Status `protobuf:"varint,4,opt,name=status,proto3,enum=AzureFunctionsRpcMessages.StatusResult_Status" json:"status,omitempty"`
	// Specific message about the result
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// Exception message (if exists) for the status
	Exception *RpcException `protobuf:"bytes,2,opt,name=exception,proto3" json:"exception,omitempty"`
	// Captured logs or relevant details can use the logs property
	Logs                 []*RpcLog `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Used by the host to determine success/failure/cancellation

func (*StatusResult) Descriptor 

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

func (*StatusResult) GetException 

func (m *StatusResult) GetException() *RpcException

func (*StatusResult) GetLogs 

func (m *StatusResult) GetLogs() []*RpcLog

func (*StatusResult) GetResult 

func (m *StatusResult) GetResult() string

func (*StatusResult) GetStatus 

func (m *StatusResult) GetStatus() StatusResult_Status

func (*StatusResult) ProtoMessage 

func (*StatusResult) ProtoMessage()

func (*StatusResult) Reset 

func (m *StatusResult) Reset()

func (*StatusResult) String 

func (m *StatusResult) String() string

func (*StatusResult) XXX_DiscardUnknown 

func (m *StatusResult) XXX_DiscardUnknown()

func (*StatusResult) XXX_Marshal 

func (m *StatusResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatusResult) XXX_Merge 

func (dst *StatusResult) XXX_Merge(src proto.Message)

func (*StatusResult) XXX_Size 

func (m *StatusResult) XXX_Size() int

func (*StatusResult) XXX_Unmarshal 

func (m *StatusResult) XXX_Unmarshal(b []byte) error

type StatusResult_Status 

type StatusResult_Status int32

Indicates Failure/Success/Cancelled 

const (
	StatusResult_Failure   StatusResult_Status = 0
	StatusResult_Success   StatusResult_Status = 1
	StatusResult_Cancelled StatusResult_Status = 2
)

func (StatusResult_Status) EnumDescriptor 

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

func (StatusResult_Status) String 

func (x StatusResult_Status) String() string

type StreamingMessage 

type StreamingMessage struct {
	// Used to identify message between host and worker
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Payload of the message
	//
	// Types that are valid to be assigned to Content:
	//	*StreamingMessage_StartStream
	//	*StreamingMessage_WorkerInitRequest
	//	*StreamingMessage_WorkerInitResponse
	//	*StreamingMessage_WorkerHeartbeat
	//	*StreamingMessage_WorkerTerminate
	//	*StreamingMessage_WorkerStatusRequest
	//	*StreamingMessage_WorkerStatusResponse
	//	*StreamingMessage_FileChangeEventRequest
	//	*StreamingMessage_WorkerActionResponse
	//	*StreamingMessage_FunctionLoadRequest
	//	*StreamingMessage_FunctionLoadResponse
	//	*StreamingMessage_InvocationRequest
	//	*StreamingMessage_InvocationResponse
	//	*StreamingMessage_InvocationCancel
	//	*StreamingMessage_RpcLog
	Content              isStreamingMessage_Content `protobuf_oneof:"content"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*StreamingMessage) Descriptor 

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

func (*StreamingMessage) GetContent 

func (m *StreamingMessage) GetContent() isStreamingMessage_Content

func (*StreamingMessage) GetFileChangeEventRequest 

func (m *StreamingMessage) GetFileChangeEventRequest() *FileChangeEventRequest

func (*StreamingMessage) GetFunctionLoadRequest 

func (m *StreamingMessage) GetFunctionLoadRequest() *FunctionLoadRequest

func (*StreamingMessage) GetFunctionLoadResponse 

func (m *StreamingMessage) GetFunctionLoadResponse() *FunctionLoadResponse

func (*StreamingMessage) GetInvocationCancel 

func (m *StreamingMessage) GetInvocationCancel() *InvocationCancel

func (*StreamingMessage) GetInvocationRequest 

func (m *StreamingMessage) GetInvocationRequest() *InvocationRequest

func (*StreamingMessage) GetInvocationResponse 

func (m *StreamingMessage) GetInvocationResponse() *InvocationResponse

func (*StreamingMessage) GetRequestId 

func (m *StreamingMessage) GetRequestId() string

func (*StreamingMessage) GetRpcLog 

func (m *StreamingMessage) GetRpcLog() *RpcLog

func (*StreamingMessage) GetStartStream 

func (m *StreamingMessage) GetStartStream() *StartStream

func (*StreamingMessage) GetWorkerActionResponse 

func (m *StreamingMessage) GetWorkerActionResponse() *WorkerActionResponse

func (*StreamingMessage) GetWorkerHeartbeat 

func (m *StreamingMessage) GetWorkerHeartbeat() *WorkerHeartbeat

func (*StreamingMessage) GetWorkerInitRequest 

func (m *StreamingMessage) GetWorkerInitRequest() *WorkerInitRequest

func (*StreamingMessage) GetWorkerInitResponse 

func (m *StreamingMessage) GetWorkerInitResponse() *WorkerInitResponse

func (*StreamingMessage) GetWorkerStatusRequest 

func (m *StreamingMessage) GetWorkerStatusRequest() *WorkerStatusRequest

func (*StreamingMessage) GetWorkerStatusResponse 

func (m *StreamingMessage) GetWorkerStatusResponse() *WorkerStatusResponse

func (*StreamingMessage) GetWorkerTerminate 

func (m *StreamingMessage) GetWorkerTerminate() *WorkerTerminate

func (*StreamingMessage) ProtoMessage 

func (*StreamingMessage) ProtoMessage()

func (*StreamingMessage) Reset 

func (m *StreamingMessage) Reset()

func (*StreamingMessage) String 

func (m *StreamingMessage) String() string

func (*StreamingMessage) XXX_DiscardUnknown 

func (m *StreamingMessage) XXX_DiscardUnknown()

func (*StreamingMessage) XXX_Marshal 

func (m *StreamingMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamingMessage) XXX_Merge 

func (dst *StreamingMessage) XXX_Merge(src proto.Message)

func (*StreamingMessage) XXX_OneofFuncs 

func (*StreamingMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*StreamingMessage) XXX_Size 

func (m *StreamingMessage) XXX_Size() int

func (*StreamingMessage) XXX_Unmarshal 

func (m *StreamingMessage) XXX_Unmarshal(b []byte) error

type StreamingMessage_FileChangeEventRequest 

type StreamingMessage_FileChangeEventRequest struct {
	FileChangeEventRequest *FileChangeEventRequest `protobuf:"bytes,6,opt,name=file_change_event_request,json=fileChangeEventRequest,proto3,oneof"`
}

type StreamingMessage_FunctionLoadRequest 

type StreamingMessage_FunctionLoadRequest struct {
	FunctionLoadRequest *FunctionLoadRequest `protobuf:"bytes,8,opt,name=function_load_request,json=functionLoadRequest,proto3,oneof"`
}

type StreamingMessage_FunctionLoadResponse 

type StreamingMessage_FunctionLoadResponse struct {
	FunctionLoadResponse *FunctionLoadResponse `protobuf:"bytes,9,opt,name=function_load_response,json=functionLoadResponse,proto3,oneof"`
}

type StreamingMessage_InvocationCancel 

type StreamingMessage_InvocationCancel struct {
	InvocationCancel *InvocationCancel `protobuf:"bytes,21,opt,name=invocation_cancel,json=invocationCancel,proto3,oneof"`
}

type StreamingMessage_InvocationRequest 

type StreamingMessage_InvocationRequest struct {
	InvocationRequest *InvocationRequest `protobuf:"bytes,4,opt,name=invocation_request,json=invocationRequest,proto3,oneof"`
}

type StreamingMessage_InvocationResponse 

type StreamingMessage_InvocationResponse struct {
	InvocationResponse *InvocationResponse `protobuf:"bytes,5,opt,name=invocation_response,json=invocationResponse,proto3,oneof"`
}

type StreamingMessage_RpcLog 

type StreamingMessage_RpcLog struct {
	RpcLog *RpcLog `protobuf:"bytes,2,opt,name=rpc_log,json=rpcLog,proto3,oneof"`
}

type StreamingMessage_StartStream 

type StreamingMessage_StartStream struct {
	StartStream *StartStream `protobuf:"bytes,20,opt,name=start_stream,json=startStream,proto3,oneof"`
}

type StreamingMessage_WorkerActionResponse 

type StreamingMessage_WorkerActionResponse struct {
	WorkerActionResponse *WorkerActionResponse `protobuf:"bytes,7,opt,name=worker_action_response,json=workerActionResponse,proto3,oneof"`
}

type StreamingMessage_WorkerHeartbeat 

type StreamingMessage_WorkerHeartbeat struct {
	WorkerHeartbeat *WorkerHeartbeat `protobuf:"bytes,15,opt,name=worker_heartbeat,json=workerHeartbeat,proto3,oneof"`
}

type StreamingMessage_WorkerInitRequest 

type StreamingMessage_WorkerInitRequest struct {
	WorkerInitRequest *WorkerInitRequest `protobuf:"bytes,17,opt,name=worker_init_request,json=workerInitRequest,proto3,oneof"`
}

type StreamingMessage_WorkerInitResponse 

type StreamingMessage_WorkerInitResponse struct {
	WorkerInitResponse *WorkerInitResponse `protobuf:"bytes,16,opt,name=worker_init_response,json=workerInitResponse,proto3,oneof"`
}

type StreamingMessage_WorkerStatusRequest 

type StreamingMessage_WorkerStatusRequest struct {
	WorkerStatusRequest *WorkerStatusRequest `protobuf:"bytes,12,opt,name=worker_status_request,json=workerStatusRequest,proto3,oneof"`
}

type StreamingMessage_WorkerStatusResponse 

type StreamingMessage_WorkerStatusResponse struct {
	WorkerStatusResponse *WorkerStatusResponse `protobuf:"bytes,13,opt,name=worker_status_response,json=workerStatusResponse,proto3,oneof"`
}

type StreamingMessage_WorkerTerminate 

type StreamingMessage_WorkerTerminate struct {
	WorkerTerminate *WorkerTerminate `protobuf:"bytes,14,opt,name=worker_terminate,json=workerTerminate,proto3,oneof"`
}

type TypedData 

type TypedData struct {
	// Types that are valid to be assigned to Data:
	//	*TypedData_String_
	//	*TypedData_Json
	//	*TypedData_Bytes
	//	*TypedData_Stream
	//	*TypedData_Http
	//	*TypedData_Int
	//	*TypedData_Double
	Data                 isTypedData_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Used to encapsulate data which could be a variety of types

func (*TypedData) Descriptor 

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

func (*TypedData) GetBytes 

func (m *TypedData) GetBytes() []byte

func (*TypedData) GetData 

func (m *TypedData) GetData() isTypedData_Data

func (*TypedData) GetDouble 

func (m *TypedData) GetDouble() float64

func (*TypedData) GetHttp 

func (m *TypedData) GetHttp() *RpcHttp

func (*TypedData) GetInt 

func (m *TypedData) GetInt() int64

func (*TypedData) GetJson 

func (m *TypedData) GetJson() string

func (*TypedData) GetStream 

func (m *TypedData) GetStream() []byte

func (*TypedData) GetString_ 

func (m *TypedData) GetString_() string

func (*TypedData) ProtoMessage 

func (*TypedData) ProtoMessage()

func (*TypedData) Reset 

func (m *TypedData) Reset()

func (*TypedData) String 

func (m *TypedData) String() string

func (*TypedData) XXX_DiscardUnknown 

func (m *TypedData) XXX_DiscardUnknown()

func (*TypedData) XXX_Marshal 

func (m *TypedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TypedData) XXX_Merge 

func (dst *TypedData) XXX_Merge(src proto.Message)

func (*TypedData) XXX_OneofFuncs 

func (*TypedData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TypedData) XXX_Size 

func (m *TypedData) XXX_Size() int

func (*TypedData) XXX_Unmarshal 

func (m *TypedData) XXX_Unmarshal(b []byte) error

type TypedData_Bytes 

type TypedData_Bytes struct {
	Bytes []byte `protobuf:"bytes,3,opt,name=bytes,proto3,oneof"`
}

type TypedData_Double 

type TypedData_Double struct {
	Double float64 `protobuf:"fixed64,7,opt,name=double,proto3,oneof"`
}

type TypedData_Http 

type TypedData_Http struct {
	Http *RpcHttp `protobuf:"bytes,5,opt,name=http,proto3,oneof"`
}

type TypedData_Int 

type TypedData_Int struct {
	Int int64 `protobuf:"zigzag64,6,opt,name=int,proto3,oneof"`
}

type TypedData_Json 

type TypedData_Json struct {
	Json string `protobuf:"bytes,2,opt,name=json,proto3,oneof"`
}

type TypedData_Stream 

type TypedData_Stream struct {
	Stream []byte `protobuf:"bytes,4,opt,name=stream,proto3,oneof"`
}

type TypedData_String_ 

type TypedData_String_ struct {
	String_ string `protobuf:"bytes,1,opt,name=string,proto3,oneof"`
}

type WorkerActionResponse 

type WorkerActionResponse struct {
	// action for this response
	Action WorkerActionResponse_Action `protobuf:"varint,1,opt,name=action,proto3,enum=AzureFunctionsRpcMessages.WorkerActionResponse_Action" json:"action,omitempty"`
	// text reason for the response
	Reason               string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Indicates whether worker reloaded successfully or needs a restart

func (*WorkerActionResponse) Descriptor 

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

func (*WorkerActionResponse) GetAction 

func (m *WorkerActionResponse) GetAction() WorkerActionResponse_Action

func (*WorkerActionResponse) GetReason 

func (m *WorkerActionResponse) GetReason() string

func (*WorkerActionResponse) ProtoMessage 

func (*WorkerActionResponse) ProtoMessage()

func (*WorkerActionResponse) Reset 

func (m *WorkerActionResponse) Reset()

func (*WorkerActionResponse) String 

func (m *WorkerActionResponse) String() string

func (*WorkerActionResponse) XXX_DiscardUnknown 

func (m *WorkerActionResponse) XXX_DiscardUnknown()

func (*WorkerActionResponse) XXX_Marshal 

func (m *WorkerActionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerActionResponse) XXX_Merge 

func (dst *WorkerActionResponse) XXX_Merge(src proto.Message)

func (*WorkerActionResponse) XXX_Size 

func (m *WorkerActionResponse) XXX_Size() int

func (*WorkerActionResponse) XXX_Unmarshal 

func (m *WorkerActionResponse) XXX_Unmarshal(b []byte) error

type WorkerActionResponse_Action 

type WorkerActionResponse_Action int32

indicates whether a restart is needed, or reload succesfully 

const (
	WorkerActionResponse_Restart WorkerActionResponse_Action = 0
	WorkerActionResponse_Reload  WorkerActionResponse_Action = 1
)

func (WorkerActionResponse_Action) EnumDescriptor 

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

func (WorkerActionResponse_Action) String 

func (x WorkerActionResponse_Action) String() string

type WorkerHeartbeat 

type WorkerHeartbeat struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message is empty by design - Will add more fields in future if needed

func (*WorkerHeartbeat) Descriptor 

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

func (*WorkerHeartbeat) ProtoMessage 

func (*WorkerHeartbeat) ProtoMessage()

func (*WorkerHeartbeat) Reset 

func (m *WorkerHeartbeat) Reset()

func (*WorkerHeartbeat) String 

func (m *WorkerHeartbeat) String() string

func (*WorkerHeartbeat) XXX_DiscardUnknown 

func (m *WorkerHeartbeat) XXX_DiscardUnknown()

func (*WorkerHeartbeat) XXX_Marshal 

func (m *WorkerHeartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerHeartbeat) XXX_Merge 

func (dst *WorkerHeartbeat) XXX_Merge(src proto.Message)

func (*WorkerHeartbeat) XXX_Size 

func (m *WorkerHeartbeat) XXX_Size() int

func (*WorkerHeartbeat) XXX_Unmarshal 

func (m *WorkerHeartbeat) XXX_Unmarshal(b []byte) error

type WorkerInitRequest 

type WorkerInitRequest struct {
	// version of the host sending init request
	HostVersion string `protobuf:"bytes,1,opt,name=host_version,json=hostVersion,proto3" json:"host_version,omitempty"`
	// A map of host supported features/capabilities
	Capabilities map[string]string `` /* 165-byte string literal not displayed */
	// inform worker of supported categories and their levels
	// i.e. Worker = Verbose, Function.MyFunc = None
	LogCategories        map[string]RpcLog_Level `` /* 233-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Host requests the worker to initialize itself

func (*WorkerInitRequest) Descriptor 

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

func (*WorkerInitRequest) GetCapabilities 

func (m *WorkerInitRequest) GetCapabilities() map[string]string

func (*WorkerInitRequest) GetHostVersion 

func (m *WorkerInitRequest) GetHostVersion() string

func (*WorkerInitRequest) GetLogCategories 

func (m *WorkerInitRequest) GetLogCategories() map[string]RpcLog_Level

func (*WorkerInitRequest) ProtoMessage 

func (*WorkerInitRequest) ProtoMessage()

func (*WorkerInitRequest) Reset 

func (m *WorkerInitRequest) Reset()

func (*WorkerInitRequest) String 

func (m *WorkerInitRequest) String() string

func (*WorkerInitRequest) XXX_DiscardUnknown 

func (m *WorkerInitRequest) XXX_DiscardUnknown()

func (*WorkerInitRequest) XXX_Marshal 

func (m *WorkerInitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerInitRequest) XXX_Merge 

func (dst *WorkerInitRequest) XXX_Merge(src proto.Message)

func (*WorkerInitRequest) XXX_Size 

func (m *WorkerInitRequest) XXX_Size() int

func (*WorkerInitRequest) XXX_Unmarshal 

func (m *WorkerInitRequest) XXX_Unmarshal(b []byte) error

type WorkerInitResponse 

type WorkerInitResponse struct {
	// Version of worker
	WorkerVersion string `protobuf:"bytes,1,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,omitempty"`
	// A map of worker supported features/capabilities
	Capabilities map[string]string `` /* 165-byte string literal not displayed */
	// Status of the response
	Result               *StatusResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Worker responds with the result of initializing itself

func (*WorkerInitResponse) Descriptor 

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

func (*WorkerInitResponse) GetCapabilities 

func (m *WorkerInitResponse) GetCapabilities() map[string]string

func (*WorkerInitResponse) GetResult 

func (m *WorkerInitResponse) GetResult() *StatusResult

func (*WorkerInitResponse) GetWorkerVersion 

func (m *WorkerInitResponse) GetWorkerVersion() string

func (*WorkerInitResponse) ProtoMessage 

func (*WorkerInitResponse) ProtoMessage()

func (*WorkerInitResponse) Reset 

func (m *WorkerInitResponse) Reset()

func (*WorkerInitResponse) String 

func (m *WorkerInitResponse) String() string

func (*WorkerInitResponse) XXX_DiscardUnknown 

func (m *WorkerInitResponse) XXX_DiscardUnknown()

func (*WorkerInitResponse) XXX_Marshal 

func (m *WorkerInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerInitResponse) XXX_Merge 

func (dst *WorkerInitResponse) XXX_Merge(src proto.Message)

func (*WorkerInitResponse) XXX_Size 

func (m *WorkerInitResponse) XXX_Size() int

func (*WorkerInitResponse) XXX_Unmarshal 

func (m *WorkerInitResponse) XXX_Unmarshal(b []byte) error

type WorkerStatusRequest 

type WorkerStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NOT USED

func (*WorkerStatusRequest) Descriptor 

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

func (*WorkerStatusRequest) ProtoMessage 

func (*WorkerStatusRequest) ProtoMessage()

func (*WorkerStatusRequest) Reset 

func (m *WorkerStatusRequest) Reset()

func (*WorkerStatusRequest) String 

func (m *WorkerStatusRequest) String() string

func (*WorkerStatusRequest) XXX_DiscardUnknown 

func (m *WorkerStatusRequest) XXX_DiscardUnknown()

func (*WorkerStatusRequest) XXX_Marshal 

func (m *WorkerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerStatusRequest) XXX_Merge 

func (dst *WorkerStatusRequest) XXX_Merge(src proto.Message)

func (*WorkerStatusRequest) XXX_Size 

func (m *WorkerStatusRequest) XXX_Size() int

func (*WorkerStatusRequest) XXX_Unmarshal 

func (m *WorkerStatusRequest) XXX_Unmarshal(b []byte) error

type WorkerStatusResponse 

type WorkerStatusResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NOT USED

func (*WorkerStatusResponse) Descriptor 

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

func (*WorkerStatusResponse) ProtoMessage 

func (*WorkerStatusResponse) ProtoMessage()

func (*WorkerStatusResponse) Reset 

func (m *WorkerStatusResponse) Reset()

func (*WorkerStatusResponse) String 

func (m *WorkerStatusResponse) String() string

func (*WorkerStatusResponse) XXX_DiscardUnknown 

func (m *WorkerStatusResponse) XXX_DiscardUnknown()

func (*WorkerStatusResponse) XXX_Marshal 

func (m *WorkerStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerStatusResponse) XXX_Merge 

func (dst *WorkerStatusResponse) XXX_Merge(src proto.Message)

func (*WorkerStatusResponse) XXX_Size 

func (m *WorkerStatusResponse) XXX_Size() int

func (*WorkerStatusResponse) XXX_Unmarshal 

func (m *WorkerStatusResponse) XXX_Unmarshal(b []byte) error

type WorkerTerminate 

type WorkerTerminate struct {
	GracePeriod          *duration.Duration `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Warning before killing the process after grace_period Worker self terminates ..no response on this

func (*WorkerTerminate) Descriptor 

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

func (*WorkerTerminate) GetGracePeriod 

func (m *WorkerTerminate) GetGracePeriod() *duration.Duration

func (*WorkerTerminate) ProtoMessage 

func (*WorkerTerminate) ProtoMessage()

func (*WorkerTerminate) Reset 

func (m *WorkerTerminate) Reset()

func (*WorkerTerminate) String 

func (m *WorkerTerminate) String() string

func (*WorkerTerminate) XXX_DiscardUnknown 

func (m *WorkerTerminate) XXX_DiscardUnknown()

func (*WorkerTerminate) XXX_Marshal 

func (m *WorkerTerminate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerTerminate) XXX_Merge 

func (dst *WorkerTerminate) XXX_Merge(src proto.Message)

func (*WorkerTerminate) XXX_Size 

func (m *WorkerTerminate) XXX_Size() int

func (*WorkerTerminate) XXX_Unmarshal 

func (m *WorkerTerminate) XXX_Unmarshal(b []byte) error

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.