boomerserver

Documentation

Overview

Package boomerserver implements the boomer server. It makes things go boom.

Index

• func New(r grpc.ServiceRegistrar, c Connection) (pb.BoomerServer, error)
• type Connection
• type Server
  • func (s *Server) Boom(ctx context.Context, req *pb.BoomRequest) (*pb.BoomResponse, error)

Functions

func New

func New(r grpc.ServiceRegistrar, c Connection) (pb.BoomerServer, error)

New creates a new boomer server. The server is registered with the provided grpc.ServiceRegistrar.

Types

type Connection

type Connection interface {
	Publish(subject string, msg []byte) error
	Request(subject string, req []byte, timeout time.Duration) (resp *nats.Msg, err error)
	RequestMsg(msg *nats.Msg, timeout time.Duration) (resp *nats.Msg, err error)
}

Connection is an interface for publishing and requesting messages. It is satisfied by nats.Conn, among others.

type Server

type Server struct {
	pb.UnimplementedBoomerServer
	// contains filtered or unexported fields
}

Server implements the boomer server

func (*Server) Boom

func (s *Server) Boom(ctx context.Context, req *pb.BoomRequest) (*pb.BoomResponse, error)

Boom implements the pb.BoomerServer GRPC interface