toyhose

README

toyhose

AWS Firehose emulation

icon	detail
🙆‍♀️	implemented!
👷	under construction (in roadmap)
🙊	not implemented (not in roadmap)

• 🙆‍♀️ CreateDeliveryStream
  • 🙊 ElasticsearchDestinationConfiguration
  • 👷 ExtendedS3DestinationConfiguration
  • 🙆‍♀️ KinesisStreamSourceConfiguration
  • 🙊 RedshiftDestinationConfiguration
  • 🙆‍♀️ S3DestinationConfiguration
  • 🙊 SplunkDestinationConfiguration
• 🙆‍♀️ DeleteDeliveryStream
• 🙆‍♀️ DescribeDeliveryStream
• 🙆‍♀️ ListDeliveryStreams
• 🙊 ListTagsForDeliveryStream
• 🙆‍♀️ PutRecord
• 🙆‍♀️ PutRecordBatch
• 🙊 StartDeliveryStreamEncryption
• 🙊 StopDeliveryStreamEncryption
• 🙊 TagDeliveryStream
• 🙊 UntagDeliveryStream
• 🙊 UpdateDestination

Documentation

Index

• func Logger() zerolog.Logger
• func SetupLogger() error
• type DeliveryStreamService
  • func (s *DeliveryStreamService) Create(ctx context.Context, input []byte) (*firehose.CreateDeliveryStreamOutput, error)
  • func (s *DeliveryStreamService) Delete(ctx context.Context, input []byte) (*firehose.DeleteDeliveryStreamOutput, error)
  • func (s *DeliveryStreamService) Describe(ctx context.Context, input []byte) (*firehose.DescribeDeliveryStreamOutput, error)
  • func (s *DeliveryStreamService) Listing(ctx context.Context, input []byte) (*firehose.ListDeliveryStreamsOutput, error)
  • func (s *DeliveryStreamService) Put(ctx context.Context, input []byte) (*firehose.PutRecordOutput, error)
  • func (s *DeliveryStreamService) PutBatch(ctx context.Context, input []byte) (*firehose.PutRecordBatchOutput, error)
• type Dispatcher
  • func NewDispatcher(conf *DispatcherConfig) *Dispatcher
  • func (d *Dispatcher) Dispatch(w http.ResponseWriter, r *http.Request)
• type DispatcherConfig
• type KinesisInjectedConf
• type S3InjectedConf

Functions

func Logger

func Logger() zerolog.Logger

Logger returns zerolog.Logger instance.

func SetupLogger

func SetupLogger() error

SetupLogger provides setting up logger for toyhose.

Types

type DeliveryStreamService

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

DeliveryStreamService represents interface for operating DeliveryStream resources.

func (*DeliveryStreamService) Create

func (s *DeliveryStreamService) Create(ctx context.Context, input []byte) (*firehose.CreateDeliveryStreamOutput, error)

Create provides creating DeliveryStream resource operation.

func (*DeliveryStreamService) Delete

func (s *DeliveryStreamService) Delete(ctx context.Context, input []byte) (*firehose.DeleteDeliveryStreamOutput, error)

Delete provides deleting DeliveryStream resource operation.

func (*DeliveryStreamService) Describe

func (s *DeliveryStreamService) Describe(ctx context.Context, input []byte) (*firehose.DescribeDeliveryStreamOutput, error)

Describe returns current deliveryStream definitions and statuses by supplied deliveryStreamName.

func (*DeliveryStreamService) Listing

func (s *DeliveryStreamService) Listing(ctx context.Context, input []byte) (*firehose.ListDeliveryStreamsOutput, error)

Listing returns registered deliveryStream names.

func (*DeliveryStreamService) Put

func (s *DeliveryStreamService) Put(ctx context.Context, input []byte) (*firehose.PutRecordOutput, error)

Put provides accepting single record data for sending to DeliveryStream.

func (*DeliveryStreamService) PutBatch

func (s *DeliveryStreamService) PutBatch(ctx context.Context, input []byte) (*firehose.PutRecordBatchOutput, error)

PutBatch provides accepting multiple record data for sending to DeliveryStream.

type Dispatcher

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

Dispatcher represents firehose API handler.

func NewDispatcher

func NewDispatcher(conf *DispatcherConfig) *Dispatcher

NewDispatcher returns Dispatcher object.

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(w http.ResponseWriter, r *http.Request)

Dispatch handlers HTTP request as http.HandlerFunc interface.

type DispatcherConfig

type DispatcherConfig struct {
	S3InjectedConf      S3InjectedConf
	KinesisInjectedConf KinesisInjectedConf
	AWSConf             *aws.Config
}

DispatcherConfig represents configuration data struct for Dispatcher.

type KinesisInjectedConf

type KinesisInjectedConf struct {
	Endpoint *string
}

KinesisInjectedConf represents configuration of KinesisStream source.

type S3InjectedConf

type S3InjectedConf struct {
	SizeInMBs         *int
	IntervalInSeconds *int
	EndPoint          *string
	DisableBuffering  bool
}

S3InjectedConf represents injection to S3 destination BufferingHints forcely.