grpc

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Oct 10, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_grpc_rulestone_proto protoreflect.FileDescriptor
View Source 
var RulestoneService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rulestone.RulestoneService",
	HandlerType: (*RulestoneServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateRuleEngine",
			Handler:    _RulestoneService_CreateRuleEngine_Handler,
		},
		{
			MethodName: "AddRuleFromJsonString",
			Handler:    _RulestoneService_AddRuleFromJsonString_Handler,
		},
		{
			MethodName: "AddRuleFromYamlString",
			Handler:    _RulestoneService_AddRuleFromYamlString_Handler,
		},
		{
			MethodName: "AddRulesFromFilePath",
			Handler:    _RulestoneService_AddRulesFromFilePath_Handler,
		},
		{
			MethodName: "AddRulesFromDirectoryPath",
			Handler:    _RulestoneService_AddRulesFromDirectoryPath_Handler,
		},
		{
			MethodName: "Activate",
			Handler:    _RulestoneService_Activate_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Match",
			Handler:       _RulestoneService_Match_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "grpc/rulestone.proto",
}

RulestoneService_ServiceDesc is the grpc.ServiceDesc for RulestoneService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterRulestoneServiceServer 

func RegisterRulestoneServiceServer(s grpc.ServiceRegistrar, srv RulestoneServiceServer)

Types

type EmptyRequest 

type EmptyRequest struct {
	// contains filtered or unexported fields
}

func (*EmptyRequest) Descriptor deprecated 

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

Deprecated: Use EmptyRequest.ProtoReflect.Descriptor instead.

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) ProtoReflect 

func (x *EmptyRequest) ProtoReflect() protoreflect.Message

func (*EmptyRequest) Reset 

func (x *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (x *EmptyRequest) String() string

type EmptyResponse 

type EmptyResponse struct {
	// contains filtered or unexported fields
}

func (*EmptyResponse) Descriptor deprecated 

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

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect 

func (x *EmptyResponse) ProtoReflect() protoreflect.Message

func (*EmptyResponse) Reset 

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String 

func (x *EmptyResponse) String() string

type MatchRequest 

type MatchRequest struct {
	RequestId    int64  `protobuf:"varint,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	RuleEngineId int32  `protobuf:"varint,2,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	JsonData     string `protobuf:"bytes,3,opt,name=jsonData,proto3" json:"jsonData,omitempty"`
	// contains filtered or unexported fields
}

func (*MatchRequest) Descriptor deprecated 

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

Deprecated: Use MatchRequest.ProtoReflect.Descriptor instead.

func (*MatchRequest) GetJsonData 

func (x *MatchRequest) GetJsonData() string

func (*MatchRequest) GetRequestId 

func (x *MatchRequest) GetRequestId() int64

func (*MatchRequest) GetRuleEngineId 

func (x *MatchRequest) GetRuleEngineId() int32

func (*MatchRequest) ProtoMessage 

func (*MatchRequest) ProtoMessage()

func (*MatchRequest) ProtoReflect 

func (x *MatchRequest) ProtoReflect() protoreflect.Message

func (*MatchRequest) Reset 

func (x *MatchRequest) Reset()

func (*MatchRequest) String 

func (x *MatchRequest) String() string

type MatchResponse 

type MatchResponse struct {
	RequestId int64   `protobuf:"varint,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	MatchIds  []int32 `protobuf:"varint,2,rep,packed,name=matchIds,proto3" json:"matchIds,omitempty"`
	// contains filtered or unexported fields
}

func (*MatchResponse) Descriptor deprecated 

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

Deprecated: Use MatchResponse.ProtoReflect.Descriptor instead.

func (*MatchResponse) GetMatchIds 

func (x *MatchResponse) GetMatchIds() []int32

func (*MatchResponse) GetRequestId 

func (x *MatchResponse) GetRequestId() int64

func (*MatchResponse) ProtoMessage 

func (*MatchResponse) ProtoMessage()

func (*MatchResponse) ProtoReflect 

func (x *MatchResponse) ProtoReflect() protoreflect.Message

func (*MatchResponse) Reset 

func (x *MatchResponse) Reset()

func (*MatchResponse) String 

func (x *MatchResponse) String() string

type NumRulesResponse 

type NumRulesResponse struct {
	NumRules int32 `protobuf:"varint,1,opt,name=numRules,proto3" json:"numRules,omitempty"`
	// contains filtered or unexported fields
}

func (*NumRulesResponse) Descriptor deprecated 

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

Deprecated: Use NumRulesResponse.ProtoReflect.Descriptor instead.

func (*NumRulesResponse) GetNumRules 

func (x *NumRulesResponse) GetNumRules() int32

func (*NumRulesResponse) ProtoMessage 

func (*NumRulesResponse) ProtoMessage()

func (*NumRulesResponse) ProtoReflect 

func (x *NumRulesResponse) ProtoReflect() protoreflect.Message

func (*NumRulesResponse) Reset 

func (x *NumRulesResponse) Reset()

func (*NumRulesResponse) String 

func (x *NumRulesResponse) String() string

type RuleEngineRequest 

type RuleEngineRequest struct {
	RuleEngineId int32 `protobuf:"varint,1,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleEngineRequest) Descriptor deprecated 

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

Deprecated: Use RuleEngineRequest.ProtoReflect.Descriptor instead.

func (*RuleEngineRequest) GetRuleEngineId 

func (x *RuleEngineRequest) GetRuleEngineId() int32

func (*RuleEngineRequest) ProtoMessage 

func (*RuleEngineRequest) ProtoMessage()

func (*RuleEngineRequest) ProtoReflect 

func (x *RuleEngineRequest) ProtoReflect() protoreflect.Message

func (*RuleEngineRequest) Reset 

func (x *RuleEngineRequest) Reset()

func (*RuleEngineRequest) String 

func (x *RuleEngineRequest) String() string

type RuleEngineResponse 

type RuleEngineResponse struct {
	RuleEngineId int32 `protobuf:"varint,1,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleEngineResponse) Descriptor deprecated 

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

Deprecated: Use RuleEngineResponse.ProtoReflect.Descriptor instead.

func (*RuleEngineResponse) GetRuleEngineId 

func (x *RuleEngineResponse) GetRuleEngineId() int32

func (*RuleEngineResponse) ProtoMessage 

func (*RuleEngineResponse) ProtoMessage()

func (*RuleEngineResponse) ProtoReflect 

func (x *RuleEngineResponse) ProtoReflect() protoreflect.Message

func (*RuleEngineResponse) Reset 

func (x *RuleEngineResponse) Reset()

func (*RuleEngineResponse) String 

func (x *RuleEngineResponse) String() string

type RuleFromDirectoryRequest 

type RuleFromDirectoryRequest struct {
	RuleEngineId       int32  `protobuf:"varint,1,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	RulesDirectoryPath string `protobuf:"bytes,2,opt,name=rulesDirectoryPath,proto3" json:"rulesDirectoryPath,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleFromDirectoryRequest) Descriptor deprecated 

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

Deprecated: Use RuleFromDirectoryRequest.ProtoReflect.Descriptor instead.

func (*RuleFromDirectoryRequest) GetRuleEngineId 

func (x *RuleFromDirectoryRequest) GetRuleEngineId() int32

func (*RuleFromDirectoryRequest) GetRulesDirectoryPath 

func (x *RuleFromDirectoryRequest) GetRulesDirectoryPath() string

func (*RuleFromDirectoryRequest) ProtoMessage 

func (*RuleFromDirectoryRequest) ProtoMessage()

func (*RuleFromDirectoryRequest) ProtoReflect 

func (x *RuleFromDirectoryRequest) ProtoReflect() protoreflect.Message

func (*RuleFromDirectoryRequest) Reset 

func (x *RuleFromDirectoryRequest) Reset()

func (*RuleFromDirectoryRequest) String 

func (x *RuleFromDirectoryRequest) String() string

type RuleFromFileRequest 

type RuleFromFileRequest struct {
	RuleEngineId int32  `protobuf:"varint,1,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	RuleFilePath string `protobuf:"bytes,2,opt,name=ruleFilePath,proto3" json:"ruleFilePath,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleFromFileRequest) Descriptor deprecated 

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

Deprecated: Use RuleFromFileRequest.ProtoReflect.Descriptor instead.

func (*RuleFromFileRequest) GetRuleEngineId 

func (x *RuleFromFileRequest) GetRuleEngineId() int32

func (*RuleFromFileRequest) GetRuleFilePath 

func (x *RuleFromFileRequest) GetRuleFilePath() string

func (*RuleFromFileRequest) ProtoMessage 

func (*RuleFromFileRequest) ProtoMessage()

func (*RuleFromFileRequest) ProtoReflect 

func (x *RuleFromFileRequest) ProtoReflect() protoreflect.Message

func (*RuleFromFileRequest) Reset 

func (x *RuleFromFileRequest) Reset()

func (*RuleFromFileRequest) String 

func (x *RuleFromFileRequest) String() string

type RuleFromStringRequest 

type RuleFromStringRequest struct {
	RuleEngineId int32  `protobuf:"varint,1,opt,name=ruleEngineId,proto3" json:"ruleEngineId,omitempty"`
	RuleString   string `protobuf:"bytes,2,opt,name=ruleString,proto3" json:"ruleString,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleFromStringRequest) Descriptor deprecated 

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

Deprecated: Use RuleFromStringRequest.ProtoReflect.Descriptor instead.

func (*RuleFromStringRequest) GetRuleEngineId 

func (x *RuleFromStringRequest) GetRuleEngineId() int32

func (*RuleFromStringRequest) GetRuleString 

func (x *RuleFromStringRequest) GetRuleString() string

func (*RuleFromStringRequest) ProtoMessage 

func (*RuleFromStringRequest) ProtoMessage()

func (*RuleFromStringRequest) ProtoReflect 

func (x *RuleFromStringRequest) ProtoReflect() protoreflect.Message

func (*RuleFromStringRequest) Reset 

func (x *RuleFromStringRequest) Reset()

func (*RuleFromStringRequest) String 

func (x *RuleFromStringRequest) String() string

type RuleResponse 

type RuleResponse struct {
	RuleId int32 `protobuf:"varint,1,opt,name=ruleId,proto3" json:"ruleId,omitempty"`
	// contains filtered or unexported fields
}

func (*RuleResponse) Descriptor deprecated 

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

Deprecated: Use RuleResponse.ProtoReflect.Descriptor instead.

func (*RuleResponse) GetRuleId 

func (x *RuleResponse) GetRuleId() int32

func (*RuleResponse) ProtoMessage 

func (*RuleResponse) ProtoMessage()

func (*RuleResponse) ProtoReflect 

func (x *RuleResponse) ProtoReflect() protoreflect.Message

func (*RuleResponse) Reset 

func (x *RuleResponse) Reset()

func (*RuleResponse) String 

func (x *RuleResponse) String() string

type RulesResponse 

type RulesResponse struct {
	RuleIds []int32 `protobuf:"varint,1,rep,packed,name=ruleIds,proto3" json:"ruleIds,omitempty"`
	// contains filtered or unexported fields
}

func (*RulesResponse) Descriptor deprecated 

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

Deprecated: Use RulesResponse.ProtoReflect.Descriptor instead.

func (*RulesResponse) GetRuleIds 

func (x *RulesResponse) GetRuleIds() []int32

func (*RulesResponse) ProtoMessage 

func (*RulesResponse) ProtoMessage()

func (*RulesResponse) ProtoReflect 

func (x *RulesResponse) ProtoReflect() protoreflect.Message

func (*RulesResponse) Reset 

func (x *RulesResponse) Reset()

func (*RulesResponse) String 

func (x *RulesResponse) String() string

type RulestoneServiceClient 

type RulestoneServiceClient interface {
	CreateRuleEngine(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*RuleEngineResponse, error)
	AddRuleFromJsonString(ctx context.Context, in *RuleFromStringRequest, opts ...grpc.CallOption) (*RuleResponse, error)
	AddRuleFromYamlString(ctx context.Context, in *RuleFromStringRequest, opts ...grpc.CallOption) (*RuleResponse, error)
	AddRulesFromFilePath(ctx context.Context, in *RuleFromFileRequest, opts ...grpc.CallOption) (*NumRulesResponse, error)
	AddRulesFromDirectoryPath(ctx context.Context, in *RuleFromDirectoryRequest, opts ...grpc.CallOption) (*NumRulesResponse, error)
	Activate(ctx context.Context, in *RuleEngineRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
	Match(ctx context.Context, opts ...grpc.CallOption) (RulestoneService_MatchClient, error)
}

RulestoneServiceClient is the client API for RulestoneService 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 NewRulestoneServiceClient 

func NewRulestoneServiceClient(cc grpc.ClientConnInterface) RulestoneServiceClient

type RulestoneServiceServer 

type RulestoneServiceServer interface {
	CreateRuleEngine(context.Context, *EmptyRequest) (*RuleEngineResponse, error)
	AddRuleFromJsonString(context.Context, *RuleFromStringRequest) (*RuleResponse, error)
	AddRuleFromYamlString(context.Context, *RuleFromStringRequest) (*RuleResponse, error)
	AddRulesFromFilePath(context.Context, *RuleFromFileRequest) (*NumRulesResponse, error)
	AddRulesFromDirectoryPath(context.Context, *RuleFromDirectoryRequest) (*NumRulesResponse, error)
	Activate(context.Context, *RuleEngineRequest) (*EmptyResponse, error)
	Match(RulestoneService_MatchServer) error
	// contains filtered or unexported methods
}

RulestoneServiceServer is the server API for RulestoneService service. All implementations must embed UnimplementedRulestoneServiceServer for forward compatibility

type RulestoneService_MatchClient 

type RulestoneService_MatchClient interface {
	Send(*MatchRequest) error
	Recv() (*MatchResponse, error)
	grpc.ClientStream
}

type RulestoneService_MatchServer 

type RulestoneService_MatchServer interface {
	Send(*MatchResponse) error
	Recv() (*MatchRequest, error)
	grpc.ServerStream
}

type UnimplementedRulestoneServiceServer 

type UnimplementedRulestoneServiceServer struct {
}

UnimplementedRulestoneServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRulestoneServiceServer) Activate 

func (UnimplementedRulestoneServiceServer) Activate(context.Context, *RuleEngineRequest) (*EmptyResponse, error)

func (UnimplementedRulestoneServiceServer) AddRuleFromJsonString 

func (UnimplementedRulestoneServiceServer) AddRuleFromJsonString(context.Context, *RuleFromStringRequest) (*RuleResponse, error)

func (UnimplementedRulestoneServiceServer) AddRuleFromYamlString 

func (UnimplementedRulestoneServiceServer) AddRuleFromYamlString(context.Context, *RuleFromStringRequest) (*RuleResponse, error)

func (UnimplementedRulestoneServiceServer) AddRulesFromDirectoryPath 

func (UnimplementedRulestoneServiceServer) AddRulesFromDirectoryPath(context.Context, *RuleFromDirectoryRequest) (*NumRulesResponse, error)

func (UnimplementedRulestoneServiceServer) AddRulesFromFilePath added in v0.2.0 

func (UnimplementedRulestoneServiceServer) AddRulesFromFilePath(context.Context, *RuleFromFileRequest) (*NumRulesResponse, error)

func (UnimplementedRulestoneServiceServer) CreateRuleEngine 

func (UnimplementedRulestoneServiceServer) CreateRuleEngine(context.Context, *EmptyRequest) (*RuleEngineResponse, error)

func (UnimplementedRulestoneServiceServer) Match 

func (UnimplementedRulestoneServiceServer) Match(RulestoneService_MatchServer) error

type UnsafeRulestoneServiceServer 

type UnsafeRulestoneServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRulestoneServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RulestoneServiceServer will result in compilation errors.

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.