pulse

README

Pulse

A AWS SNS(endpoint) and SSE(server side) integration library written in GO

##Install

go get github.com/polydice/pulse

##Features

• Works out of the box, without any configuration
• Auto confirm SNS subscribing
• Auto parse SNS notification
• Built-in http server for SNS request and SSE connection
• Auto send notification to SSE client

##Usage

package main

import (
	"github.com/polydice/pulse"
)

func main() {
	pump := pulse.New(":8000")
	pump.Start(true) // Allow cross domain or not.
}

Then add /publish/any_event_name_you_want to your AWS SNS http endpoint. Now there is a SSE server on /subscribe/any_event_name_you_want, example usage:

var source = new EventSource('http://localhost:8000/subscribe/any_event_name_you_want');

// Create a callback for when a new message is received.
source.onmessage = function(e) {
  console.log(e.data)
};

##TODO

• SNS signature verification
• examples

Documentation

Index

• type Pump
  • func New(port string) *Pump
  • func (self *Pump) RegisterMessenger(name string, msger *messenger.Messenger)
  • func (self *Pump) Start(allowCrossDomain bool)

Types

type Pump

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

func New

func New(port string) *Pump

func (*Pump) RegisterMessenger

func (self *Pump) RegisterMessenger(name string, msger *messenger.Messenger)

func (*Pump) Start

func (self *Pump) Start(allowCrossDomain bool)