grpc

Documentation

Index

• Variables
• func RegisterApiServer(s grpc.ServiceRegistrar, srv ApiServer)
• type ApiClient
  • func NewApiClient(cc grpc.ClientConnInterface) ApiClient
• type ApiRequest
  • func (*ApiRequest) Descriptor() ([]byte, []int)
  • func (x *ApiRequest) GetData() string
  • func (x *ApiRequest) GetInput() string
  • func (x *ApiRequest) GetIsCache() bool
  • func (x *ApiRequest) GetPackages() []string
  • func (x *ApiRequest) GetQuery() string
  • func (x *ApiRequest) GetResultPath() string
  • func (*ApiRequest) ProtoMessage()
  • func (x *ApiRequest) ProtoReflect() protoreflect.Message
  • func (x *ApiRequest) Reset()
  • func (x *ApiRequest) String() string
• type ApiResult
  • func (*ApiResult) Descriptor() ([]byte, []int)
  • func (x *ApiResult) GetError() string
  • func (x *ApiResult) GetIsSuccess() bool
  • func (x *ApiResult) GetResult() string
  • func (*ApiResult) ProtoMessage()
  • func (x *ApiResult) ProtoReflect() protoreflect.Message
  • func (x *ApiResult) Reset()
  • func (x *ApiResult) String() string
• type ApiServer
• type UnimplementedApiServer
  • func (UnimplementedApiServer) Execute(context.Context, *ApiRequest) (*ApiResult, error)
• type UnsafeApiServer

Variables

var Api_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "OPA.Api",
	HandlerType: (*ApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Execute",
			Handler:    _Api_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

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

var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterApiServer

func RegisterApiServer(s grpc.ServiceRegistrar, srv ApiServer)

Types

type ApiClient

type ApiClient interface {
	Execute(ctx context.Context, in *ApiRequest, opts ...grpc.CallOption) (*ApiResult, error)
}

ApiClient is the client API for Api 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 NewApiClient

func NewApiClient(cc grpc.ClientConnInterface) ApiClient

type ApiRequest

type ApiRequest struct {
	Packages   []string `protobuf:"bytes,1,rep,name=packages,proto3" json:"packages,omitempty"`
	Data       string   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Input      string   `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	Query      string   `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	ResultPath string   `protobuf:"bytes,5,opt,name=resultPath,proto3" json:"resultPath,omitempty"`
	IsCache    bool     `protobuf:"varint,6,opt,name=isCache,proto3" json:"isCache,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiRequest) Descriptor

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

Deprecated: Use ApiRequest.ProtoReflect.Descriptor instead.

func (*ApiRequest) GetData

func (x *ApiRequest) GetData() string

func (*ApiRequest) GetInput

func (x *ApiRequest) GetInput() string

func (*ApiRequest) GetIsCache

func (x *ApiRequest) GetIsCache() bool

func (*ApiRequest) GetPackages

func (x *ApiRequest) GetPackages() []string

func (*ApiRequest) GetQuery

func (x *ApiRequest) GetQuery() string

func (*ApiRequest) GetResultPath

func (x *ApiRequest) GetResultPath() string

func (*ApiRequest) ProtoMessage

func (*ApiRequest) ProtoMessage()

func (*ApiRequest) ProtoReflect

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

func (*ApiRequest) Reset

func (x *ApiRequest) Reset()

func (*ApiRequest) String

func (x *ApiRequest) String() string

type ApiResult

type ApiResult struct {
	IsSuccess bool   `protobuf:"varint,1,opt,name=isSuccess,proto3" json:"isSuccess,omitempty"`
	Result    string `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Error     string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiResult) Descriptor

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

Deprecated: Use ApiResult.ProtoReflect.Descriptor instead.

func (*ApiResult) GetError

func (x *ApiResult) GetError() string

func (*ApiResult) GetIsSuccess

func (x *ApiResult) GetIsSuccess() bool

func (*ApiResult) GetResult

func (x *ApiResult) GetResult() string

func (*ApiResult) ProtoMessage

func (*ApiResult) ProtoMessage()

func (*ApiResult) ProtoReflect

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

func (*ApiResult) Reset

func (x *ApiResult) Reset()

func (*ApiResult) String

func (x *ApiResult) String() string

type ApiServer

type ApiServer interface {
	Execute(context.Context, *ApiRequest) (*ApiResult, error)
	// contains filtered or unexported methods
}

ApiServer is the server API for Api service. All implementations must embed UnimplementedApiServer for forward compatibility

type UnimplementedApiServer

type UnimplementedApiServer struct {
}

UnimplementedApiServer must be embedded to have forward compatible implementations.

func (UnimplementedApiServer) Execute

func (UnimplementedApiServer) Execute(context.Context, *ApiRequest) (*ApiResult, error)

type UnsafeApiServer

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

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