broker

Documentation

Index

• type Listener
  • func NewListener(brokerUrl string, repository *proposal.Repository) *Listener
  • func (l *Listener) Listen() error
  • func (l *Listener) Shutdown()
• type Msg

Types

type Listener

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

func NewListener

func NewListener(brokerUrl string, repository *proposal.Repository) *Listener

func (*Listener) Listen

func (l *Listener) Listen() error

func (*Listener) Shutdown

func (l *Listener) Shutdown()

type Msg

type Msg struct {
	Proposal proposal.Proposal
}