Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrMalformedEvent = errors.New("malformed event")
)
Functions ¶
func NewInventoryEventBuilder ¶
func NewInventoryEventBuilder() entities.EventBuilder
Types ¶
type Config ¶
type GCPConsumer ¶
type GCPConsumer struct {
// contains filtered or unexported fields
}
func New ¶
func New(options *ConsumerOptions, cfg config.GenericConfig, pipeline pipeline.IPipelineGroup, eventBuilder entities.EventBuilder) (*GCPConsumer, error)
func (*GCPConsumer) Close ¶
func (g *GCPConsumer) Close() error
type InventoryEvent ¶
type InventoryEvent struct {
Asset InventoryEventAsset `json:"asset"`
PriorAsset InventoryEventAsset `json:"priorAsset"`
PriorAssetState string `json:"priorAssetState"`
Window InventoryEventWindow `json:"window"`
Deleted bool `json:"deleted"`
}
type InventoryEventAsset ¶
type InventoryEventBuilder ¶
type InventoryEventBuilder struct{}
func (*InventoryEventBuilder) GetPipelineEvent ¶
func (b *InventoryEventBuilder) GetPipelineEvent(_ context.Context, data []byte) (entities.PipelineEvent, error)
type InventoryEventWindow ¶
type InventoryEventWindow struct {
StartTime string `json:"startTime"`
}
Click to show internal directories.
Click to hide internal directories.