rest

Sep 13, 2018

Changes in this version

+ type AssetCache struct

+ func NewAssetCache(maxSize int64, pruneItems int) *AssetCache

+ func (c *AssetCache) Include(data json.RawMessage) error

+ func (c *AssetCache) Shutdown()

+ type AssetReader func(data json.RawMessage) (interface{}, error)

+ type AssetType string

+ type MockServerSource struct

+ func NewMockServerSource(cache *AssetCache) *MockServerSource

+ func (s *MockServerSource) MarshalJSON() ([]byte, error)

+ func (s *MockServerSource) MockResponse(url string, response json.RawMessage)

+ func (s *MockServerSource) MockedRequests() []string

+ type ServerSource struct

+ func NewServerSource(authToken string, typeURLs map[AssetType]string, httpClient *utils.HTTPClient, ...) *ServerSource

+ func ReadServerSource(authToken string, httpClient *utils.HTTPClient, cache *AssetCache, ...) (*ServerSource, error)

+ func (s *ServerSource) Channels() ([]assets.Channel, error)

+ func (s *ServerSource) Fields() ([]assets.Field, error)

+ func (s *ServerSource) Flow(uuid assets.FlowUUID) (assets.Flow, error)

+ func (s *ServerSource) Groups() ([]assets.Group, error)

+ func (s *ServerSource) Labels() ([]assets.Label, error)

+ func (s *ServerSource) Locations() ([]assets.LocationHierarchy, error)

+ func (s *ServerSource) Resthooks() ([]assets.Resthook, error)