Documentation ¶
Index ¶
- Variables
- func RegisterFSReconcileServer(s grpc.ServiceRegistrar, srv FSReconcileServer)
- func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)
- type ConnectRequest
- type Event
- type FSReconcileClient
- type FSReconcileServer
- type FSReconcile_ReconcileClient
- type FSReconcile_ReconcileServer
- type FunctionClient
- type FunctionProcessRequest
- func (*FunctionProcessRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionProcessRequest) GetName() string
- func (*FunctionProcessRequest) ProtoMessage()
- func (x *FunctionProcessRequest) ProtoReflect() protoreflect.Message
- func (x *FunctionProcessRequest) Reset()
- func (x *FunctionProcessRequest) String() string
- type FunctionServer
- type FunctionStatus
- func (*FunctionStatus) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionStatus) GetDetails() string
- func (x *FunctionStatus) GetName() string
- func (x *FunctionStatus) GetStatus() FunctionStatus_Status
- func (*FunctionStatus) ProtoMessage()
- func (x *FunctionStatus) ProtoReflect() protoreflect.Message
- func (x *FunctionStatus) Reset()
- func (x *FunctionStatus) String() string
- type FunctionStatus_Status
- func (FunctionStatus_Status) Descriptor() protoreflect.EnumDescriptor
- func (x FunctionStatus_Status) Enum() *FunctionStatus_Status
- func (FunctionStatus_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x FunctionStatus_Status) Number() protoreflect.EnumNumber
- func (x FunctionStatus_Status) String() string
- func (FunctionStatus_Status) Type() protoreflect.EnumType
- type Function_ProcessClient
- type Function_ProcessServer
- type GetStateRequest
- type GetStateResponse
- func (*GetStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateResponse) GetResponse() *Response
- func (x *GetStateResponse) GetValue() []byte
- func (*GetStateResponse) ProtoMessage()
- func (x *GetStateResponse) ProtoReflect() protoreflect.Message
- func (x *GetStateResponse) Reset()
- func (x *GetStateResponse) String() string
- type PutStateRequest
- func (*PutStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PutStateRequest) GetKey() string
- func (x *PutStateRequest) GetValue() []byte
- func (*PutStateRequest) ProtoMessage()
- func (x *PutStateRequest) ProtoReflect() protoreflect.Message
- func (x *PutStateRequest) Reset()
- func (x *PutStateRequest) String() string
- type Response
- type Response_Status
- func (Response_Status) Descriptor() protoreflect.EnumDescriptor
- func (x Response_Status) Enum() *Response_Status
- func (Response_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x Response_Status) Number() protoreflect.EnumNumber
- func (x Response_Status) String() string
- func (Response_Status) Type() protoreflect.EnumType
- type UnimplementedFSReconcileServer
- type UnimplementedFunctionServer
- func (UnimplementedFunctionServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
- func (UnimplementedFunctionServer) Output(context.Context, *Event) (*Response, error)
- func (UnimplementedFunctionServer) Process(*FunctionProcessRequest, Function_ProcessServer) error
- func (UnimplementedFunctionServer) PutState(context.Context, *PutStateRequest) (*Response, error)
- type UnsafeFSReconcileServer
- type UnsafeFunctionServer
Constants ¶
This section is empty.
Variables ¶
var ( Response_Status_name = map[int32]string{ 0: "OK", 1: "ERROR", } Response_Status_value = map[string]int32{ "OK": 0, "ERROR": 1, } )
Enum value maps for Response_Status.
var ( FunctionStatus_Status_name = map[int32]string{ 0: "CREATING", 1: "RUNNING", 2: "DELETING", 3: "DELETED", 4: "FAILED", } FunctionStatus_Status_value = map[string]int32{ "CREATING": 0, "RUNNING": 1, "DELETING": 2, "DELETED": 3, "FAILED": 4, } )
Enum value maps for FunctionStatus_Status.
var FSReconcile_ServiceDesc = grpc.ServiceDesc{ ServiceName: "fs_func.FSReconcile", HandlerType: (*FSReconcileServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateStatus", Handler: _FSReconcile_UpdateStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Reconcile", Handler: _FSReconcile_Reconcile_Handler, ServerStreams: true, }, }, Metadata: "fs/runtime/grpc/proto/grpc_func.proto", }
FSReconcile_ServiceDesc is the grpc.ServiceDesc for FSReconcile service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_fs_runtime_grpc_proto_grpc_func_proto protoreflect.FileDescriptor
var Function_ServiceDesc = grpc.ServiceDesc{ ServiceName: "fs_func.Function", HandlerType: (*FunctionServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Output", Handler: _Function_Output_Handler, }, { MethodName: "PutState", Handler: _Function_PutState_Handler, }, { MethodName: "GetState", Handler: _Function_GetState_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Process", Handler: _Function_Process_Handler, ServerStreams: true, }, }, Metadata: "fs/runtime/grpc/proto/grpc_func.proto", }
Function_ServiceDesc is the grpc.ServiceDesc for Function service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFSReconcileServer ¶
func RegisterFSReconcileServer(s grpc.ServiceRegistrar, srv FSReconcileServer)
func RegisterFunctionServer ¶
func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)
Types ¶
type ConnectRequest ¶
type ConnectRequest struct {
// contains filtered or unexported fields
}
func (*ConnectRequest) Descriptor
deprecated
func (*ConnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) ProtoReflect ¶
func (x *ConnectRequest) ProtoReflect() protoreflect.Message
func (*ConnectRequest) Reset ¶
func (x *ConnectRequest) Reset()
func (*ConnectRequest) String ¶
func (x *ConnectRequest) String() string
type Event ¶
type Event struct { Payload string `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
The request message for the Process method.
func (*Event) Descriptor
deprecated
func (*Event) GetPayload ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type FSReconcileClient ¶
type FSReconcileClient interface { Reconcile(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (FSReconcile_ReconcileClient, error) UpdateStatus(ctx context.Context, in *FunctionStatus, opts ...grpc.CallOption) (*Response, error) }
FSReconcileClient is the client API for FSReconcile service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFSReconcileClient ¶
func NewFSReconcileClient(cc grpc.ClientConnInterface) FSReconcileClient
type FSReconcileServer ¶
type FSReconcileServer interface { Reconcile(*ConnectRequest, FSReconcile_ReconcileServer) error UpdateStatus(context.Context, *FunctionStatus) (*Response, error) // contains filtered or unexported methods }
FSReconcileServer is the server API for FSReconcile service. All implementations must embed UnimplementedFSReconcileServer for forward compatibility
type FSReconcile_ReconcileClient ¶
type FSReconcile_ReconcileClient interface { Recv() (*FunctionStatus, error) grpc.ClientStream }
type FSReconcile_ReconcileServer ¶
type FSReconcile_ReconcileServer interface { Send(*FunctionStatus) error grpc.ServerStream }
type FunctionClient ¶
type FunctionClient interface { Process(ctx context.Context, in *FunctionProcessRequest, opts ...grpc.CallOption) (Function_ProcessClient, error) Output(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Response, error) PutState(ctx context.Context, in *PutStateRequest, opts ...grpc.CallOption) (*Response, error) GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error) }
FunctionClient is the client API for Function service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFunctionClient ¶
func NewFunctionClient(cc grpc.ClientConnInterface) FunctionClient
type FunctionProcessRequest ¶
type FunctionProcessRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*FunctionProcessRequest) Descriptor
deprecated
func (*FunctionProcessRequest) Descriptor() ([]byte, []int)
Deprecated: Use FunctionProcessRequest.ProtoReflect.Descriptor instead.
func (*FunctionProcessRequest) GetName ¶
func (x *FunctionProcessRequest) GetName() string
func (*FunctionProcessRequest) ProtoMessage ¶
func (*FunctionProcessRequest) ProtoMessage()
func (*FunctionProcessRequest) ProtoReflect ¶
func (x *FunctionProcessRequest) ProtoReflect() protoreflect.Message
func (*FunctionProcessRequest) Reset ¶
func (x *FunctionProcessRequest) Reset()
func (*FunctionProcessRequest) String ¶
func (x *FunctionProcessRequest) String() string
type FunctionServer ¶
type FunctionServer interface { Process(*FunctionProcessRequest, Function_ProcessServer) error Output(context.Context, *Event) (*Response, error) PutState(context.Context, *PutStateRequest) (*Response, error) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error) // contains filtered or unexported methods }
FunctionServer is the server API for Function service. All implementations must embed UnimplementedFunctionServer for forward compatibility
type FunctionStatus ¶
type FunctionStatus struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Status FunctionStatus_Status `protobuf:"varint,2,opt,name=status,proto3,enum=fs_func.FunctionStatus_Status" json:"status,omitempty"` Details *string `protobuf:"bytes,3,opt,name=details,proto3,oneof" json:"details,omitempty"` // contains filtered or unexported fields }
func (*FunctionStatus) Descriptor
deprecated
func (*FunctionStatus) Descriptor() ([]byte, []int)
Deprecated: Use FunctionStatus.ProtoReflect.Descriptor instead.
func (*FunctionStatus) GetDetails ¶
func (x *FunctionStatus) GetDetails() string
func (*FunctionStatus) GetName ¶
func (x *FunctionStatus) GetName() string
func (*FunctionStatus) GetStatus ¶
func (x *FunctionStatus) GetStatus() FunctionStatus_Status
func (*FunctionStatus) ProtoMessage ¶
func (*FunctionStatus) ProtoMessage()
func (*FunctionStatus) ProtoReflect ¶
func (x *FunctionStatus) ProtoReflect() protoreflect.Message
func (*FunctionStatus) Reset ¶
func (x *FunctionStatus) Reset()
func (*FunctionStatus) String ¶
func (x *FunctionStatus) String() string
type FunctionStatus_Status ¶
type FunctionStatus_Status int32
const ( FunctionStatus_CREATING FunctionStatus_Status = 0 FunctionStatus_RUNNING FunctionStatus_Status = 1 FunctionStatus_DELETING FunctionStatus_Status = 2 FunctionStatus_DELETED FunctionStatus_Status = 3 FunctionStatus_FAILED FunctionStatus_Status = 4 )
func (FunctionStatus_Status) Descriptor ¶
func (FunctionStatus_Status) Descriptor() protoreflect.EnumDescriptor
func (FunctionStatus_Status) Enum ¶
func (x FunctionStatus_Status) Enum() *FunctionStatus_Status
func (FunctionStatus_Status) EnumDescriptor
deprecated
func (FunctionStatus_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use FunctionStatus_Status.Descriptor instead.
func (FunctionStatus_Status) Number ¶
func (x FunctionStatus_Status) Number() protoreflect.EnumNumber
func (FunctionStatus_Status) String ¶
func (x FunctionStatus_Status) String() string
func (FunctionStatus_Status) Type ¶
func (FunctionStatus_Status) Type() protoreflect.EnumType
type Function_ProcessClient ¶
type Function_ProcessClient interface { Recv() (*Event, error) grpc.ClientStream }
type Function_ProcessServer ¶
type Function_ProcessServer interface { Send(*Event) error grpc.ServerStream }
type GetStateRequest ¶
type GetStateRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetStateRequest) Descriptor
deprecated
func (*GetStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.
func (*GetStateRequest) GetKey ¶
func (x *GetStateRequest) GetKey() string
func (*GetStateRequest) ProtoMessage ¶
func (*GetStateRequest) ProtoMessage()
func (*GetStateRequest) ProtoReflect ¶
func (x *GetStateRequest) ProtoReflect() protoreflect.Message
func (*GetStateRequest) Reset ¶
func (x *GetStateRequest) Reset()
func (*GetStateRequest) String ¶
func (x *GetStateRequest) String() string
type GetStateResponse ¶
type GetStateResponse struct { Response *Response `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*GetStateResponse) Descriptor
deprecated
func (*GetStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.
func (*GetStateResponse) GetResponse ¶
func (x *GetStateResponse) GetResponse() *Response
func (*GetStateResponse) GetValue ¶
func (x *GetStateResponse) GetValue() []byte
func (*GetStateResponse) ProtoMessage ¶
func (*GetStateResponse) ProtoMessage()
func (*GetStateResponse) ProtoReflect ¶
func (x *GetStateResponse) ProtoReflect() protoreflect.Message
func (*GetStateResponse) Reset ¶
func (x *GetStateResponse) Reset()
func (*GetStateResponse) String ¶
func (x *GetStateResponse) String() string
type PutStateRequest ¶
type PutStateRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*PutStateRequest) Descriptor
deprecated
func (*PutStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutStateRequest.ProtoReflect.Descriptor instead.
func (*PutStateRequest) GetKey ¶
func (x *PutStateRequest) GetKey() string
func (*PutStateRequest) GetValue ¶
func (x *PutStateRequest) GetValue() []byte
func (*PutStateRequest) ProtoMessage ¶
func (*PutStateRequest) ProtoMessage()
func (*PutStateRequest) ProtoReflect ¶
func (x *PutStateRequest) ProtoReflect() protoreflect.Message
func (*PutStateRequest) Reset ¶
func (x *PutStateRequest) Reset()
func (*PutStateRequest) String ¶
func (x *PutStateRequest) String() string
type Response ¶
type Response struct { Status Response_Status `protobuf:"varint,1,opt,name=status,proto3,enum=fs_func.Response_Status" json:"status,omitempty"` Message *string `protobuf:"bytes,2,opt,name=message,proto3,oneof" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetMessage ¶
func (*Response) GetStatus ¶
func (x *Response) GetStatus() Response_Status
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Response_Status ¶
type Response_Status int32
const ( Response_OK Response_Status = 0 Response_ERROR Response_Status = 1 )
func (Response_Status) Descriptor ¶
func (Response_Status) Descriptor() protoreflect.EnumDescriptor
func (Response_Status) Enum ¶
func (x Response_Status) Enum() *Response_Status
func (Response_Status) EnumDescriptor
deprecated
func (Response_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use Response_Status.Descriptor instead.
func (Response_Status) Number ¶
func (x Response_Status) Number() protoreflect.EnumNumber
func (Response_Status) String ¶
func (x Response_Status) String() string
func (Response_Status) Type ¶
func (Response_Status) Type() protoreflect.EnumType
type UnimplementedFSReconcileServer ¶
type UnimplementedFSReconcileServer struct { }
UnimplementedFSReconcileServer must be embedded to have forward compatible implementations.
func (UnimplementedFSReconcileServer) Reconcile ¶
func (UnimplementedFSReconcileServer) Reconcile(*ConnectRequest, FSReconcile_ReconcileServer) error
func (UnimplementedFSReconcileServer) UpdateStatus ¶
func (UnimplementedFSReconcileServer) UpdateStatus(context.Context, *FunctionStatus) (*Response, error)
type UnimplementedFunctionServer ¶
type UnimplementedFunctionServer struct { }
UnimplementedFunctionServer must be embedded to have forward compatible implementations.
func (UnimplementedFunctionServer) GetState ¶
func (UnimplementedFunctionServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
func (UnimplementedFunctionServer) Process ¶
func (UnimplementedFunctionServer) Process(*FunctionProcessRequest, Function_ProcessServer) error
func (UnimplementedFunctionServer) PutState ¶
func (UnimplementedFunctionServer) PutState(context.Context, *PutStateRequest) (*Response, error)
type UnsafeFSReconcileServer ¶
type UnsafeFSReconcileServer interface {
// contains filtered or unexported methods
}
UnsafeFSReconcileServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FSReconcileServer will result in compilation errors.
type UnsafeFunctionServer ¶
type UnsafeFunctionServer interface {
// contains filtered or unexported methods
}
UnsafeFunctionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FunctionServer will result in compilation errors.