thingfulx

package module

Go to main page

Versions in this module

v0

v0.11.0

Feb 21, 2020

v0.10.0

Jan 24, 2020

Changes in this version

type Channel

+ func (m *Channel) GetProvider() *Provider

type Provider

+ Uid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Provider) Descriptor() ([]byte, []int)

+ func (*Provider) ProtoMessage()

+ func (m *Provider) GetDescription() string

+ func (m *Provider) GetName() string

+ func (m *Provider) GetUid() string

+ func (m *Provider) GetWebpage() string

+ func (m *Provider) Reset()

+ func (m *Provider) String() string

+ func (m *Provider) XXX_DiscardUnknown()

+ func (m *Provider) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Provider) XXX_Merge(src proto.Message)

+ func (m *Provider) XXX_Size() int

+ func (m *Provider) XXX_Unmarshal(b []byte) error

v0.9.0

Nov 30, 2019

Changes in this version

+ const Unknown

+ var DataType_name = map[int32]string

+ var DataType_value = map[string]int32

+ var Visibility_name = map[int32]string

+ var Visibility_value = map[string]int32

type Attribution

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Attribution) Descriptor() ([]byte, []int)

+ func (*Attribution) ProtoMessage()

+ func (m *Attribution) GetName() string

+ func (m *Attribution) GetURL() string

+ func (m *Attribution) Reset()

+ func (m *Attribution) String() string

+ func (m *Attribution) XXX_DiscardUnknown()

+ func (m *Attribution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Attribution) XXX_Merge(src proto.Message)

+ func (m *Attribution) XXX_Size() int

+ func (m *Attribution) XXX_Unmarshal(b []byte) error

type Channel

+ DataType DataType

+ ProviderUid string

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Channel) Descriptor() ([]byte, []int)

+ func (*Channel) ProtoMessage()

+ func (m *Channel) GetAttributions() []*Attribution

+ func (m *Channel) GetDataLicense() *DataLicense

+ func (m *Channel) GetDataType() DataType

+ func (m *Channel) GetDescription() string

+ func (m *Channel) GetDomainOfInterest() []string

+ func (m *Channel) GetIndexedAt() string

+ func (m *Channel) GetLocation() *Location

+ func (m *Channel) GetMeasuredBy() string

+ func (m *Channel) GetMetadata() []*Metadata

+ func (m *Channel) GetObservations() []*Observation

+ func (m *Channel) GetProviderUid() string

+ func (m *Channel) GetQuantityKind() string

+ func (m *Channel) GetTitle() string

+ func (m *Channel) GetUnit() string

+ func (m *Channel) GetUpdateInterval() int32

+ func (m *Channel) GetUrl() string

+ func (m *Channel) GetVisibility() Visibility

+ func (m *Channel) GetWebpage() string

+ func (m *Channel) Reset()

+ func (m *Channel) String() string

+ func (m *Channel) XXX_DiscardUnknown()

+ func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Channel) XXX_Merge(src proto.Message)

+ func (m *Channel) XXX_Size() int

+ func (m *Channel) XXX_Unmarshal(b []byte) error

type DataLicense

+ LegalCodeUrl string

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DataLicense) Descriptor() ([]byte, []int)

+ func (*DataLicense) ProtoMessage()

+ func (m *DataLicense) GetLegalCodeUrl() string

+ func (m *DataLicense) GetName() string

+ func (m *DataLicense) GetPermits() []string

+ func (m *DataLicense) GetProhibits() []string

+ func (m *DataLicense) GetRequires() []string

+ func (m *DataLicense) GetUrl() string

+ func (m *DataLicense) Reset()

+ func (m *DataLicense) String() string

+ func (m *DataLicense) XXX_DiscardUnknown()

+ func (m *DataLicense) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataLicense) XXX_Merge(src proto.Message)

+ func (m *DataLicense) XXX_Size() int

+ func (m *DataLicense) XXX_Unmarshal(b []byte) error

+ type DataType int32

+ const DataType_BOOLEAN

+ const DataType_BYTES

+ const DataType_DATE_TIME

+ const DataType_INTEGER

+ const DataType_NUMBER

+ const DataType_STRING

+ const DataType_TIME

+ const DataType_UNKNOWN

+ func (DataType) EnumDescriptor() ([]byte, []int)

+ func (x DataType) String() string

type Location

+ Latitude float32

+ Longitude float32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Location) Descriptor() ([]byte, []int)

+ func (*Location) ProtoMessage()

+ func (m *Location) GetElevation() float32

+ func (m *Location) GetLatitude() float32

+ func (m *Location) GetLongitude() float32

+ func (m *Location) Reset()

+ func (m *Location) String() string

+ func (m *Location) XXX_DiscardUnknown()

+ func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Location) XXX_Merge(src proto.Message)

+ func (m *Location) XXX_Size() int

+ func (m *Location) XXX_Unmarshal(b []byte) error

type Metadata

+ Property string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (m *Metadata) GetProperty() string

+ func (m *Metadata) GetValue() string

+ func (m *Metadata) Reset()

+ func (m *Metadata) String() string

+ func (m *Metadata) XXX_DiscardUnknown()

+ func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Metadata) XXX_Merge(src proto.Message)

+ func (m *Metadata) XXX_Size() int

+ func (m *Metadata) XXX_Unmarshal(b []byte) error

type Observation

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Observation) Descriptor() ([]byte, []int)

+ func (*Observation) ProtoMessage()

+ func (m *Observation) GetLocation() *Location

+ func (m *Observation) GetRecordedAt() string

+ func (m *Observation) GetValue() string

+ func (m *Observation) Reset()

+ func (m *Observation) String() string

+ func (m *Observation) XXX_DiscardUnknown()

+ func (m *Observation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Observation) XXX_Merge(src proto.Message)

+ func (m *Observation) XXX_Size() int

+ func (m *Observation) XXX_Unmarshal(b []byte) error

type Visibility

+ const Visibility_CLOSED

+ const Visibility_OPEN

+ const Visibility_SHARED

+ func (Visibility) EnumDescriptor() ([]byte, []int)

v0.8.3

Nov 19, 2019

v0.8.2

Nov 19, 2019

v0.8.1

Nov 19, 2019

Changes in this version

type Channel

+ ProviderUID string

type Indexer

+ Provider func() *Provider

v0.8.0

Nov 16, 2019

Changes in this version

+ const AttributionReq

+ const CommercialUseProhib

+ const CopyleftReq

+ const DerivativeWorksPerm

+ const DistributionPerm

+ const ErrRobotsForbidden

+ const HighIncomeNationUseProhib

+ const LesserCopyleftReq

+ const NoticeReq

+ const ReproductionPerm

+ const ShareAlikeReq

+ const SharingPerm

+ const SourceCodeReq

type Attribution

+ Name string

+ URL string

type Channel

+ Attributions []Attribution

+ ContentType string

+ DataLicense *DataLicense

+ Description string

+ IndexedAt time.Time

+ Location *Location

+ Provider *Provider

+ Title string

+ URL string

+ UpdateInterval int32

+ Visibility Visibility

+ Webpage string

+ type Permission string

+ type Prohibition string

type Provider

+ UID string

+ Webpage string

+ type Requirement string

v0.7.0

Jul 8, 2019

v0.6.3

Jun 28, 2019

v0.6.2

Jun 27, 2019

v0.6.1

Jun 27, 2019

Changes in this version

type Clock

+ func NewMockClockAt(t time.Time) Clock

v0.6.0

Jun 27, 2019

Changes in this version

+ type Clock interface

+ Now func() time.Time

+ func NewClock() Clock

+ func NewMockClock(t time.Time) Clock

+ type DefaultClock struct

+ func (c DefaultClock) Now() time.Time

+ type MockClock struct

+ func (t MockClock) Now() time.Time

v0.5.1

May 1, 2019

v0.5.0

May 1, 2019

v0.4.0

May 1, 2019

Changes in this version

+ type URLData struct

+ Err error

+ URLS []string

v0.3.0

Apr 30, 2019

Changes in this version

type Client

+ GetHTTP func(ctx context.Context, urlStr string) ([]byte, error)

+ PostHTTP func(ctx context.Context, urlStr, contentType string, body io.Reader) ([]byte, error)

type Indexer

+ Fetch func(ctx context.Context, urlStr string, client Client) ([]byte, error)

+ Parse func(rawData []byte, urlStr string, timeProvider TimeProvider) ([]Thing, error)

+ UID func() string

+ URLS func(ctx context.Context, client Client, delay time.Duration, out chan<- []string) error

v0.2.6

Feb 26, 2018

Changes in this version

+ const Attribution

+ const CC0V1URL

+ const CCByNCSAV3URL

+ const CCByNCV3URL

+ const CCByNDV3URL

+ const CCBySAV4URL

+ const CCByV3URL

+ const CCByV4URL

+ const ClientToken

+ const Closed

+ const CommercialUse

+ const Copyleft

+ const DerivativeWorks

+ const Distribution

+ const Energy

+ const Environment

+ const ErrInvalidData

+ const ErrInvalidLocation

+ const ErrInvalidTime

+ const ErrInvalidURL

+ const ErrNotFound

+ const Experiment

+ const Flora

+ const Health

+ const HighIncomeNationUse

+ const Home

+ const IODLV2URL

+ const LesserCopyleft

+ const Miscellaneous

+ const Notice

+ const ODCByV1URL

+ const ODbLV1URL

+ const OGLV2URL

+ const OGLV3URL

+ const Open

+ const PDDLV1URL

+ const Reproduction

+ const SGODLV1

+ const ShareAlike

+ const Shared

+ const Sharing

+ const SourceCode

+ const Transport

+ type Category string

+ func Categorise(str string) Category

+ func (c Category) String() string

+ type Channel struct

+ DomainOfInterest []string

+ ID string

+ MeasuredBy string

+ Metadata []Metadata

+ Observations []Observation

+ QuantityKind string

+ Type schema.DataType

+ Unit string

+ type Client interface

+ DoHTTP func(req *http.Request) (*http.Response, error)

+ DoHTTPGetRequest func(urlString string) ([]byte, error)

+ Get func(urlStr string) ([]byte, error)

+ func NewClient(userAgent string, timeout time.Duration) Client

+ type ContextKey string

+ type DataLicense struct

+ LegalCodeURL string

+ Name string

+ Permits []string

+ Prohibits []string

+ Requires []string

+ URL string

+ func GetDataLicense(licenseURL string) *DataLicense

+ type DefaultTimeProvider struct

+ func (t DefaultTimeProvider) Now() time.Time

+ type Endpoint struct

+ ContentType string

+ URL string

+ type ErrBadData struct

+ Msg string

+ func NewErrBadData(msg string) *ErrBadData

+ func (e *ErrBadData) Error() string

+ type ErrMissingConfig struct

+ Variable string

+ func NewErrMissingConfig(variable string) *ErrMissingConfig

+ func (e *ErrMissingConfig) Error() string

+ type ErrUnexpectedResponse struct

+ Status string

+ func NewErrUnexpectedResponse(status string) *ErrUnexpectedResponse

+ func (e *ErrUnexpectedResponse) Error() string

+ type Error string

+ func (e Error) Error() string

+ type Fetcher interface

+ Fetch func(ctx context.Context, urlStr string, client Client) ([]byte, error)

+ type Indexer interface

+ type IndexerBuilder func() (Indexer, error)

+ type Location struct

+ Elevation float64

+ Lat float64

+ Lng float64

+ type Metadata struct

+ Prop string

+ Val string

+ type MockTimeProvider struct

+ InternalTime time.Time

+ func (t MockTimeProvider) Now() time.Time

+ type Observation struct

+ Location *Location

+ RecordedAt time.Time

+ Val string

+ type Parser interface

+ Parse func(rawData []byte, urlStr string, timeProvider TimeProvider) ([]Thing, error)

+ type Provider struct

+ Description string

+ ID string

+ Name string

+ URL string

+ type Thing struct

+ AttributionName string

+ AttributionURL string

+ Category Category

+ Channels []Channel

+ DataLicense *DataLicense

+ Description string

+ Endpoint *Endpoint

+ IndexedAt time.Time

+ Location *Location

+ Metadata []Metadata

+ Provider *Provider

+ ThingType string

+ Title string

+ UpdateInterval int

+ Visibility Visibility

+ Webpage string

+ func (t *Thing) MetaVal(prop string) string

+ type TimeProvider interface

+ Now func() time.Time

+ func NewMockTimeProvider(t time.Time) TimeProvider

+ func NewTimeProvider() TimeProvider

+ type UIDable interface

+ UID func() string

+ type URLProvider interface

+ URLS func(ctx context.Context, client Client, delay time.Duration) ([]string, error)

+ type Visibility string

+ func (v Visibility) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL