v3ioitempoller

Documentation

Index

• type Configuration
• type Event
  • func (e *Event) GetHeader(key string) interface{}
  • func (e *Event) GetHeaders() map[string]interface{}
  • func (e *Event) GetPath() string
  • func (e *Event) GetSize() int
  • func (e *Event) GetTimestamp() time.Time
  • func (e *Event) GetURL() string

Types

type Configuration

type Configuration struct {
	poller.Configuration
	Restart        bool
	URL            string
	ContainerID    int
	ContainerAlias string
	Paths          []string
	Attributes     []string
	Queries        []string
	Suffixes       []string
	Incremental    bool
	ShardID        int
	TotalShards    int
}

type Event

type Event struct {
	processor.AbstractEvent
	// contains filtered or unexported fields
}

func (*Event) GetHeader

func (e *Event) GetHeader(key string) interface{}

func (*Event) GetHeaders

func (e *Event) GetHeaders() map[string]interface{}

func (*Event) GetPath

func (e *Event) GetPath() string

func (*Event) GetSize

func (e *Event) GetSize() int

func (*Event) GetTimestamp

func (e *Event) GetTimestamp() time.Time

func (*Event) GetURL

func (e *Event) GetURL() string