observer

Documentation

Index

• type Publisher
  • func (p *Publisher) Publish(m *tail.Line)
  • func (p *Publisher) Subscribe(c chan *tail.Line)
• type Subscriber
  • func (s *Subscriber) ListenToChannel()

Types

type Publisher

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

func (*Publisher) Publish

func (p *Publisher) Publish(m *tail.Line)

func (*Publisher) Subscribe

func (p *Publisher) Subscribe(c chan *tail.Line)

type Subscriber

type Subscriber struct {
	Channel   chan *tail.Line
	Connector connectors.ConnectorInterface
}

func (*Subscriber) ListenToChannel

func (s *Subscriber) ListenToChannel()