subscriber

Documentation

Index

• type Subscriber
  • func New(endpoint, region, bucket, accessKey, secretKey, objectPrefix string, ...) *Subscriber
  • func (s *Subscriber) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)
  • func (s *Subscriber) StoreFlows(flows []*flow.Flow) error

Types

type Subscriber

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

Subscriber describes a Flows subscriber writing to an object storage service

func New

func New(endpoint, region, bucket, accessKey, secretKey, objectPrefix string, maxSecondsPerStream int, flowTransformer flowtransformer.FlowTransformer) *Subscriber

New returns a new flows subscriber writing to an object storage service

func (*Subscriber) OnStructMessage

func (s *Subscriber) OnStructMessage(c ws.Speaker, msg *ws.StructMessage)

OnStructMessage is triggered when WS server sends us a message.

func (*Subscriber) StoreFlows

func (s *Subscriber) StoreFlows(flows []*flow.Flow) error

StoreFlows writes a set of flows to the object storage service