rpc

type BindingInfo struct {
	Type      string                `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	Direction BindingInfo_Direction `protobuf:"varint,3,opt,name=direction,enum=FunctionRpc.BindingInfo_Direction" json:"direction,omitempty"`
}

type BindingInfo_Direction int32

type FileChangeEventRequest struct {
	Type     FileChangeEventRequest_Type `protobuf:"varint,1,opt,name=type,enum=FunctionRpc.FileChangeEventRequest_Type" json:"type,omitempty"`
	FullPath string                      `protobuf:"bytes,2,opt,name=full_path,json=fullPath" json:"full_path,omitempty"`
	Name     string                      `protobuf:"bytes,3,opt,name=name" json:"name,omitempty"`
}

type FileChangeEventRequest_Type int32

type FunctionLoadRequest struct {
	// unique function identifier (avoid name collisions, facilitate reload case)
	FunctionId string               `protobuf:"bytes,1,opt,name=function_id,json=functionId" json:"function_id,omitempty"`
	Metadata   *RpcFunctionMetadata `protobuf:"bytes,2,opt,name=metadata" json:"metadata,omitempty"`
}

type FunctionLoadResponse struct {
	FunctionId string        `protobuf:"bytes,1,opt,name=function_id,json=functionId" json:"function_id,omitempty"`
	Result     *StatusResult `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"`
}

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

type FunctionRpcServer interface {
	EventStream(FunctionRpc_EventStreamServer) error
}

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

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

type InvocationCancel struct {
	InvocationId string                    `protobuf:"bytes,2,opt,name=invocation_id,json=invocationId" json:"invocation_id,omitempty"`
	GracePeriod  *google_protobuf.Duration `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod" json:"grace_period,omitempty"`
}

type InvocationRequest struct {
	InvocationId    string                `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId" json:"invocation_id,omitempty"`
	FunctionId      string                `protobuf:"bytes,2,opt,name=function_id,json=functionId" json:"function_id,omitempty"`
	InputData       []*ParameterBinding   `protobuf:"bytes,3,rep,name=input_data,json=inputData" json:"input_data,omitempty"`
	TriggerMetadata map[string]*TypedData `` /* 173-byte string literal not displayed */
}

type InvocationResponse struct {
	InvocationId string              `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId" json:"invocation_id,omitempty"`
	OutputData   []*ParameterBinding `protobuf:"bytes,2,rep,name=output_data,json=outputData" json:"output_data,omitempty"`
	ReturnValue  *TypedData          `protobuf:"bytes,4,opt,name=return_value,json=returnValue" json:"return_value,omitempty"`
	Result       *StatusResult       `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

type ParameterBinding struct {
	Name string     `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Data *TypedData `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

type RpcException struct {
	Source     string `protobuf:"bytes,3,opt,name=source" json:"source,omitempty"`
	StackTrace string `protobuf:"bytes,1,opt,name=stack_trace,json=stackTrace" json:"stack_trace,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

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" json:"name,omitempty"`
	Directory  string                  `protobuf:"bytes,1,opt,name=directory" json:"directory,omitempty"`
	ScriptFile string                  `protobuf:"bytes,2,opt,name=script_file,json=scriptFile" json:"script_file,omitempty"`
	EntryPoint string                  `protobuf:"bytes,3,opt,name=entry_point,json=entryPoint" json:"entry_point,omitempty"`
	Bindings   map[string]*BindingInfo `` /* 136-byte string literal not displayed */
}

type RpcHttp struct {
	Method     string            `protobuf:"bytes,1,opt,name=method" json:"method,omitempty"`
	Url        string            `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
	Headers    map[string]string `` /* 134-byte string literal not displayed */
	Body       *TypedData        `protobuf:"bytes,4,opt,name=body" json:"body,omitempty"`
	Params     map[string]string `` /* 133-byte string literal not displayed */
	StatusCode string            `protobuf:"bytes,12,opt,name=status_code,json=statusCode" json:"status_code,omitempty"`
	Query      map[string]string `` /* 131-byte string literal not displayed */
	IsRaw      bool              `protobuf:"varint,16,opt,name=is_raw,json=isRaw" json:"is_raw,omitempty"`
}

type RpcLog struct {
	InvocationId string        `protobuf:"bytes,1,opt,name=invocation_id,json=invocationId" json:"invocation_id,omitempty"`
	Category     string        `protobuf:"bytes,2,opt,name=category" json:"category,omitempty"`
	Level        RpcLog_Level  `protobuf:"varint,3,opt,name=level,enum=FunctionRpc.RpcLog_Level" json:"level,omitempty"`
	Message      string        `protobuf:"bytes,4,opt,name=message" json:"message,omitempty"`
	EventId      string        `protobuf:"bytes,5,opt,name=event_id,json=eventId" json:"event_id,omitempty"`
	Exception    *RpcException `protobuf:"bytes,6,opt,name=exception" 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" json:"properties,omitempty"`
}

type RpcLog_Level int32

type StartStream struct {
	WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId" json:"worker_id,omitempty"`
}

type StatusResult struct {
	Status    StatusResult_Status `protobuf:"varint,4,opt,name=status,enum=FunctionRpc.StatusResult_Status" json:"status,omitempty"`
	Result    string              `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
	Exception *RpcException       `protobuf:"bytes,2,opt,name=exception" json:"exception,omitempty"`
	// Captured logs or relevant details can use the logs property
	Logs []*RpcLog `protobuf:"bytes,3,rep,name=logs" json:"logs,omitempty"`
}

type StatusResult_Status int32

type StreamingMessage struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId" json:"request_id,omitempty"`
	// 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"`
}

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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"`
}

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

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

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

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

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

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

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

type WorkerActionResponse struct {
	Action WorkerActionResponse_Action `protobuf:"varint,1,opt,name=action,enum=FunctionRpc.WorkerActionResponse_Action" json:"action,omitempty"`
	Reason string                      `protobuf:"bytes,2,opt,name=reason" json:"reason,omitempty"`
}

type WorkerActionResponse_Action int32

type WorkerHeartbeat struct {
}

type WorkerInitRequest struct {
	HostVersion string `protobuf:"bytes,1,opt,name=host_version,json=hostVersion" json:"host_version,omitempty"`
	// A map of host supported features/capabilities
	Capabilities map[string]string `` /* 144-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 `` /* 198-byte string literal not displayed */
}

type WorkerInitResponse struct {
	WorkerVersion string `protobuf:"bytes,1,opt,name=worker_version,json=workerVersion" json:"worker_version,omitempty"`
	// A map of worker supported features/capabilities
	Capabilities map[string]string `` /* 144-byte string literal not displayed */
	Result       *StatusResult     `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

type WorkerStatusRequest struct {
}

type WorkerStatusResponse struct {
}

type WorkerTerminate struct {
	GracePeriod *google_protobuf.Duration `protobuf:"bytes,1,opt,name=grace_period,json=gracePeriod" json:"grace_period,omitempty"`
}