firehose

Documentation

Index

• type FirehoseClient
  • func NewFirehoseClient(config *config.Config) (*FirehoseClient, error)
  • func (c FirehoseClient) Stream(ctx context.Context, event ForwardedEventUploadEvent) (response *firehose_v2.PutRecordOutput, err error)
• type FirehoseClientIface
• type ForwardedEventUploadEvent
• type Metadata

Types

type FirehoseClient

type FirehoseClient struct {
	DataStream string
	Service    FirehoseClientIface
}

func NewFirehoseClient

func NewFirehoseClient(config *config.Config) (*FirehoseClient, error)

func (FirehoseClient) Stream

func (c FirehoseClient) Stream(ctx context.Context, event ForwardedEventUploadEvent) (response *firehose_v2.PutRecordOutput, err error)

type FirehoseClientIface

type FirehoseClientIface interface {
	PutRecord(ctx context.Context, params *firehose_v2.PutRecordInput, optFns ...func(*firehose_v2.Options)) (*firehose_v2.PutRecordOutput, error)
}

type ForwardedEventUploadEvent

type ForwardedEventUploadEvent struct {
	SerialNumber string   `json:"serial_number"`
	Metadata     Metadata `json:"metadata"`
}

type Metadata

type Metadata struct {
	CommonName              string    `json:"common_name"`
	SubjectAlternateName    []string  `json:"subject_alternate_name"`
	CertificateExpiration   time.Time `json:"certificate_expiration"`
	IssuedDate              time.Time `json:"issued_date"`
	CaSerialNumber          string    `json:"ca_serial_number"`
	CertificateAuthorityArn string    `json:"certificate_authority_arn"`
	Timestamp               time.Time `json:"timestamp"`
}