server

package

v0.0.0-...-2d43357 Latest Latest Go to latest Published: Jan 27, 2017 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Jocko struct {
	LogDir string
}

func NewJocko(logDir string) (*Jocko, error)

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

func New(addr string, broker jocko.Broker, logger *simplelog.Logger) *Server

func (s *Server) Addr() net.Addr

Addr returns the address on which the Server is listening

func (s *Server) Close()

Close closes the service.

func (s *Server) Start() error

Start starts the service.

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

type TopicConfig struct {
}