eventbridge

Documentation

Overview

Package eventbridge provides methods to interact with AWS Eventbridge service allowing user to publish events to Eventbridge

Index

• type Client
  • func New(cfg *Config) (*Client, error)
  • func (c *Client) Bind(message []byte, target interface{}) error
  • func (c *Client) CommitOffset(pubsub.TopicPartition)
  • func (c *Client) HealthCheck() types.Health
  • func (c *Client) IsSet() bool
  • func (c *Client) Ping() error
  • func (c *Client) PublishEvent(detailType string, detail interface{}, _ map[string]string) error
  • func (c *Client) PublishEventWithOptions(string, interface{}, map[string]string, *pubsub.PublishOptions) (err error)
  • func (c *Client) Subscribe() (*pubsub.Message, error)
  • func (c *Client) SubscribeWithCommit(pubsub.CommitFunc) (*pubsub.Message, error)
• type Config

Types

type Client

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

Client represents a client to interact with AWS EventBridge.

func New

func New(cfg *Config) (*Client, error)

New returns new client

func (*Client) Bind

func (c *Client) Bind(message []byte, target interface{}) error

Bind not implemented for Eventbridge

func (*Client) CommitOffset

func (c *Client) CommitOffset(pubsub.TopicPartition)

CommitOffset not implemented for Eventbridge

func (*Client) HealthCheck

func (c *Client) HealthCheck() types.Health

HealthCheck checks eventbridge health.

func (*Client) IsSet

func (c *Client) IsSet() bool

IsSet checks whether eventbridge is initialized or not

func (*Client) Ping

func (c *Client) Ping() error

Ping not implemented for Eventbridge

func (*Client) PublishEvent

func (c *Client) PublishEvent(detailType string, detail interface{}, _ map[string]string) error

PublishEvent publishes the event to eventbridge

func (*Client) PublishEventWithOptions

func (c *Client) PublishEventWithOptions(string, interface{}, map[string]string,
	*pubsub.PublishOptions) (err error)

PublishEventWithOptions not implemented for Eventbridge

func (*Client) Subscribe

func (c *Client) Subscribe() (*pubsub.Message, error)

Subscribe not implemented for Eventbridge

func (*Client) SubscribeWithCommit

func (c *Client) SubscribeWithCommit(pubsub.CommitFunc) (*pubsub.Message, error)

SubscribeWithCommit not implemented for Eventbridge

type Config

type Config struct {
	ConnRetryDuration int
	EventBus          string
	EventSource       string
	Region            string
	AccessKeyID       string
	SecretAccessKey   string
}

Config stores the configuration parameters required to connect to AWS EventBridge.