http

Documentation

Index

• func New() subscriber.Subscriber
• type Dest
• type HTTPHeaders
• type HTTPSubscriber
  • func (s *HTTPSubscriber) Name() string
  • func (s *HTTPSubscriber) Publish(dest string, content string, timestamp int64, msg *types.Message) []error
  • func (s *HTTPSubscriber) Status() interface{}

Functions

func New

func New() subscriber.Subscriber

Types

type Dest

type Dest []string

urls

type HTTPHeaders

type HTTPHeaders map[string]string

label: HTTP-HEADERS

type HTTPSubscriber

type HTTPSubscriber struct{}

func (*HTTPSubscriber) Name

func (s *HTTPSubscriber) Name() string

func (*HTTPSubscriber) Publish

func (s *HTTPSubscriber) Publish(dest string, content string, timestamp int64, msg *types.Message) []error

func (*HTTPSubscriber) Status

func (s *HTTPSubscriber) Status() interface{}