README
¶
toyhose
AWS Firehose emulation
| icon | detail |
|---|---|
| 🙆♀️ | implemented! |
| 👷 | under construction (in roadmap) |
| 🙊 | not implemented (not in roadmap) |
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
- type DispatcherConfig
- type KinesisInjectedConf
- type S3InjectedConf
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 ¶ added in v0.2.0
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 ¶ added in v0.2.0
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.
Source Files
Directories