Documentation ¶
Index ¶
- Variables
- func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)
- type FunctionCallRequest
- func (*FunctionCallRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionCallRequest) GetEvent() *model.Event
- func (x *FunctionCallRequest) GetName() string
- func (*FunctionCallRequest) ProtoMessage()
- func (x *FunctionCallRequest) ProtoReflect() protoreflect.Message
- func (x *FunctionCallRequest) Reset()
- func (x *FunctionCallRequest) String() string
- type FunctionCallResponse
- func (*FunctionCallResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionCallResponse) GetEvent() *model.Event
- func (*FunctionCallResponse) ProtoMessage()
- func (x *FunctionCallResponse) ProtoReflect() protoreflect.Message
- func (x *FunctionCallResponse) Reset()
- func (x *FunctionCallResponse) String() string
- type FunctionClient
- type FunctionServer
- type UnimplementedFunctionServer
- type UnsafeFunctionServer
Constants ¶
This section is empty.
Variables ¶
var File_ext_function_proto protoreflect.FileDescriptor
var Function_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ext.Function", HandlerType: (*FunctionServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "FunctionCall", Handler: _Function_FunctionCall_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ext/function.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 RegisterFunctionServer ¶
func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)
Types ¶
type FunctionCallRequest ¶
type FunctionCallRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Event *model.Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*FunctionCallRequest) Descriptor
deprecated
func (*FunctionCallRequest) Descriptor() ([]byte, []int)
Deprecated: Use FunctionCallRequest.ProtoReflect.Descriptor instead.
func (*FunctionCallRequest) GetEvent ¶
func (x *FunctionCallRequest) GetEvent() *model.Event
func (*FunctionCallRequest) GetName ¶
func (x *FunctionCallRequest) GetName() string
func (*FunctionCallRequest) ProtoMessage ¶
func (*FunctionCallRequest) ProtoMessage()
func (*FunctionCallRequest) ProtoReflect ¶
func (x *FunctionCallRequest) ProtoReflect() protoreflect.Message
func (*FunctionCallRequest) Reset ¶
func (x *FunctionCallRequest) Reset()
func (*FunctionCallRequest) String ¶
func (x *FunctionCallRequest) String() string
type FunctionCallResponse ¶
type FunctionCallResponse struct { // This event is only used/required if it is a sync event. Event *model.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*FunctionCallResponse) Descriptor
deprecated
func (*FunctionCallResponse) Descriptor() ([]byte, []int)
Deprecated: Use FunctionCallResponse.ProtoReflect.Descriptor instead.
func (*FunctionCallResponse) GetEvent ¶
func (x *FunctionCallResponse) GetEvent() *model.Event
func (*FunctionCallResponse) ProtoMessage ¶
func (*FunctionCallResponse) ProtoMessage()
func (*FunctionCallResponse) ProtoReflect ¶
func (x *FunctionCallResponse) ProtoReflect() protoreflect.Message
func (*FunctionCallResponse) Reset ¶
func (x *FunctionCallResponse) Reset()
func (*FunctionCallResponse) String ¶
func (x *FunctionCallResponse) String() string
type FunctionClient ¶
type FunctionClient interface {
FunctionCall(ctx context.Context, in *FunctionCallRequest, opts ...grpc.CallOption) (*FunctionCallResponse, 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 FunctionServer ¶
type FunctionServer interface { FunctionCall(context.Context, *FunctionCallRequest) (*FunctionCallResponse, error) // contains filtered or unexported methods }
FunctionServer is the server API for Function service. All implementations must embed UnimplementedFunctionServer for forward compatibility
type UnimplementedFunctionServer ¶
type UnimplementedFunctionServer struct { }
UnimplementedFunctionServer must be embedded to have forward compatible implementations.
func (UnimplementedFunctionServer) FunctionCall ¶
func (UnimplementedFunctionServer) FunctionCall(context.Context, *FunctionCallRequest) (*FunctionCallResponse, error)
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.