discovery

package
v0.0.0-...-228f33a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 18, 2021 License: MIT Imports: 28 Imported by: 78

Documentation

Overview

Package discovery is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDiscovery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDiscovery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDiscovery = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterDiscoveryHandler 

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

RegisterDiscoveryHandler registers the http handlers for service Discovery to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDiscoveryHandlerClient 

func RegisterDiscoveryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DiscoveryClient) error

RegisterDiscoveryHandlerClient registers the http handlers for service Discovery to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DiscoveryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DiscoveryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DiscoveryClient" to call the correct interceptors.

func RegisterDiscoveryHandlerFromEndpoint 

func RegisterDiscoveryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDiscoveryHandlerFromEndpoint is same as RegisterDiscoveryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDiscoveryHandlerServer 

func RegisterDiscoveryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DiscoveryServer) error

RegisterDiscoveryHandlerServer registers the http handlers for service Discovery to "mux". UnaryRPC :call DiscoveryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterDiscoveryManagerServer 

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

func RegisterDiscoveryServer 

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

Types

type Announcement 

type Announcement struct {
	// The ID of the component
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the component (router/broker/handler)
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Service version in the form "[version]-[commit] ([build date])"
	ServiceVersion string `protobuf:"bytes,3,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"`
	// Description of the component
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// URL with documentation or more information about this component
	Url string `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// Indicates whether this service is part of The Things Network (the public community network)
	Public bool `protobuf:"varint,6,opt,name=public,proto3" json:"public,omitempty"`
	// Comma-separated network addresses in the form "domain1:port,domain2:port,domain3:port" (currently we only use the first)
	NetAddress string `protobuf:"bytes,11,opt,name=net_address,json=netAddress,proto3" json:"net_address,omitempty"`
	// ECDSA public key of this component
	PublicKey string `protobuf:"bytes,12,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// TLS Certificate for gRPC on net_address (if TLS is enabled)
	Certificate string `protobuf:"bytes,13,opt,name=certificate,proto3" json:"certificate,omitempty"`
	// Contains the address where the HTTP API is exposed (if there is one).
	// Format of api_address: `http(s)://domain(:port)`
	// default http port is 80, default https port is 443.
	ApiAddress string `protobuf:"bytes,14,opt,name=api_address,json=apiAddress,proto3" json:"api_address,omitempty"`
	// Contains the address where the MQTT API is exposed (if there is one)
	// Format of mqtt_address: `(mqtt(s)://)host(:port)`
	// default mqtt port is 1883, default mqtts port is 8883.
	// Examples:
	// if `host:port` then `mqtt://host:port`
	// if `host:8883` then `mqtts://host:8883`
	// if `host` then `mqtt://host:1883` and `mqtts://host:8883`
	// if `mqtt://host` then `mqtt://host:1883`
	// if `mqtts://host` then `mqtt://host:1883` and `mqtts://host:8883`
	MqttAddress string `protobuf:"bytes,15,opt,name=mqtt_address,json=mqttAddress,proto3" json:"mqtt_address,omitempty"`
	// Contains the address where the AMQP API is exposed (if there is one)
	// Format of amqp_address: `(amqp(s)://)host(:port)`
	// default amqp port is 5672, default amqps port is 5671.
	// Examples:
	// if `host:port` then `amqp://host:port`
	// if `host:5671` then `amqps://host:5671`
	// if `host` then `amqp://host:5672` and `amqps://host:5671`
	// if `amqp://host` then `amqp://host:5672`
	// if `amqps://host` then `amqp://host:5672` and `amqps://host:5671`
	AmqpAddress string `protobuf:"bytes,16,opt,name=amqp_address,json=amqpAddress,proto3" json:"amqp_address,omitempty"`
	// Metadata for this component
	Metadata             []*Metadata `protobuf:"bytes,22,rep,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

The Announcement of a service (also called component)

func NewPopulatedAnnouncement 

func NewPopulatedAnnouncement(r randyDiscovery, easy bool) *Announcement

func (*Announcement) AppEUIs 

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

AppEUIs that are handled by this component

func (*Announcement) AppIDs 

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

AppIDs that are handled by this component

func (*Announcement) Descriptor 

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

func (*Announcement) DevAddrPrefixes 

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

DevAddrPrefixes that are handled by this component

func (*Announcement) Dial 

func (a *Announcement) Dial(p *pool.Pool) (*grpc.ClientConn, error)

Dial the component represented by this Announcement. This function is blocking if the pool uses grpc.WithBlock()

func (*Announcement) Equal 

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

func (*Announcement) GatewayIDs 

func (a *Announcement) GatewayIDs() (gatewayIDs []string)

GatewayIDs that are handled by this component

func (*Announcement) GetAmqpAddress 

func (m *Announcement) GetAmqpAddress() string

func (*Announcement) GetApiAddress 

func (m *Announcement) GetApiAddress() string

func (*Announcement) GetCertificate 

func (m *Announcement) GetCertificate() string

func (*Announcement) GetDescription 

func (m *Announcement) GetDescription() string

func (*Announcement) GetID 

func (m *Announcement) GetID() string

func (*Announcement) GetMetadata 

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

func (*Announcement) GetMqttAddress 

func (m *Announcement) GetMqttAddress() string

func (*Announcement) GetNetAddress 

func (m *Announcement) GetNetAddress() string

func (*Announcement) GetPublic 

func (m *Announcement) GetPublic() bool

func (*Announcement) GetPublicKey 

func (m *Announcement) GetPublicKey() string

func (*Announcement) GetServiceName 

func (m *Announcement) GetServiceName() string

func (*Announcement) GetServiceVersion 

func (m *Announcement) GetServiceVersion() string

func (*Announcement) GetTLSConfig 

func (a *Announcement) GetTLSConfig() (*tls.Config, error)

GetTLSConfig for securely connecting with this component

func (*Announcement) GetUrl 

func (m *Announcement) GetUrl() string

func (*Announcement) Marshal 

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

func (*Announcement) MarshalTo 

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

func (*Announcement) MarshalToSizedBuffer 

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

func (*Announcement) ProtoMessage 

func (*Announcement) ProtoMessage()

func (*Announcement) Reset 

func (m *Announcement) Reset()

func (*Announcement) Size 

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

func (*Announcement) String 

func (this *Announcement) String() string

func (*Announcement) Unmarshal 

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

func (*Announcement) WithSecure 

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

WithSecure returns a gRPC DialOption with TLS

func (*Announcement) XXX_DiscardUnknown 

func (m *Announcement) XXX_DiscardUnknown()

func (*Announcement) XXX_Marshal 

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

func (*Announcement) XXX_Merge 

func (m *Announcement) XXX_Merge(src proto.Message)

func (*Announcement) XXX_Size 

func (m *Announcement) XXX_Size() int

func (*Announcement) XXX_Unmarshal 

func (m *Announcement) XXX_Unmarshal(b []byte) error

type AnnouncementsResponse 

type AnnouncementsResponse struct {
	Services             []*Announcement `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A list of announcements

func NewPopulatedAnnouncementsResponse 

func NewPopulatedAnnouncementsResponse(r randyDiscovery, easy bool) *AnnouncementsResponse

func (*AnnouncementsResponse) Descriptor 

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

func (*AnnouncementsResponse) Equal 

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

func (*AnnouncementsResponse) GetServices 

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

func (*AnnouncementsResponse) Marshal 

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

func (*AnnouncementsResponse) MarshalTo 

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

func (*AnnouncementsResponse) MarshalToSizedBuffer 

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

func (*AnnouncementsResponse) ProtoMessage 

func (*AnnouncementsResponse) ProtoMessage()

func (*AnnouncementsResponse) Reset 

func (m *AnnouncementsResponse) Reset()

func (*AnnouncementsResponse) Size 

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

func (*AnnouncementsResponse) String 

func (this *AnnouncementsResponse) String() string

func (*AnnouncementsResponse) Unmarshal 

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

func (*AnnouncementsResponse) XXX_DiscardUnknown 

func (m *AnnouncementsResponse) XXX_DiscardUnknown()

func (*AnnouncementsResponse) XXX_Marshal 

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

func (*AnnouncementsResponse) XXX_Merge 

func (m *AnnouncementsResponse) XXX_Merge(src proto.Message)

func (*AnnouncementsResponse) XXX_Size 

func (m *AnnouncementsResponse) XXX_Size() int

func (*AnnouncementsResponse) XXX_Unmarshal 

func (m *AnnouncementsResponse) XXX_Unmarshal(b []byte) error

type DiscoveryClient 

type DiscoveryClient interface {
	// Announce a component to the Discovery server.
	// A call to `Announce` does not processes the `metadata` field, so you can safely leave this field empty.
	// Adding or removing Metadata should be done with the `AddMetadata` and `DeleteMetadata` methods.
	Announce(ctx context.Context, in *Announcement, opts ...grpc.CallOption) (*types.Empty, error)
	// Get all announcements for a specific service type
	GetAll(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*AnnouncementsResponse, error)
	// Get a specific announcement
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Announcement, error)
	// Add metadata to an announement
	AddMetadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*types.Empty, error)
	// Delete metadata from an announcement
	DeleteMetadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*types.Empty, error)
	GetByAppID(ctx context.Context, in *GetByAppIDRequest, opts ...grpc.CallOption) (*Announcement, error)
	GetByGatewayID(ctx context.Context, in *GetByGatewayIDRequest, opts ...grpc.CallOption) (*Announcement, error)
	GetByAppEUI(ctx context.Context, in *GetByAppEUIRequest, opts ...grpc.CallOption) (*Announcement, error)
}

DiscoveryClient is the client API for Discovery service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscoveryClient 

func NewDiscoveryClient(cc *grpc.ClientConn) DiscoveryClient

type DiscoveryManagerClient 

type DiscoveryManagerClient interface {
}

DiscoveryManagerClient is the client API for DiscoveryManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDiscoveryManagerClient 

func NewDiscoveryManagerClient(cc *grpc.ClientConn) DiscoveryManagerClient

type DiscoveryManagerServer 

type DiscoveryManagerServer interface {
}

DiscoveryManagerServer is the server API for DiscoveryManager service.

type DiscoveryServer 

type DiscoveryServer interface {
	// Announce a component to the Discovery server.
	// A call to `Announce` does not processes the `metadata` field, so you can safely leave this field empty.
	// Adding or removing Metadata should be done with the `AddMetadata` and `DeleteMetadata` methods.
	Announce(context.Context, *Announcement) (*types.Empty, error)
	// Get all announcements for a specific service type
	GetAll(context.Context, *GetServiceRequest) (*AnnouncementsResponse, error)
	// Get a specific announcement
	Get(context.Context, *GetRequest) (*Announcement, error)
	// Add metadata to an announement
	AddMetadata(context.Context, *MetadataRequest) (*types.Empty, error)
	// Delete metadata from an announcement
	DeleteMetadata(context.Context, *MetadataRequest) (*types.Empty, error)
	GetByAppID(context.Context, *GetByAppIDRequest) (*Announcement, error)
	GetByGatewayID(context.Context, *GetByGatewayIDRequest) (*Announcement, error)
	GetByAppEUI(context.Context, *GetByAppEUIRequest) (*Announcement, error)
}

DiscoveryServer is the server API for Discovery service.

type GetByAppEUIRequest 

type GetByAppEUIRequest struct {
	AppEUI               github_com_TheThingsNetwork_ttn_core_types.AppEUI `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                          `json:"-"`
	XXX_sizecache        int32                                             `json:"-"`
}

func NewPopulatedGetByAppEUIRequest 

func NewPopulatedGetByAppEUIRequest(r randyDiscovery, easy bool) *GetByAppEUIRequest

func (*GetByAppEUIRequest) Descriptor 

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

func (*GetByAppEUIRequest) Equal 

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

func (*GetByAppEUIRequest) GetAppEUI 

func (m *GetByAppEUIRequest) GetAppEUI() (eui types.AppEUI)

func (*GetByAppEUIRequest) Marshal 

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

func (*GetByAppEUIRequest) MarshalTo 

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

func (*GetByAppEUIRequest) MarshalToSizedBuffer 

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

func (*GetByAppEUIRequest) ProtoMessage 

func (*GetByAppEUIRequest) ProtoMessage()

func (*GetByAppEUIRequest) Reset 

func (m *GetByAppEUIRequest) Reset()

func (*GetByAppEUIRequest) Size 

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

func (*GetByAppEUIRequest) String 

func (this *GetByAppEUIRequest) String() string

func (*GetByAppEUIRequest) Unmarshal 

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

func (*GetByAppEUIRequest) XXX_DiscardUnknown 

func (m *GetByAppEUIRequest) XXX_DiscardUnknown()

func (*GetByAppEUIRequest) XXX_Marshal 

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

func (*GetByAppEUIRequest) XXX_Merge 

func (m *GetByAppEUIRequest) XXX_Merge(src proto.Message)

func (*GetByAppEUIRequest) XXX_Size 

func (m *GetByAppEUIRequest) XXX_Size() int

func (*GetByAppEUIRequest) XXX_Unmarshal 

func (m *GetByAppEUIRequest) XXX_Unmarshal(b []byte) error

type GetByAppIDRequest 

type GetByAppIDRequest struct {
	AppID                string   `protobuf:"bytes,30,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedGetByAppIDRequest 

func NewPopulatedGetByAppIDRequest(r randyDiscovery, easy bool) *GetByAppIDRequest

func (*GetByAppIDRequest) Descriptor 

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

func (*GetByAppIDRequest) Equal 

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

func (*GetByAppIDRequest) GetAppID 

func (m *GetByAppIDRequest) GetAppID() string

func (*GetByAppIDRequest) Marshal 

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

func (*GetByAppIDRequest) MarshalTo 

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

func (*GetByAppIDRequest) MarshalToSizedBuffer 

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

func (*GetByAppIDRequest) ProtoMessage 

func (*GetByAppIDRequest) ProtoMessage()

func (*GetByAppIDRequest) Reset 

func (m *GetByAppIDRequest) Reset()

func (*GetByAppIDRequest) Size 

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

func (*GetByAppIDRequest) String 

func (this *GetByAppIDRequest) String() string

func (*GetByAppIDRequest) Unmarshal 

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

func (*GetByAppIDRequest) XXX_DiscardUnknown 

func (m *GetByAppIDRequest) XXX_DiscardUnknown()

func (*GetByAppIDRequest) XXX_Marshal 

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

func (*GetByAppIDRequest) XXX_Merge 

func (m *GetByAppIDRequest) XXX_Merge(src proto.Message)

func (*GetByAppIDRequest) XXX_Size 

func (m *GetByAppIDRequest) XXX_Size() int

func (*GetByAppIDRequest) XXX_Unmarshal 

func (m *GetByAppIDRequest) XXX_Unmarshal(b []byte) error

type GetByGatewayIDRequest 

type GetByGatewayIDRequest struct {
	GatewayID            string   `protobuf:"bytes,30,opt,name=gateway_id,json=gatewayId,proto3" json:"gateway_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedGetByGatewayIDRequest 

func NewPopulatedGetByGatewayIDRequest(r randyDiscovery, easy bool) *GetByGatewayIDRequest

func (*GetByGatewayIDRequest) Descriptor 

func (*GetByGatewayIDRequest) Descriptor() ([]byte, []int)

func (*GetByGatewayIDRequest) Equal 

func (this *GetByGatewayIDRequest) Equal(that interface{}) bool

func (*GetByGatewayIDRequest) GetGatewayID 

func (m *GetByGatewayIDRequest) GetGatewayID() string

func (*GetByGatewayIDRequest) Marshal 

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

func (*GetByGatewayIDRequest) MarshalTo 

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

func (*GetByGatewayIDRequest) MarshalToSizedBuffer 

func (m *GetByGatewayIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetByGatewayIDRequest) ProtoMessage 

func (*GetByGatewayIDRequest) ProtoMessage()

func (*GetByGatewayIDRequest) Reset 

func (m *GetByGatewayIDRequest) Reset()

func (*GetByGatewayIDRequest) Size 

func (m *GetByGatewayIDRequest) Size() (n int)

func (*GetByGatewayIDRequest) String 

func (this *GetByGatewayIDRequest) String() string

func (*GetByGatewayIDRequest) Unmarshal 

func (m *GetByGatewayIDRequest) Unmarshal(dAtA []byte) error

func (*GetByGatewayIDRequest) XXX_DiscardUnknown 

func (m *GetByGatewayIDRequest) XXX_DiscardUnknown()

func (*GetByGatewayIDRequest) XXX_Marshal 

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

func (*GetByGatewayIDRequest) XXX_Merge 

func (m *GetByGatewayIDRequest) XXX_Merge(src proto.Message)

func (*GetByGatewayIDRequest) XXX_Size 

func (m *GetByGatewayIDRequest) XXX_Size() int

func (*GetByGatewayIDRequest) XXX_Unmarshal 

func (m *GetByGatewayIDRequest) XXX_Unmarshal(b []byte) error

type GetRequest 

type GetRequest struct {
	// The ID of the service
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the service (router/broker/handler)
	ServiceName          string   `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The identifier of the service that should be returned

func NewPopulatedGetRequest 

func NewPopulatedGetRequest(r randyDiscovery, easy bool) *GetRequest

func (*GetRequest) Descriptor 

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

func (*GetRequest) Equal 

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

func (*GetRequest) GetID 

func (m *GetRequest) GetID() string

func (*GetRequest) GetServiceName 

func (m *GetRequest) GetServiceName() string

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (this *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

type GetServiceRequest 

type GetServiceRequest struct {
	// The name of the service (router/broker/handler)
	ServiceName          string   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedGetServiceRequest 

func NewPopulatedGetServiceRequest(r randyDiscovery, easy bool) *GetServiceRequest

func (*GetServiceRequest) Descriptor 

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

func (*GetServiceRequest) Equal 

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

func (*GetServiceRequest) GetServiceName 

func (m *GetServiceRequest) GetServiceName() string

func (*GetServiceRequest) Marshal 

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

func (*GetServiceRequest) MarshalTo 

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

func (*GetServiceRequest) MarshalToSizedBuffer 

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

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) Size 

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

func (*GetServiceRequest) String 

func (this *GetServiceRequest) String() string

func (*GetServiceRequest) Unmarshal 

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

func (*GetServiceRequest) XXX_DiscardUnknown 

func (m *GetServiceRequest) XXX_DiscardUnknown()

func (*GetServiceRequest) XXX_Marshal 

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

func (*GetServiceRequest) XXX_Merge 

func (m *GetServiceRequest) XXX_Merge(src proto.Message)

func (*GetServiceRequest) XXX_Size 

func (m *GetServiceRequest) XXX_Size() int

func (*GetServiceRequest) XXX_Unmarshal 

func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error

type Metadata 

type Metadata struct {
	// Types that are valid to be assigned to Metadata:
	//	*Metadata_GatewayID
	//	*Metadata_DevAddrPrefix
	//	*Metadata_AppID
	//	*Metadata_AppEUI
	Metadata             isMetadata_Metadata `protobuf_oneof:"metadata"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func NewPopulatedMetadata 

func NewPopulatedMetadata(r randyDiscovery, easy bool) *Metadata

func (*Metadata) Descriptor 

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

func (*Metadata) Equal 

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

func (*Metadata) GetAppEUI 

func (m *Metadata) GetAppEUI() []byte

func (*Metadata) GetAppID 

func (m *Metadata) GetAppID() string

func (*Metadata) GetDevAddrPrefix 

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

func (*Metadata) GetGatewayID 

func (m *Metadata) GetGatewayID() string

func (*Metadata) GetMetadata 

func (m *Metadata) GetMetadata() isMetadata_Metadata

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) MarshalToSizedBuffer 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (this *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_OneofWrappers 

func (*Metadata) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type MetadataRequest 

type MetadataRequest struct {
	// The ID of the service that should be modified
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The name of the service (router/broker/handler) that should be modified
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Metadata to add or remove
	Metadata             Metadata `protobuf:"bytes,12,opt,name=metadata,proto3" json:"metadata"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The metadata to add or remove from an announement

func NewPopulatedMetadataRequest 

func NewPopulatedMetadataRequest(r randyDiscovery, easy bool) *MetadataRequest

func (*MetadataRequest) Descriptor 

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

func (*MetadataRequest) Equal 

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

func (*MetadataRequest) GetID 

func (m *MetadataRequest) GetID() string

func (*MetadataRequest) GetMetadata 

func (m *MetadataRequest) GetMetadata() Metadata

func (*MetadataRequest) GetServiceName 

func (m *MetadataRequest) GetServiceName() string

func (*MetadataRequest) Marshal 

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

func (*MetadataRequest) MarshalTo 

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

func (*MetadataRequest) MarshalToSizedBuffer 

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

func (*MetadataRequest) ProtoMessage 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) Reset 

func (m *MetadataRequest) Reset()

func (*MetadataRequest) Size 

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

func (*MetadataRequest) String 

func (this *MetadataRequest) String() string

func (*MetadataRequest) Unmarshal 

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

func (*MetadataRequest) XXX_DiscardUnknown 

func (m *MetadataRequest) XXX_DiscardUnknown()

func (*MetadataRequest) XXX_Marshal 

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

func (*MetadataRequest) XXX_Merge 

func (m *MetadataRequest) XXX_Merge(src proto.Message)

func (*MetadataRequest) XXX_Size 

func (m *MetadataRequest) XXX_Size() int

func (*MetadataRequest) XXX_Unmarshal 

func (m *MetadataRequest) XXX_Unmarshal(b []byte) error

type Metadata_AppEUI 

type Metadata_AppEUI struct {
	AppEUI []byte `protobuf:"bytes,31,opt,name=app_eui,json=appEui,proto3,oneof" json:"app_eui,omitempty"`
}

func NewPopulatedMetadata_AppEUI 

func NewPopulatedMetadata_AppEUI(r randyDiscovery, easy bool) *Metadata_AppEUI

func (*Metadata_AppEUI) Equal 

func (this *Metadata_AppEUI) Equal(that interface{}) bool

func (*Metadata_AppEUI) MarshalTo 

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

func (*Metadata_AppEUI) MarshalToSizedBuffer 

func (m *Metadata_AppEUI) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata_AppEUI) Size 

func (m *Metadata_AppEUI) Size() (n int)

func (*Metadata_AppEUI) String 

func (this *Metadata_AppEUI) String() string

type Metadata_AppID 

type Metadata_AppID struct {
	AppID string `protobuf:"bytes,30,opt,name=app_id,json=appId,proto3,oneof" json:"app_id,omitempty"`
}

func NewPopulatedMetadata_AppID 

func NewPopulatedMetadata_AppID(r randyDiscovery, easy bool) *Metadata_AppID

func (*Metadata_AppID) Equal 

func (this *Metadata_AppID) Equal(that interface{}) bool

func (*Metadata_AppID) MarshalTo 

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

func (*Metadata_AppID) MarshalToSizedBuffer 

func (m *Metadata_AppID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata_AppID) Size 

func (m *Metadata_AppID) Size() (n int)

func (*Metadata_AppID) String 

func (this *Metadata_AppID) String() string

type Metadata_DevAddrPrefix 

type Metadata_DevAddrPrefix struct {
	DevAddrPrefix []byte `protobuf:"bytes,20,opt,name=dev_addr_prefix,json=devAddrPrefix,proto3,oneof" json:"dev_addr_prefix,omitempty"`
}

func NewPopulatedMetadata_DevAddrPrefix 

func NewPopulatedMetadata_DevAddrPrefix(r randyDiscovery, easy bool) *Metadata_DevAddrPrefix

func (*Metadata_DevAddrPrefix) Equal 

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

func (*Metadata_DevAddrPrefix) MarshalTo 

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

func (*Metadata_DevAddrPrefix) MarshalToSizedBuffer 

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

func (*Metadata_DevAddrPrefix) Size 

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

func (*Metadata_DevAddrPrefix) String 

func (this *Metadata_DevAddrPrefix) String() string

type Metadata_GatewayID 

type Metadata_GatewayID struct {
	GatewayID string `protobuf:"bytes,10,opt,name=gateway_id,json=gatewayId,proto3,oneof" json:"gateway_id,omitempty"`
}

func NewPopulatedMetadata_GatewayID 

func NewPopulatedMetadata_GatewayID(r randyDiscovery, easy bool) *Metadata_GatewayID

func (*Metadata_GatewayID) Equal 

func (this *Metadata_GatewayID) Equal(that interface{}) bool

func (*Metadata_GatewayID) MarshalTo 

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

func (*Metadata_GatewayID) MarshalToSizedBuffer 

func (m *Metadata_GatewayID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata_GatewayID) Size 

func (m *Metadata_GatewayID) Size() (n int)

func (*Metadata_GatewayID) String 

func (this *Metadata_GatewayID) String() string

type UnimplementedDiscoveryManagerServer 

type UnimplementedDiscoveryManagerServer struct {
}

UnimplementedDiscoveryManagerServer can be embedded to have forward compatible implementations.

type UnimplementedDiscoveryServer 

type UnimplementedDiscoveryServer struct {
}

UnimplementedDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiscoveryServer) AddMetadata 

func (*UnimplementedDiscoveryServer) AddMetadata(ctx context.Context, req *MetadataRequest) (*types.Empty, error)

func (*UnimplementedDiscoveryServer) Announce 

func (*UnimplementedDiscoveryServer) Announce(ctx context.Context, req *Announcement) (*types.Empty, error)

func (*UnimplementedDiscoveryServer) DeleteMetadata 

func (*UnimplementedDiscoveryServer) DeleteMetadata(ctx context.Context, req *MetadataRequest) (*types.Empty, error)

func (*UnimplementedDiscoveryServer) Get 

func (*UnimplementedDiscoveryServer) Get(ctx context.Context, req *GetRequest) (*Announcement, error)

func (*UnimplementedDiscoveryServer) GetAll 

func (*UnimplementedDiscoveryServer) GetAll(ctx context.Context, req *GetServiceRequest) (*AnnouncementsResponse, error)

func (*UnimplementedDiscoveryServer) GetByAppEUI 

func (*UnimplementedDiscoveryServer) GetByAppEUI(ctx context.Context, req *GetByAppEUIRequest) (*Announcement, error)

func (*UnimplementedDiscoveryServer) GetByAppID 

func (*UnimplementedDiscoveryServer) GetByAppID(ctx context.Context, req *GetByAppIDRequest) (*Announcement, error)

func (*UnimplementedDiscoveryServer) GetByGatewayID 

func (*UnimplementedDiscoveryServer) GetByGatewayID(ctx context.Context, req *GetByGatewayIDRequest) (*Announcement, error)

Source Files

View all Source files

Directories

Path Synopsis
Package discoveryclient is a generated GoMock package.
 Package discoveryclient is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.