Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.