announcement

Aug 30, 2017

Changes in this version

+ type GatewayIDMetadata struct

+ GatewayID string

+ func (m GatewayIDMetadata) MarshalText() ([]byte, error)

+ func (m GatewayIDMetadata) ToProto() *pb.Metadata

type RedisAnnouncementStore

+ func (s *RedisAnnouncementStore) GetForGatewayID(gatewayID string) (*Announcement, error)

type Store

+ GetForGatewayID func(gatewayID string) (*Announcement, error)

Feb 7, 2017

Changes in this version

type Announcement

+ func (a *Announcement) DBVersion() string

Jan 10, 2017

Changes in this version

type Announcement

+ AMQPAddress string

+ MQTTAddress string

Dec 14, 2016

Changes in this version

+ var DefaultCacheOptions = CacheOptions

+ type Announcement struct

+ APIAddress string

+ Certificate string

+ CreatedAt time.Time

+ Description string

+ ID string

+ Metadata []Metadata

+ NetAddress string

+ Public bool

+ PublicKey string

+ ServiceName string

+ ServiceVersion string

+ URL string

+ UpdatedAt time.Time

+ func FromProto(a *pb.Announcement) Announcement

+ func (a *Announcement) StartUpdate()

+ func (a Announcement) ChangedFields() (changed []string)

+ func (a Announcement) ToProto() *pb.Announcement

+ type AppEUIMetadata struct

+ AppEUI types.AppEUI

+ func (m AppEUIMetadata) MarshalText() ([]byte, error)

+ func (m AppEUIMetadata) ToProto() *pb.Metadata

+ type AppIDMetadata struct

+ AppID string

+ func (m AppIDMetadata) MarshalText() ([]byte, error)

+ func (m AppIDMetadata) ToProto() *pb.Metadata

+ type CacheOptions struct

+ ListCacheExpiration time.Duration

+ ListCacheSize int

+ ServiceCacheExpiration time.Duration

+ ServiceCacheSize int

+ type Metadata interface

+ ToProto func() *pb.Metadata

+ func MetadataFromProto(proto *pb.Metadata) Metadata

+ func MetadataFromString(str string) Metadata

+ type PrefixMetadata struct

+ Prefix types.DevAddrPrefix

+ func (m PrefixMetadata) MarshalText() ([]byte, error)

+ func (m PrefixMetadata) ToProto() *pb.Metadata

+ type RedisAnnouncementStore struct

+ func (s *RedisAnnouncementStore) AddMetadata(serviceName, serviceID string, metadata ...Metadata) error

+ func (s *RedisAnnouncementStore) Delete(serviceName, serviceID string) error

+ func (s *RedisAnnouncementStore) Get(serviceName, serviceID string) (*Announcement, error)

+ func (s *RedisAnnouncementStore) GetForAppEUI(appEUI types.AppEUI) (*Announcement, error)

+ func (s *RedisAnnouncementStore) GetForAppID(appID string) (*Announcement, error)

+ func (s *RedisAnnouncementStore) GetMetadata(serviceName, serviceID string) ([]Metadata, error)

+ func (s *RedisAnnouncementStore) List() ([]*Announcement, error)

+ func (s *RedisAnnouncementStore) ListService(serviceName string) ([]*Announcement, error)

+ func (s *RedisAnnouncementStore) RemoveMetadata(serviceName, serviceID string, metadata ...Metadata) error

+ func (s *RedisAnnouncementStore) Set(new *Announcement) error

+ type Store interface

+ AddMetadata func(serviceName, serviceID string, metadata ...Metadata) error

+ Delete func(serviceName, serviceID string) error

+ Get func(serviceName, serviceID string) (*Announcement, error)

+ GetForAppEUI func(appEUI types.AppEUI) (*Announcement, error)

+ GetForAppID func(appID string) (*Announcement, error)

+ GetMetadata func(serviceName, serviceID string) ([]Metadata, error)

+ List func() ([]*Announcement, error)

+ ListService func(serviceName string) ([]*Announcement, error)

+ RemoveMetadata func(serviceName, serviceID string, metadata ...Metadata) error

+ Set func(new *Announcement) error

+ func NewCachedAnnouncementStore(store Store, options CacheOptions) Store

+ func NewRedisAnnouncementStore(client *redis.Client, prefix string) Store