firehose

Documentation

Overview

Package firehose provides a basic emulation of Amazon Data Firehose (formerly Kinesis Data Firehose).

Implemented operations: CreateDeliveryStream, DescribeDeliveryStream, ListDeliveryStreams, DeleteDeliveryStream, PutRecord, PutRecordBatch.

Records are accepted but silently discarded (no S3 buffering).

Index

• type DeliveryStream
• type Service
  • func New(cfg *config.Config, st state.Store, logger *zap.Logger, _ clock.Clock) *Service
  • func (s *Service) Dispatch(w http.ResponseWriter, r *http.Request)
  • func (s *Service) Name() string
  • func (s *Service) Operations() []op.Operation
  • func (s *Service) RegisterRoutes(_ chi.Router)
  • func (s *Service) SupportedProtocols() []codec.Codec
  • func (s *Service) TargetPrefix() string

Types

type DeliveryStream

type DeliveryStream struct {
	DeliveryStreamName   string `json:"DeliveryStreamName"`
	DeliveryStreamARN    string `json:"DeliveryStreamARN"`
	DeliveryStreamStatus string `json:"DeliveryStreamStatus"`
	DeliveryStreamType   string `json:"DeliveryStreamType"`
}

DeliveryStream represents a Firehose delivery stream.

type Service

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

Service implements router.Service and router.TargetDispatcher for Firehose.

func New

func New(cfg *config.Config, st state.Store, logger *zap.Logger, _ clock.Clock) *Service

New returns a configured Firehose Service.

func (*Service) Dispatch

func (s *Service) Dispatch(w http.ResponseWriter, r *http.Request)

func (*Service) Name

func (s *Service) Name() string

func (*Service) Operations

func (s *Service) Operations() []op.Operation

func (*Service) RegisterRoutes

func (s *Service) RegisterRoutes(_ chi.Router)

func (*Service) SupportedProtocols

func (s *Service) SupportedProtocols() []codec.Codec

func (*Service) TargetPrefix

func (s *Service) TargetPrefix() string