testapp

README

Testing gRPC Application

This directory contains a testing application for validating the New Relic gRPC integration. The code in testapp.pb.go is generated using the following command (to be run from the _integrations/nrgrpc directory). This command should be rerun every time the testapp.proto file has changed for any reason.

$ protoc -I testapp/ testapp/testapp.proto --go_out=plugins=grpc:testapp

To install required dependencies:

go get -u google.golang.org/grpc
go get -u github.com/golang/protobuf/protoc-gen-go

Documentation

Index

• func RegisterTestApplicationServer(s *grpc.Server, srv TestApplicationServer)
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetText() string
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type Server
  • func (s *Server) DoStreamStream(stream TestApplication_DoStreamStreamServer) error
  • func (s *Server) DoStreamUnary(stream TestApplication_DoStreamUnaryServer) error
  • func (s *Server) DoUnaryStream(msg *Message, stream TestApplication_DoUnaryStreamServer) error
  • func (s *Server) DoUnaryStreamError(msg *Message, stream TestApplication_DoUnaryStreamErrorServer) error
  • func (s *Server) DoUnaryUnary(ctx context.Context, msg *Message) (*Message, error)
  • func (s *Server) DoUnaryUnaryError(ctx context.Context, msg *Message) (*Message, error)
• type TestApplicationClient
  • func NewTestApplicationClient(cc *grpc.ClientConn) TestApplicationClient
• type TestApplicationServer
• type TestApplication_DoStreamStreamClient
• type TestApplication_DoStreamStreamServer
• type TestApplication_DoStreamUnaryClient
• type TestApplication_DoStreamUnaryServer
• type TestApplication_DoUnaryStreamClient
• type TestApplication_DoUnaryStreamErrorClient
• type TestApplication_DoUnaryStreamErrorServer
• type TestApplication_DoUnaryStreamServer
• type UnimplementedTestApplicationServer
  • func (*UnimplementedTestApplicationServer) DoStreamStream(srv TestApplication_DoStreamStreamServer) error
  • func (*UnimplementedTestApplicationServer) DoStreamUnary(srv TestApplication_DoStreamUnaryServer) error
  • func (*UnimplementedTestApplicationServer) DoUnaryStream(req *Message, srv TestApplication_DoUnaryStreamServer) error
  • func (*UnimplementedTestApplicationServer) DoUnaryStreamError(req *Message, srv TestApplication_DoUnaryStreamErrorServer) error
  • func (*UnimplementedTestApplicationServer) DoUnaryUnary(ctx context.Context, req *Message) (*Message, error)
  • func (*UnimplementedTestApplicationServer) DoUnaryUnaryError(ctx context.Context, req *Message) (*Message, error)

Functions

func RegisterTestApplicationServer

func RegisterTestApplicationServer(s *grpc.Server, srv TestApplicationServer)

Types

type Message

type Message struct {
	Text                 string   `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor

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

func (*Message) GetText

func (m *Message) GetText() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

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

func (*Message) XXX_Merge

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

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

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

type Server

type Server struct{}

Server is a gRPC server.

func (*Server) DoStreamStream

func (s *Server) DoStreamStream(stream TestApplication_DoStreamStreamServer) error

DoStreamStream is a stream request, stream response method.

func (*Server) DoStreamUnary

func (s *Server) DoStreamUnary(stream TestApplication_DoStreamUnaryServer) error

DoStreamUnary is a stream request, unary response method.

func (*Server) DoUnaryStream

func (s *Server) DoUnaryStream(msg *Message, stream TestApplication_DoUnaryStreamServer) error

DoUnaryStream is a unary request, stream response method.

func (*Server) DoUnaryStreamError

func (s *Server) DoUnaryStreamError(msg *Message, stream TestApplication_DoUnaryStreamErrorServer) error

DoUnaryStreamError is a unary request, unary response method that returns an error.

func (*Server) DoUnaryUnary

func (s *Server) DoUnaryUnary(ctx context.Context, msg *Message) (*Message, error)

DoUnaryUnary is a unary request, unary response method.

func (*Server) DoUnaryUnaryError

func (s *Server) DoUnaryUnaryError(ctx context.Context, msg *Message) (*Message, error)

DoUnaryUnaryError is a unary request, unary response method that returns an error.

type TestApplicationClient

type TestApplicationClient interface {
	DoUnaryUnary(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	DoUnaryStream(ctx context.Context, in *Message, opts ...grpc.CallOption) (TestApplication_DoUnaryStreamClient, error)
	DoStreamUnary(ctx context.Context, opts ...grpc.CallOption) (TestApplication_DoStreamUnaryClient, error)
	DoStreamStream(ctx context.Context, opts ...grpc.CallOption) (TestApplication_DoStreamStreamClient, error)
	DoUnaryUnaryError(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	DoUnaryStreamError(ctx context.Context, in *Message, opts ...grpc.CallOption) (TestApplication_DoUnaryStreamErrorClient, error)
}

TestApplicationClient is the client API for TestApplication service.

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

func NewTestApplicationClient

func NewTestApplicationClient(cc *grpc.ClientConn) TestApplicationClient

type TestApplicationServer

type TestApplicationServer interface {
	DoUnaryUnary(context.Context, *Message) (*Message, error)
	DoUnaryStream(*Message, TestApplication_DoUnaryStreamServer) error
	DoStreamUnary(TestApplication_DoStreamUnaryServer) error
	DoStreamStream(TestApplication_DoStreamStreamServer) error
	DoUnaryUnaryError(context.Context, *Message) (*Message, error)
	DoUnaryStreamError(*Message, TestApplication_DoUnaryStreamErrorServer) error
}

TestApplicationServer is the server API for TestApplication service.

type TestApplication_DoStreamStreamClient

type TestApplication_DoStreamStreamClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type TestApplication_DoStreamStreamServer

type TestApplication_DoStreamStreamServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type TestApplication_DoStreamUnaryClient

type TestApplication_DoStreamUnaryClient interface {
	Send(*Message) error
	CloseAndRecv() (*Message, error)
	grpc.ClientStream
}

type TestApplication_DoStreamUnaryServer

type TestApplication_DoStreamUnaryServer interface {
	SendAndClose(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type TestApplication_DoUnaryStreamClient

type TestApplication_DoUnaryStreamClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type TestApplication_DoUnaryStreamErrorClient

type TestApplication_DoUnaryStreamErrorClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type TestApplication_DoUnaryStreamErrorServer

type TestApplication_DoUnaryStreamErrorServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type TestApplication_DoUnaryStreamServer

type TestApplication_DoUnaryStreamServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type UnimplementedTestApplicationServer

type UnimplementedTestApplicationServer struct {
}

UnimplementedTestApplicationServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestApplicationServer) DoStreamStream

func (*UnimplementedTestApplicationServer) DoStreamStream(srv TestApplication_DoStreamStreamServer) error

func (*UnimplementedTestApplicationServer) DoStreamUnary

func (*UnimplementedTestApplicationServer) DoStreamUnary(srv TestApplication_DoStreamUnaryServer) error

func (*UnimplementedTestApplicationServer) DoUnaryStream

func (*UnimplementedTestApplicationServer) DoUnaryStream(req *Message, srv TestApplication_DoUnaryStreamServer) error

func (*UnimplementedTestApplicationServer) DoUnaryStreamError

func (*UnimplementedTestApplicationServer) DoUnaryStreamError(req *Message, srv TestApplication_DoUnaryStreamErrorServer) error

func (*UnimplementedTestApplicationServer) DoUnaryUnary

func (*UnimplementedTestApplicationServer) DoUnaryUnary(ctx context.Context, req *Message) (*Message, error)

func (*UnimplementedTestApplicationServer) DoUnaryUnaryError

func (*UnimplementedTestApplicationServer) DoUnaryUnaryError(ctx context.Context, req *Message) (*Message, error)