kinesisacquisition

Documentation

Index

• type CloudWatchSubscriptionRecord
• type CloudwatchSubscriptionLogEvent
• type KinesisConfiguration
• type KinesisSource
  • func (k *KinesisSource) CanRun() error
  • func (k *KinesisSource) Configure(yamlConfig []byte, logger *log.Entry, MetricsLevel int) error
  • func (k *KinesisSource) ConfigureByDSN(string, map[string]string, *log.Entry, string) error
  • func (k *KinesisSource) DeregisterConsumer() error
  • func (k *KinesisSource) Dump() interface{}
  • func (k *KinesisSource) EnhancedRead(out chan types.Event, t *tomb.Tomb) error
  • func (k *KinesisSource) GetAggregMetrics() []prometheus.Collector
  • func (k *KinesisSource) GetMetrics() []prometheus.Collector
  • func (k *KinesisSource) GetMode() string
  • func (k *KinesisSource) GetName() string
  • func (k *KinesisSource) GetUuid() string
  • func (k *KinesisSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (k *KinesisSource) ParseAndPushRecords(records []*kinesis.Record, out chan types.Event, logger *log.Entry, ...)
  • func (k *KinesisSource) ReadFromShard(out chan types.Event, shardId string) error
  • func (k *KinesisSource) ReadFromStream(out chan types.Event, t *tomb.Tomb) error
  • func (k *KinesisSource) ReadFromSubscription(reader kinesis.SubscribeToShardEventStreamReader, out chan types.Event, ...) error
  • func (k *KinesisSource) RegisterConsumer() (*kinesis.RegisterStreamConsumerOutput, error)
  • func (k *KinesisSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error
  • func (k *KinesisSource) SubscribeToShards(arn arn.ARN, streamConsumer *kinesis.RegisterStreamConsumerOutput, ...) error
  • func (k *KinesisSource) UnmarshalConfig(yamlConfig []byte) error
  • func (k *KinesisSource) WaitForConsumerDeregistration(consumerName string, streamARN string) error
  • func (k *KinesisSource) WaitForConsumerRegistration(consumerARN string) error

Types

type CloudWatchSubscriptionRecord

type CloudWatchSubscriptionRecord struct {
	MessageType         string                           `json:"messageType"`
	Owner               string                           `json:"owner"`
	LogGroup            string                           `json:"logGroup"`
	LogStream           string                           `json:"logStream"`
	SubscriptionFilters []string                         `json:"subscriptionFilters"`
	LogEvents           []CloudwatchSubscriptionLogEvent `json:"logEvents"`
}

type CloudwatchSubscriptionLogEvent

type CloudwatchSubscriptionLogEvent struct {
	ID        string `json:"id"`
	Message   string `json:"message"`
	Timestamp int64  `json:"timestamp"`
}

type KinesisConfiguration

type KinesisConfiguration struct {
	configuration.DataSourceCommonCfg `yaml:",inline"`
	StreamName                        string  `yaml:"stream_name"`
	StreamARN                         string  `yaml:"stream_arn"`
	UseEnhancedFanOut                 bool    `yaml:"use_enhanced_fanout"` //Use RegisterStreamConsumer and SubscribeToShard instead of GetRecords
	AwsProfile                        *string `yaml:"aws_profile"`
	AwsRegion                         string  `yaml:"aws_region"`
	AwsEndpoint                       string  `yaml:"aws_endpoint"`
	ConsumerName                      string  `yaml:"consumer_name"`
	FromSubscription                  bool    `yaml:"from_subscription"`
	MaxRetries                        int     `yaml:"max_retries"`
}

type KinesisSource

type KinesisSource struct {
	Config KinesisConfiguration
	// contains filtered or unexported fields
}

func (*KinesisSource) CanRun

func (k *KinesisSource) CanRun() error

func (*KinesisSource) Configure

func (k *KinesisSource) Configure(yamlConfig []byte, logger *log.Entry, MetricsLevel int) error

func (*KinesisSource) ConfigureByDSN

func (k *KinesisSource) ConfigureByDSN(string, map[string]string, *log.Entry, string) error

func (*KinesisSource) DeregisterConsumer

func (k *KinesisSource) DeregisterConsumer() error

func (*KinesisSource) Dump

func (k *KinesisSource) Dump() interface{}

func (*KinesisSource) EnhancedRead

func (k *KinesisSource) EnhancedRead(out chan types.Event, t *tomb.Tomb) error

func (*KinesisSource) GetAggregMetrics

func (k *KinesisSource) GetAggregMetrics() []prometheus.Collector

func (*KinesisSource) GetMetrics

func (k *KinesisSource) GetMetrics() []prometheus.Collector

func (*KinesisSource) GetMode

func (k *KinesisSource) GetMode() string

func (*KinesisSource) GetName

func (k *KinesisSource) GetName() string

func (*KinesisSource) GetUuid

func (k *KinesisSource) GetUuid() string

func (*KinesisSource) OneShotAcquisition

func (k *KinesisSource) OneShotAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*KinesisSource) ParseAndPushRecords

func (k *KinesisSource) ParseAndPushRecords(records []*kinesis.Record, out chan types.Event, logger *log.Entry, shardId string)

func (*KinesisSource) ReadFromShard

func (k *KinesisSource) ReadFromShard(out chan types.Event, shardId string) error

func (*KinesisSource) ReadFromStream

func (k *KinesisSource) ReadFromStream(out chan types.Event, t *tomb.Tomb) error

func (*KinesisSource) ReadFromSubscription

func (k *KinesisSource) ReadFromSubscription(reader kinesis.SubscribeToShardEventStreamReader, out chan types.Event, shardId string, streamName string) error

func (*KinesisSource) RegisterConsumer

func (k *KinesisSource) RegisterConsumer() (*kinesis.RegisterStreamConsumerOutput, error)

func (*KinesisSource) StreamingAcquisition

func (k *KinesisSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) error

func (*KinesisSource) SubscribeToShards

func (k *KinesisSource) SubscribeToShards(arn arn.ARN, streamConsumer *kinesis.RegisterStreamConsumerOutput, out chan types.Event) error

func (*KinesisSource) UnmarshalConfig

func (k *KinesisSource) UnmarshalConfig(yamlConfig []byte) error

func (*KinesisSource) WaitForConsumerDeregistration

func (k *KinesisSource) WaitForConsumerDeregistration(consumerName string, streamARN string) error

func (*KinesisSource) WaitForConsumerRegistration

func (k *KinesisSource) WaitForConsumerRegistration(consumerARN string) error