megaphone

type ConfigError ¶

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

ConfigError is returned when the configuration provided for a Client is invalid.

func NewConfigError(e error) *ConfigError

func NewConfigErrorWithField(e error, field string) *ConfigError

func (ce *ConfigError) Error() string

type FluentdClient ¶ added in v1.0.0

type FluentdClient struct {
	FluentdConfig
	// contains filtered or unexported fields
}

Client provides a standard interface to publish events to Megaphone. Conventionally, a FileLogger is used if no configuration for a FluentLogger is provided, allowing for easy local development in absence of a local Megaphone Fluentd container.

func (c *FluentdClient) Publish(topic, subtopic, schema, partitionKey string, payload []byte) (err error)

func (c *FluentdClient) PublishRawMessage(streamName string, partitionKey string, messageBytes []byte) error

type FluentdConfig ¶ added in v1.0.0

type FluentdConfig struct {
	Origin string
	Host   string
	Port   int
}

FluentdConfig holds the configuration for a FluentdClient.

type KinesisSynchronousPublisher ¶ added in v1.0.0

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

func NewKinesisSynchronousPublisher(config kinesisclient.Config) (*KinesisSynchronousPublisher, error)

func (c *KinesisSynchronousPublisher) Publish(topic, subtopic, schema, partitionKey string, payload []byte) error

func (c *KinesisSynchronousPublisher) PublishRawMessage(streamName string, partitionKey string, messageBytes []byte) error

type PayloadError ¶

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

PayloadError is returned when the event payload to be published is invalid.

func NewPayloadError(e error, payload string) *PayloadError

func (pe *PayloadError) Error() string

type PublicationError ¶

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

PublicationError is returned when an event couldn't be published.

func NewPublicationError(e error, event string) *PublicationError

func (pe *PublicationError) Error() string

type Publisher ¶ added in v0.2.0

type Publisher interface {
	Publish(topic, subtopic, schema, partitionKey string, payload []byte) (err error)
	PublishRawMessage(streamName string, partitionKey string, messageBytes []byte) (err error)
}

Publisher provides means to publish an event.

func NewFluentdClient(origin, host string, port int) (c Publisher, err error)