test

Documentation

Overview

Package test is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

• Variables
• func NewGenerator(token string, err error) token.Generator
• func NewVerifier(token string) token.Verifier
• func RegisterGreeterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
• func RegisterGreeterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GreeterClient) error
• func RegisterGreeterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
• func RegisterGreeterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GreeterServer) error
• func RegisterGreeterServer(s *grpc.Server, srv GreeterServer)
• type GreeterClient
  • func NewGreeterClient(cc grpc.ClientConnInterface) GreeterClient
• type GreeterServer
• type Greeter_SayStreamHelloClient
• type Greeter_SayStreamHelloServer
• type Handler
  • func NewHandler(err error) *Handler
  • func (h *Handler) Handle(ctx context.Context, m *message.Message) (context.Context, error)
  • func (h *Handler) Message() *message.Message
• type HelloReply
  • func (*HelloReply) Descriptor() ([]byte, []int)
  • func (x *HelloReply) GetMessage() string
  • func (*HelloReply) ProtoMessage()
  • func (x *HelloReply) ProtoReflect() protoreflect.Message
  • func (x *HelloReply) Reset()
  • func (x *HelloReply) String() string
• type HelloRequest
  • func (*HelloRequest) Descriptor() ([]byte, []int)
  • func (x *HelloRequest) GetName() string
  • func (*HelloRequest) ProtoMessage()
  • func (x *HelloRequest) ProtoReflect() protoreflect.Message
  • func (x *HelloRequest) Reset()
  • func (x *HelloRequest) String() string
• type Server
  • func NewServer() *Server
  • func (s *Server) SayHello(ctx context.Context, req *HelloRequest) (*HelloReply, error)
  • func (s *Server) SayStreamHello(stream Greeter_SayStreamHelloServer) error
• type Shutdowner
  • func NewShutdowner() *Shutdowner
  • func (*Shutdowner) Shutdown(...fx.ShutdownOption) error
• type UnimplementedGreeterServer
  • func (UnimplementedGreeterServer) SayHello(context.Context, *HelloRequest) (*HelloReply, error)
  • func (UnimplementedGreeterServer) SayStreamHello(Greeter_SayStreamHelloServer) error
• type UnsafeGreeterServer

Variables

var File_greet_proto protoreflect.FileDescriptor

Functions

func NewGenerator

func NewGenerator(token string, err error) token.Generator

NewGenerator for test.

func NewVerifier

func NewVerifier(token string) token.Verifier

NewVerifier for test.

func RegisterGreeterHandler

func RegisterGreeterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterGreeterHandler registers the http handlers for service Greeter to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterGreeterHandlerClient

func RegisterGreeterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client GreeterClient) error

RegisterGreeterHandlerClient registers the http handlers for service Greeter to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "GreeterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "GreeterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "GreeterClient" to call the correct interceptors.

func RegisterGreeterHandlerFromEndpoint

func RegisterGreeterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterGreeterHandlerFromEndpoint is same as RegisterGreeterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterGreeterHandlerServer

func RegisterGreeterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server GreeterServer) error

RegisterGreeterHandlerServer registers the http handlers for service Greeter to "mux". UnaryRPC :call GreeterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterGreeterHandlerFromEndpoint instead.

func RegisterGreeterServer

func RegisterGreeterServer(s *grpc.Server, srv GreeterServer)

Types

type GreeterClient

type GreeterClient interface {
	SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error)
	SayStreamHello(ctx context.Context, opts ...grpc.CallOption) (Greeter_SayStreamHelloClient, error)
}

GreeterClient is the client API for Greeter 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 NewGreeterClient

func NewGreeterClient(cc grpc.ClientConnInterface) GreeterClient

type GreeterServer

type GreeterServer interface {
	SayHello(context.Context, *HelloRequest) (*HelloReply, error)
	SayStreamHello(Greeter_SayStreamHelloServer) error
	// contains filtered or unexported methods
}

GreeterServer is the server API for Greeter service. All implementations must embed UnimplementedGreeterServer for forward compatibility

type Greeter_SayStreamHelloClient

type Greeter_SayStreamHelloClient interface {
	Send(*HelloRequest) error
	Recv() (*HelloReply, error)
	grpc.ClientStream
}

type Greeter_SayStreamHelloServer

type Greeter_SayStreamHelloServer interface {
	Send(*HelloReply) error
	Recv() (*HelloRequest, error)
	grpc.ServerStream
}

type Handler

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

Handler for test.

func NewHandler

func NewHandler(err error) *Handler

NewHandler for test.

func (*Handler) Handle

func (h *Handler) Handle(ctx context.Context, m *message.Message) (context.Context, error)

func (*Handler) Message

func (h *Handler) Message() *message.Message

type HelloReply

type HelloReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloReply) Descriptor

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

Deprecated: Use HelloReply.ProtoReflect.Descriptor instead.

func (*HelloReply) GetMessage

func (x *HelloReply) GetMessage() string

func (*HelloReply) ProtoMessage

func (*HelloReply) ProtoMessage()

func (*HelloReply) ProtoReflect

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

func (*HelloReply) Reset

func (x *HelloReply) Reset()

func (*HelloReply) String

func (x *HelloReply) String() string

type HelloRequest

type HelloRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*HelloRequest) Descriptor

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

Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.

func (*HelloRequest) GetName

func (x *HelloRequest) GetName() string

func (*HelloRequest) ProtoMessage

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) ProtoReflect

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

func (*HelloRequest) Reset

func (x *HelloRequest) Reset()

func (*HelloRequest) String

func (x *HelloRequest) String() string

type Server

type Server struct {
	UnimplementedGreeterServer
}

func NewServer

func NewServer() *Server

func (*Server) SayHello

func (s *Server) SayHello(ctx context.Context, req *HelloRequest) (*HelloReply, error)

func (*Server) SayStreamHello

func (s *Server) SayStreamHello(stream Greeter_SayStreamHelloServer) error

type Shutdowner

type Shutdowner struct{}

func NewShutdowner

func NewShutdowner() *Shutdowner

func (*Shutdowner) Shutdown

func (*Shutdowner) Shutdown(...fx.ShutdownOption) error

type UnimplementedGreeterServer

type UnimplementedGreeterServer struct {
}

UnimplementedGreeterServer must be embedded to have forward compatible implementations.

func (UnimplementedGreeterServer) SayHello

func (UnimplementedGreeterServer) SayHello(context.Context, *HelloRequest) (*HelloReply, error)

func (UnimplementedGreeterServer) SayStreamHello

func (UnimplementedGreeterServer) SayStreamHello(Greeter_SayStreamHelloServer) error

type UnsafeGreeterServer

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

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