generic

package
v0.0.0-...-9595dc2 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 2020 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterGenericServiceServer

func RegisterGenericServiceServer(s *grpc.Server, srv GenericServiceServer)

Types

type GenericParams

type GenericParams struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Params               []*ast.Value `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GenericParams) Descriptor

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

func (*GenericParams) GetName

func (m *GenericParams) GetName() string

func (*GenericParams) GetParams

func (m *GenericParams) GetParams() []*ast.Value

func (*GenericParams) ProtoMessage

func (*GenericParams) ProtoMessage()

func (*GenericParams) Reset

func (m *GenericParams) Reset()

func (*GenericParams) String

func (m *GenericParams) String() string

func (*GenericParams) XXX_DiscardUnknown

func (m *GenericParams) XXX_DiscardUnknown()

func (*GenericParams) XXX_Marshal

func (m *GenericParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenericParams) XXX_Merge

func (m *GenericParams) XXX_Merge(src proto.Message)

func (*GenericParams) XXX_Size

func (m *GenericParams) XXX_Size() int

func (*GenericParams) XXX_Unmarshal

func (m *GenericParams) XXX_Unmarshal(b []byte) error

type GenericServiceClient

type GenericServiceClient interface {
	Call(ctx context.Context, in *GenericParams, opts ...grpc.CallOption) (*ast.Value, error)
	Stream(ctx context.Context, in *GenericParams, opts ...grpc.CallOption) (GenericService_StreamClient, error)
}

GenericServiceClient is the client API for GenericService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGenericServiceClient

func NewGenericServiceClient(cc *grpc.ClientConn) GenericServiceClient

type GenericServiceServer

type GenericServiceServer interface {
	Call(context.Context, *GenericParams) (*ast.Value, error)
	Stream(*GenericParams, GenericService_StreamServer) error
}

GenericServiceServer is the server API for GenericService service.

type GenericService_StreamClient

type GenericService_StreamClient interface {
	Recv() (*ast.Value, error)
	grpc.ClientStream
}

type GenericService_StreamServer

type GenericService_StreamServer interface {
	Send(*ast.Value) error
	grpc.ServerStream
}

type Server

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

func NewServer

func NewServer(astContent []byte, redisPool *redis.Pool, rpcUrl string) (*Server, error)

func (*Server) Call

func (s *Server) Call(ctx context.Context, p *GenericParams) (*ast.Value, error)

func (*Server) Stream

func (s *Server) Stream(p *GenericParams, streamServer GenericService_StreamServer) error

type UnimplementedGenericServiceServer

type UnimplementedGenericServiceServer struct {
}

UnimplementedGenericServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedGenericServiceServer) Call

func (*UnimplementedGenericServiceServer) Stream

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL