ammo

type Ammo interface{}

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

type Decoder interface {
	Decode([]byte, Ammo) (Ammo, error)
}

type Http struct {
	Host    string
	Method  string
	Uri     string
	Headers map[string]string
	Tag     string
}

type HttpJSONDecoder struct{}

type HttpProvider struct {
	*BaseProvider
	// contains filtered or unexported fields
}

type Log struct {
	Message string
}

type LogJSONDecoder struct{}

type LogProvider struct {
	*BaseProvider
	// contains filtered or unexported fields
}

type Provider interface {
	Start(context.Context) error
	Source() <-chan Ammo
	Release(Ammo) // return unused Ammo object to memory pool
}