gtm

Documentation

Index

• Constants
• Variables
• type MarshalMessageFunc
• type Publisher
  • func NewPublisher(url 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 PublisherOption
  • func PublisherWithClient(v *http.Client) PublisherOption
  • func PublisherWithMarshalMessageFunc(v MarshalMessageFunc) PublisherOption

Constants

const (
	HeaderUUID   = "Message-Uuid"
	ProviderName = "gtm"
)

Variables

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

Types

type MarshalMessageFunc

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

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

type Publisher

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

func NewPublisher

func NewPublisher(url 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 PublisherOption

type PublisherOption func(*Publisher)

func PublisherWithClient

func PublisherWithClient(v *http.Client) PublisherOption

func PublisherWithMarshalMessageFunc

func PublisherWithMarshalMessageFunc(v MarshalMessageFunc) PublisherOption