server

Documentation

Index

• type Server
  • func NewServer(serverOpts ...ServerOption) (*Server, error)
  • func (s *Server) Start() error
• type ServerOption
  • func WithConsumerAddr(consumerAddrs ...string) ServerOption
  • func WithProducerAddr(producerAddrs ...string) ServerOption

Types

type Server

type Server struct {
	// We must use two mutex to synchronise the creation of new topic store.
	ProducerAddrs []string
	ConsumerAddrs []string
	// contains filtered or unexported fields
}

func NewServer

func NewServer(serverOpts ...ServerOption) (*Server, error)

func (*Server) Start

func (s *Server) Start() error

type ServerOption

type ServerOption func(*Server)

func WithConsumerAddr

func WithConsumerAddr(consumerAddrs ...string) ServerOption

will update the port at 4000 only if atleast one port it given, else will keep on running at 4000 if no addr is passed.

func WithProducerAddr

func WithProducerAddr(producerAddrs ...string) ServerOption

will update the port at 3000 only if atleast one port it given, else will keep on running at 3000 if no addr is passed.