connection

Documentation

Index

• type Connection
  • func NewConnection(proxy *httputil.ReverseProxy, backend string, startup *sync.WaitGroup) *Connection
  • func (c *Connection) Get() (*httputil.ReverseProxy, error)
  • func (c *Connection) Shutdown()
• type Message

Types

type Connection

type Connection struct {
	Shut     bool
	Messages chan Message
	Backend  string
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(proxy *httputil.ReverseProxy, backend string, startup *sync.WaitGroup) *Connection

func (*Connection) Get

func (c *Connection) Get() (*httputil.ReverseProxy, error)

func (*Connection) Shutdown

func (c *Connection) Shutdown()

type Message

type Message struct {
	Health   bool
	Backend  string
	Proxy    *httputil.ReverseProxy
	Ack      *sync.WaitGroup
	Shutdown bool
}