Versions in this module Expand all Collapse all v0 v0.1.5 Jun 27, 2020 Changes in this version + const DefaultShutdownTimeout + const TransportName + type Option func(*Transport) error + func WithEncoding(encoding encoding.Encoding) Option + func WithPath(path string) Option + func WithPort(port int) Option + func WithShutdownTimeout(timeout time.Duration) Option + type Transport struct + Client *_sns.SNS + Converter transport.Converter + Encoding encoding.Encoding + Handler *http.ServeMux + Path string + Port *int + Receiver transport.Receiver + ShutdownTimeout *time.Duration + TopicARN string + func New(topicARN string, opts ...Option) (*Transport, error) + func (t *Transport) GetPath() string + func (t *Transport) GetPort() int + func (t *Transport) HasConverter() bool + func (t *Transport) HasTracePropagation() bool + func (t *Transport) Notification(ctx context.Context, notif *snshttp.Notification) error + func (t *Transport) Send(ctx context.Context, event cloudevents.Event) (context.Context, *cloudevents.Event, error) + func (t *Transport) SetConverter(c transport.Converter) + func (t *Transport) SetReceiver(r transport.Receiver) + func (t *Transport) StartReceiver(ctx context.Context) (err error)