models

package

v0.6.0 Latest Latest Go to latest Published: Dec 13, 2018 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ElasticRecord struct {
	Index string
	Type  string
	ID    string
	Json  map[string]interface{}
}

type Record struct {
	Topic     string
	Partition int32
	Offset    int64
	Timestamp time.Time
	Json      map[string]interface{}
}

func (r *Record) FilteredFieldsJSON(blacklistedFields []string) map[string]interface{}

func (r *Record) FormatTimestampDay() string

func (r *Record) FormatTimestampHour() string

func (r *Record) GetId() string

func (r *Record) GetValueForField(field string) (string, error)