gtm

Documentation

Index

• Variables
• type Publisher
  • func NewPublisher(l *zap.Logger, host string, opts ...PublisherOption) *Publisher
  • func (p *Publisher) Client() *http.Client
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(topic string, messages ...*message.Message) error
• type PublisherMarshalMessageFunc
• type PublisherOption
  • func PublisherWithClient(v *http.Client) PublisherOption
  • func PublisherWithMarshalMessageFunc(v PublisherMarshalMessageFunc) PublisherOption
  • func PublisherWithPath(v string) PublisherOption

Variables

var (
	ErrErrorResponse   = errors.New("server responded with error status")
	ErrPublisherClosed = errors.New("publisher is closed")
)

Types

type Publisher

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

func NewPublisher

func NewPublisher(l *zap.Logger, host string, opts ...PublisherOption) *Publisher

func (*Publisher) Client

func (p *Publisher) Client() *http.Client

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) Publish

func (p *Publisher) Publish(topic string, messages ...*message.Message) error

type PublisherMarshalMessageFunc

type PublisherMarshalMessageFunc func(url string, msg *message.Message) (*http.Request, error)

PublisherMarshalMessageFunc transforms the message into a HTTP request to be sent to the specified url.

type PublisherOption

type PublisherOption func(*Publisher)

func PublisherWithClient

func PublisherWithClient(v *http.Client) PublisherOption

func PublisherWithMarshalMessageFunc

func PublisherWithMarshalMessageFunc(v PublisherMarshalMessageFunc) PublisherOption

func PublisherWithPath

func PublisherWithPath(v string) PublisherOption