reversegrpc

README

Revering the flow of grpc

DO NOT USE IN PROD, YOU HAVE BEEN WARNED

why?

No good reason at all: because you can!

how

Implicit interfaces and some dialer magic

tell me more!

blog post coming soonTM

Documentation

Index

• Variables
• type Controller
  • func (c *Controller) Accept(options ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (c *Controller) Listen(address string) error
• type DialListener
  • func NewDialListener(addr string) *DialListener
  • func (d *DialListener) Accept() (net.Conn, error)
  • func (d DialListener) Addr() net.Addr
  • func (d *DialListener) Close() error

Variables

var ErrWorkerDisconnected = errors.New("worker disconnected")

Types

type Controller

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

func (*Controller) Accept

func (c *Controller) Accept(options ...grpc.DialOption) (*grpc.ClientConn, error)

func (*Controller) Listen

func (c *Controller) Listen(address string) error

type DialListener

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

who needs to listen anyways. just dial :svekw:

func NewDialListener

func NewDialListener(addr string) *DialListener

func (*DialListener) Accept

func (d *DialListener) Accept() (net.Conn, error)

Accepts dials out the controller and returns the tcp connection that has been set up. A semaphore is used to ensure there is a most one live connection

func (DialListener) Addr

func (d DialListener) Addr() net.Addr

func (*DialListener) Close

func (d *DialListener) Close() error

nothing to close when you aren't listening