stream

Documentation

Index

• type Sink
• type Stream
  • func New(cc *cassandra.Client) *Stream
  • func (stream *Stream) HttpUpgrade(w http.ResponseWriter, r *http.Request) error
  • func (s *Stream) Listen()

Types

type Sink

type Sink string

const (
	Cassandra Sink = "cassandra"
)

type Stream

type Stream struct {
	PushIncident chan map[string]interface{}
	// contains filtered or unexported fields
}

func New

func New(cc *cassandra.Client) *Stream

func (*Stream) HttpUpgrade

func (stream *Stream) HttpUpgrade(w http.ResponseWriter, r *http.Request) error

func (*Stream) Listen

func (s *Stream) Listen()