discovery

Jul 5, 2017

Changes in this version

type DiscoveryClient

+ GetByAppEUI func(ctx context.Context, in *GetByAppEUIRequest, opts ...grpc.CallOption) (*Announcement, error)

+ GetByAppID func(ctx context.Context, in *GetByAppIDRequest, opts ...grpc.CallOption) (*Announcement, error)

type DiscoveryServer

+ GetByAppEUI func(context.Context, *GetByAppEUIRequest) (*Announcement, error)

+ GetByAppID func(context.Context, *GetByAppIDRequest) (*Announcement, error)

+ type GetByAppEUIRequest struct

+ AppEui *github_com_TheThingsNetwork_ttn_core_types.AppEUI

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

+ func (*GetByAppEUIRequest) ProtoMessage()

+ func (m *GetByAppEUIRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetByAppEUIRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetByAppEUIRequest) Reset()

+ func (m *GetByAppEUIRequest) Size() (n int)

+ func (m *GetByAppEUIRequest) Unmarshal(dAtA []byte) error

+ func (this *GetByAppEUIRequest) Equal(that interface{}) bool

+ func (this *GetByAppEUIRequest) String() string

+ func (this *GetByAppEUIRequest) VerboseEqual(that interface{}) error

+ type GetByAppIDRequest struct

+ AppId string

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

+ func (*GetByAppIDRequest) ProtoMessage()

+ func (m *GetByAppIDRequest) GetAppId() string

+ func (m *GetByAppIDRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetByAppIDRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetByAppIDRequest) Reset()

+ func (m *GetByAppIDRequest) Size() (n int)

+ func (m *GetByAppIDRequest) Unmarshal(dAtA []byte) error

+ func (this *GetByAppIDRequest) Equal(that interface{}) bool

+ func (this *GetByAppIDRequest) String() string

+ func (this *GetByAppIDRequest) VerboseEqual(that interface{}) error

May 9, 2017

Changes in this version

type Announcement

+ func (this *Announcement) Equal(that interface{}) bool

+ func (this *Announcement) VerboseEqual(that interface{}) error

type AnnouncementsResponse

+ func (this *AnnouncementsResponse) Equal(that interface{}) bool

+ func (this *AnnouncementsResponse) VerboseEqual(that interface{}) error

type GetRequest

+ func (this *GetRequest) Equal(that interface{}) bool

+ func (this *GetRequest) VerboseEqual(that interface{}) error

type GetServiceRequest

+ func (this *GetServiceRequest) Equal(that interface{}) bool

+ func (this *GetServiceRequest) VerboseEqual(that interface{}) error

type Metadata

+ func (this *Metadata) Equal(that interface{}) bool

+ func (this *Metadata) VerboseEqual(that interface{}) error

type MetadataRequest

+ func (this *MetadataRequest) Equal(that interface{}) bool

+ func (this *MetadataRequest) VerboseEqual(that interface{}) error

type Metadata_AppEui

+ func (this *Metadata_AppEui) Equal(that interface{}) bool

+ func (this *Metadata_AppEui) String() string

+ func (this *Metadata_AppEui) VerboseEqual(that interface{}) error

type Metadata_AppId

+ func (this *Metadata_AppId) Equal(that interface{}) bool

+ func (this *Metadata_AppId) String() string

+ func (this *Metadata_AppId) VerboseEqual(that interface{}) error

type Metadata_DevAddrPrefix

+ func (this *Metadata_DevAddrPrefix) Equal(that interface{}) bool

+ func (this *Metadata_DevAddrPrefix) String() string

+ func (this *Metadata_DevAddrPrefix) VerboseEqual(that interface{}) error

Mar 23, 2017

Changes in this version

type Announcement

+ func (a *Announcement) TLSConfig() (*tls.Config, error)

+ func (a *Announcement) WithSecure() grpc.DialOption

Jan 23, 2017

Changes in this version

type Announcement

+ func (m *Announcement) GetAmqpAddress() string

+ func (m *Announcement) GetApiAddress() string

+ func (m *Announcement) GetCertificate() string

+ func (m *Announcement) GetDescription() string

+ func (m *Announcement) GetId() string

+ func (m *Announcement) GetMqttAddress() string

+ func (m *Announcement) GetNetAddress() string

+ func (m *Announcement) GetPublic() bool

+ func (m *Announcement) GetPublicKey() string

+ func (m *Announcement) GetServiceName() string

+ func (m *Announcement) GetServiceVersion() string

+ func (m *Announcement) GetUrl() string

type GetRequest

+ func (m *GetRequest) GetId() string

+ func (m *GetRequest) GetServiceName() string

type GetServiceRequest

+ func (m *GetServiceRequest) GetServiceName() string

type MetadataRequest

+ func (m *MetadataRequest) GetId() string

+ func (m *MetadataRequest) GetServiceName() string

Jan 10, 2017

Changes in this version

type Announcement

+ AmqpAddress string

+ MqttAddress string

Dec 14, 2016

Changes in this version

+ var CacheExpiration = 5 * time.Minute

+ var CacheSize = 1000

+ var ErrIntOverflowDiscovery = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDiscovery = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterDiscoveryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterDiscoveryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterDiscoveryManagerServer(s *grpc.Server, srv DiscoveryManagerServer)

+ func RegisterDiscoveryServer(s *grpc.Server, srv DiscoveryServer)

+ type Announcement struct

+ ApiAddress string

+ Certificate string

+ Description string

+ Id string

+ Metadata []*Metadata

+ NetAddress string

+ Public bool

+ PublicKey string

+ ServiceName string

+ ServiceVersion string

+ Url string

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

+ func (*Announcement) ProtoMessage()

+ func (a *Announcement) AppEUIs() (euis []types.AppEUI)

+ func (a *Announcement) AppIDs() (appIDs []string)

+ func (a *Announcement) DevAddrPrefixes() (prefixes []types.DevAddrPrefix)

+ func (a *Announcement) Dial() (*grpc.ClientConn, error)

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

+ func (m *Announcement) Marshal() (dAtA []byte, err error)

+ func (m *Announcement) MarshalTo(dAtA []byte) (int, error)

+ func (m *Announcement) Reset()

+ func (m *Announcement) Size() (n int)

+ func (m *Announcement) String() string

+ func (m *Announcement) Unmarshal(dAtA []byte) error

+ func (m *Announcement) Validate() error

+ type AnnouncementsResponse struct

+ Services []*Announcement

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

+ func (*AnnouncementsResponse) ProtoMessage()

+ func (m *AnnouncementsResponse) GetServices() []*Announcement

+ func (m *AnnouncementsResponse) Marshal() (dAtA []byte, err error)

+ func (m *AnnouncementsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *AnnouncementsResponse) Reset()

+ func (m *AnnouncementsResponse) Size() (n int)

+ func (m *AnnouncementsResponse) String() string

+ func (m *AnnouncementsResponse) Unmarshal(dAtA []byte) error

+ type Client interface

+ AddAppID func(appID string, token string) error

+ AddDevAddrPrefix func(prefix types.DevAddrPrefix) error

+ Announce func(token string) error

+ Close func() error

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

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

+ GetAllBrokersForDevAddr func(devAddr types.DevAddr) ([]*Announcement, error)

+ GetAllHandlersForAppID func(appID string) ([]*Announcement, error)

+ RemoveAppID func(appID string, token string) error

+ RemoveDevAddrPrefix func(prefix types.DevAddrPrefix) error

+ func NewClient(server string, announcement *Announcement, tokenFunc func() string) (Client, error)

+ type DefaultClient struct

+ func (c *DefaultClient) AddAppID(appID string, token string) error

+ func (c *DefaultClient) AddDevAddrPrefix(prefix types.DevAddrPrefix) error

+ func (c *DefaultClient) Announce(token string) error

+ func (c *DefaultClient) Close() error

+ func (c *DefaultClient) Get(serviceName, id string) (*Announcement, error)

+ func (c *DefaultClient) GetAll(serviceName string) ([]*Announcement, error)

+ func (c *DefaultClient) GetAllBrokersForDevAddr(devAddr types.DevAddr) (announcements []*Announcement, err error)

+ func (c *DefaultClient) GetAllHandlersForAppID(appID string) (announcements []*Announcement, err error)

+ func (c *DefaultClient) RemoveAppID(appID string, token string) error

+ func (c *DefaultClient) RemoveDevAddrPrefix(prefix types.DevAddrPrefix) error

+ type DiscoveryClient interface

+ AddMetadata func(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ Announce func(ctx context.Context, in *Announcement, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ DeleteMetadata func(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)

+ Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Announcement, error)

+ GetAll func(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*AnnouncementsResponse, error)

+ func NewDiscoveryClient(cc *grpc.ClientConn) DiscoveryClient

+ type DiscoveryManagerClient interface

+ func NewDiscoveryManagerClient(cc *grpc.ClientConn) DiscoveryManagerClient

+ type DiscoveryManagerServer interface

+ type DiscoveryServer interface

+ AddMetadata func(context.Context, *MetadataRequest) (*google_protobuf.Empty, error)

+ Announce func(context.Context, *Announcement) (*google_protobuf.Empty, error)

+ DeleteMetadata func(context.Context, *MetadataRequest) (*google_protobuf.Empty, error)

+ Get func(context.Context, *GetRequest) (*Announcement, error)

+ GetAll func(context.Context, *GetServiceRequest) (*AnnouncementsResponse, error)

+ type GetRequest struct

+ Id string

+ ServiceName string

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

+ func (*GetRequest) ProtoMessage()

+ func (m *GetRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetRequest) Reset()

+ func (m *GetRequest) Size() (n int)

+ func (m *GetRequest) String() string

+ func (m *GetRequest) Unmarshal(dAtA []byte) error

+ type GetServiceRequest struct

+ ServiceName string

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

+ func (*GetServiceRequest) ProtoMessage()

+ func (m *GetServiceRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetServiceRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetServiceRequest) Reset()

+ func (m *GetServiceRequest) Size() (n int)

+ func (m *GetServiceRequest) String() string

+ func (m *GetServiceRequest) Unmarshal(dAtA []byte) error

+ type Metadata struct

+ Metadata isMetadata_Metadata

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

+ func (*Metadata) ProtoMessage()

+ func (*Metadata) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Metadata) GetAppEui() []byte

+ func (m *Metadata) GetAppId() string

+ func (m *Metadata) GetDevAddrPrefix() []byte

+ func (m *Metadata) GetMetadata() isMetadata_Metadata

+ func (m *Metadata) Marshal() (dAtA []byte, err error)

+ func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *Metadata) Reset()

+ func (m *Metadata) Size() (n int)

+ func (m *Metadata) String() string

+ func (m *Metadata) Unmarshal(dAtA []byte) error

+ type MetadataRequest struct

+ Id string

+ Metadata *Metadata

+ ServiceName string

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

+ func (*MetadataRequest) ProtoMessage()

+ func (m *MetadataRequest) GetMetadata() *Metadata

+ func (m *MetadataRequest) Marshal() (dAtA []byte, err error)

+ func (m *MetadataRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *MetadataRequest) Reset()

+ func (m *MetadataRequest) Size() (n int)

+ func (m *MetadataRequest) String() string

+ func (m *MetadataRequest) Unmarshal(dAtA []byte) error

+ type Metadata_AppEui struct

+ AppEui []byte

+ func (m *Metadata_AppEui) MarshalTo(dAtA []byte) (int, error)

+ func (m *Metadata_AppEui) Size() (n int)

+ type Metadata_AppId struct

+ AppId string

+ func (m *Metadata_AppId) MarshalTo(dAtA []byte) (int, error)

+ func (m *Metadata_AppId) Size() (n int)

+ type Metadata_DevAddrPrefix struct

+ DevAddrPrefix []byte

+ func (m *Metadata_DevAddrPrefix) MarshalTo(dAtA []byte) (int, error)

+ func (m *Metadata_DevAddrPrefix) Size() (n int)

+ type MockClient struct

+ func NewMockClient(ctrl *gomock.Controller) *MockClient

+ func (_m *MockClient) AddAppID(appID string, token string) error

+ func (_m *MockClient) AddDevAddrPrefix(prefix types.DevAddrPrefix) error

+ func (_m *MockClient) Announce(token string) error

+ func (_m *MockClient) Close() error

+ func (_m *MockClient) EXPECT() *_MockClientRecorder

+ func (_m *MockClient) Get(serviceName string, id string) (*Announcement, error)

+ func (_m *MockClient) GetAll(serviceName string) ([]*Announcement, error)

+ func (_m *MockClient) GetAllBrokersForDevAddr(devAddr types.DevAddr) ([]*Announcement, error)

+ func (_m *MockClient) GetAllHandlersForAppID(appID string) ([]*Announcement, error)

+ func (_m *MockClient) RemoveAppID(appID string, token string) error

+ func (_m *MockClient) RemoveDevAddrPrefix(prefix types.DevAddrPrefix) error