Versions in this module Expand all Collapse all v0 v0.1.1 Aug 7, 2020 v0.1.0 Jul 24, 2019 Changes in this version + func LastModified(body interface{}) int64 + func NewDefaultRecord(rtype string, source string, id int64, uri string, body interface{}, ...) (catalog.Record, error) + func NewElasticsearchRecord(id int64, uri string, body interface{}, t time.Duration) (catalog.Record, error) + func NewErrorRecord(source string, id int64, uri string, err error, t time.Duration) (catalog.Record, error) + type DefaultRecord struct + RecordBody interface{} + RecordHash string + RecordID int64 + RecordLastModified int64 + RecordSource string + RecordTiming time.Duration + RecordType string + RecordURI string + func (r *DefaultRecord) Body() interface{} + func (r *DefaultRecord) Id() int64 + func (r *DefaultRecord) LastModified() int64 + func (r *DefaultRecord) Source() string + func (r *DefaultRecord) Timing() time.Duration + func (r *DefaultRecord) Type() string + func (r *DefaultRecord) URI() string + type ElasticsearchRecord struct + RecordBody interface{} + RecordHash string + RecordID int64 + RecordLastModified int64 + RecordSource string + RecordTiming time.Duration + RecordType string + RecordURI string + func (r *ElasticsearchRecord) Body() interface{} + func (r *ElasticsearchRecord) Id() int64 + func (r *ElasticsearchRecord) LastModified() int64 + func (r *ElasticsearchRecord) Source() string + func (r *ElasticsearchRecord) Timing() time.Duration + func (r *ElasticsearchRecord) Type() string + func (r *ElasticsearchRecord) URI() string