server

Documentation

Index

• type PipeServer
  • func New(c *config.Config, l logger.Logger) *PipeServer
  • func (p *PipeServer) Listen()
  • func (p *PipeServer) Stop()

Types

type PipeServer

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

PipeServer is the main server which configures the providers and starts listening for messages

func New

func New(c *config.Config, l logger.Logger) *PipeServer

New creates a new PipeServer

func (*PipeServer) Listen

func (p *PipeServer) Listen()

Listen starts listening for messages

func (*PipeServer) Stop

func (p *PipeServer) Stop()

Stop listening for messages and shutdown connections