ext

Documentation

Index

• Constants
• Variables
• func RegisterFunctionServer(s grpc.ServiceRegistrar, srv FunctionServer)
• type FunctionCallRequest
  • func (*FunctionCallRequest) Descriptor() ([]byte, []int)
  • 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)
  • 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
  • func NewFunctionClient(cc grpc.ClientConnInterface) FunctionClient
• type FunctionServer
• type UnimplementedFunctionServer
  • func (UnimplementedFunctionServer) FunctionCall(context.Context, *FunctionCallRequest) (*FunctionCallResponse, error)
• type UnsafeFunctionServer

Constants

const (
	Function_FunctionCall_FullMethodName = "/ext.Function/FunctionCall"
)

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

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

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.