handler

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: 29 Imported by: 97

Documentation

Overview

Package handler is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthHandler        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHandler          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHandler = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterApplicationManagerHandler 

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

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

func RegisterApplicationManagerHandlerClient 

func RegisterApplicationManagerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ApplicationManagerClient) error

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

func RegisterApplicationManagerHandlerFromEndpoint 

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

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

func RegisterApplicationManagerHandlerServer 

func RegisterApplicationManagerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ApplicationManagerServer) error

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

func RegisterApplicationManagerServer 

func RegisterApplicationManagerServer(s *grpc.Server, srv ApplicationManagerServer)

func RegisterHandlerManagerServer 

func RegisterHandlerManagerServer(s *grpc.Server, srv HandlerManagerServer)

func RegisterHandlerServer 

func RegisterHandlerServer(s *grpc.Server, srv HandlerServer)

Types

type Application 

type Application struct {
	AppID string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	// The payload format indicates how payload is formatted.
	PayloadFormat string `protobuf:"bytes,6,opt,name=payload_format,json=payloadFormat,proto3" json:"payload_format,omitempty"`
	// The decoder is a JavaScript function that decodes a byte array to an object.
	// This function is used when the payload format is set to custom.
	Decoder string `protobuf:"bytes,2,opt,name=decoder,proto3" json:"decoder,omitempty"`
	// The converter is a JavaScript function that can be used to convert values
	// in the object returned from the decoder. This can for example be useful to
	// convert a voltage to a temperature. This function is used when the payload format is set to custom.
	Converter string `protobuf:"bytes,3,opt,name=converter,proto3" json:"converter,omitempty"`
	// The validator is a JavaScript function that checks the validity of the
	// object returned by the decoder or converter. If validation fails, the
	// message is dropped. This function is used when the payload format is set to custom.
	Validator string `protobuf:"bytes,4,opt,name=validator,proto3" json:"validator,omitempty"`
	// The encoder is a JavaScript function that encodes an object to a byte array.
	// This function is used when the payload format is set to custom.
	Encoder string `protobuf:"bytes,5,opt,name=encoder,proto3" json:"encoder,omitempty"`
	// The "register on join" access key should only be set if devices need to be registered on join
	RegisterOnJoinAccessKey string   `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

The Application settings

func NewPopulatedApplication 

func NewPopulatedApplication(r randyHandler, easy bool) *Application

func (*Application) Descriptor 

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

func (*Application) Equal 

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

func (*Application) GetAppID 

func (m *Application) GetAppID() string

func (*Application) GetConverter 

func (m *Application) GetConverter() string

func (*Application) GetDecoder 

func (m *Application) GetDecoder() string

func (*Application) GetEncoder 

func (m *Application) GetEncoder() string

func (*Application) GetPayloadFormat 

func (m *Application) GetPayloadFormat() string

func (*Application) GetRegisterOnJoinAccessKey 

func (m *Application) GetRegisterOnJoinAccessKey() string

func (*Application) GetValidator 

func (m *Application) GetValidator() string

func (*Application) Marshal 

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

func (*Application) MarshalTo 

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

func (*Application) MarshalToSizedBuffer 

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

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) Reset 

func (m *Application) Reset()

func (*Application) Size 

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

func (*Application) String 

func (this *Application) String() string

func (*Application) Unmarshal 

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

func (*Application) Validate 

func (m *Application) Validate() error

Validate implements the api.Validator interface

func (*Application) XXX_DiscardUnknown 

func (m *Application) XXX_DiscardUnknown()

func (*Application) XXX_Marshal 

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

func (*Application) XXX_Merge 

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

func (*Application) XXX_Size 

func (m *Application) XXX_Size() int

func (*Application) XXX_Unmarshal 

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

type ApplicationIdentifier 

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

func NewPopulatedApplicationIdentifier 

func NewPopulatedApplicationIdentifier(r randyHandler, easy bool) *ApplicationIdentifier

func (*ApplicationIdentifier) Descriptor 

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

func (*ApplicationIdentifier) Equal 

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

func (*ApplicationIdentifier) GetAppID 

func (m *ApplicationIdentifier) GetAppID() string

func (*ApplicationIdentifier) Marshal 

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

func (*ApplicationIdentifier) MarshalTo 

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

func (*ApplicationIdentifier) MarshalToSizedBuffer 

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

func (*ApplicationIdentifier) ProtoMessage 

func (*ApplicationIdentifier) ProtoMessage()

func (*ApplicationIdentifier) Reset 

func (m *ApplicationIdentifier) Reset()

func (*ApplicationIdentifier) Size 

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

func (*ApplicationIdentifier) String 

func (this *ApplicationIdentifier) String() string

func (*ApplicationIdentifier) Unmarshal 

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

func (*ApplicationIdentifier) Validate 

func (m *ApplicationIdentifier) Validate() error

Validate implements the api.Validator interface

func (*ApplicationIdentifier) XXX_DiscardUnknown 

func (m *ApplicationIdentifier) XXX_DiscardUnknown()

func (*ApplicationIdentifier) XXX_Marshal 

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

func (*ApplicationIdentifier) XXX_Merge 

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

func (*ApplicationIdentifier) XXX_Size 

func (m *ApplicationIdentifier) XXX_Size() int

func (*ApplicationIdentifier) XXX_Unmarshal 

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

type ApplicationManagerClient 

type ApplicationManagerClient interface {
	// Applications should first be registered to the Handler with the `RegisterApplication` method
	RegisterApplication(ctx context.Context, in *ApplicationIdentifier, opts ...grpc.CallOption) (*types.Empty, error)
	// GetApplication returns the application with the given identifier (app_id)
	GetApplication(ctx context.Context, in *ApplicationIdentifier, opts ...grpc.CallOption) (*Application, error)
	// SetApplication updates the settings for the application. All fields must be supplied.
	SetApplication(ctx context.Context, in *Application, opts ...grpc.CallOption) (*types.Empty, error)
	// DeleteApplication deletes the application with the given identifier (app_id)
	DeleteApplication(ctx context.Context, in *ApplicationIdentifier, opts ...grpc.CallOption) (*types.Empty, error)
	// GetDevice returns the device with the given identifier (app_id and dev_id)
	GetDevice(ctx context.Context, in *DeviceIdentifier, opts ...grpc.CallOption) (*Device, error)
	// SetDevice creates or updates a device. All fields must be supplied.
	SetDevice(ctx context.Context, in *Device, opts ...grpc.CallOption) (*types.Empty, error)
	// DeleteDevice deletes the device with the given identifier (app_id and dev_id)
	DeleteDevice(ctx context.Context, in *DeviceIdentifier, opts ...grpc.CallOption) (*types.Empty, error)
	// GetDevicesForApplication returns all devices that belong to the application with the given identifier (app_id)
	GetDevicesForApplication(ctx context.Context, in *ApplicationIdentifier, opts ...grpc.CallOption) (*DeviceList, error)
	// DryUplink simulates processing a downlink message and returns the result
	DryDownlink(ctx context.Context, in *DryDownlinkMessage, opts ...grpc.CallOption) (*DryDownlinkResult, error)
	// DryUplink simulates processing an uplink message and returns the result
	DryUplink(ctx context.Context, in *DryUplinkMessage, opts ...grpc.CallOption) (*DryUplinkResult, error)
	// SimulateUplink simulates an uplink message
	SimulateUplink(ctx context.Context, in *SimulatedUplinkMessage, opts ...grpc.CallOption) (*types.Empty, error)
}

ApplicationManagerClient is the client API for ApplicationManager service.

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

func NewApplicationManagerClient 

func NewApplicationManagerClient(cc *grpc.ClientConn) ApplicationManagerClient

type ApplicationManagerServer 

type ApplicationManagerServer interface {
	// Applications should first be registered to the Handler with the `RegisterApplication` method
	RegisterApplication(context.Context, *ApplicationIdentifier) (*types.Empty, error)
	// GetApplication returns the application with the given identifier (app_id)
	GetApplication(context.Context, *ApplicationIdentifier) (*Application, error)
	// SetApplication updates the settings for the application. All fields must be supplied.
	SetApplication(context.Context, *Application) (*types.Empty, error)
	// DeleteApplication deletes the application with the given identifier (app_id)
	DeleteApplication(context.Context, *ApplicationIdentifier) (*types.Empty, error)
	// GetDevice returns the device with the given identifier (app_id and dev_id)
	GetDevice(context.Context, *DeviceIdentifier) (*Device, error)
	// SetDevice creates or updates a device. All fields must be supplied.
	SetDevice(context.Context, *Device) (*types.Empty, error)
	// DeleteDevice deletes the device with the given identifier (app_id and dev_id)
	DeleteDevice(context.Context, *DeviceIdentifier) (*types.Empty, error)
	// GetDevicesForApplication returns all devices that belong to the application with the given identifier (app_id)
	GetDevicesForApplication(context.Context, *ApplicationIdentifier) (*DeviceList, error)
	// DryUplink simulates processing a downlink message and returns the result
	DryDownlink(context.Context, *DryDownlinkMessage) (*DryDownlinkResult, error)
	// DryUplink simulates processing an uplink message and returns the result
	DryUplink(context.Context, *DryUplinkMessage) (*DryUplinkResult, error)
	// SimulateUplink simulates an uplink message
	SimulateUplink(context.Context, *SimulatedUplinkMessage) (*types.Empty, error)
}

ApplicationManagerServer is the server API for ApplicationManager service.

type Device 

type Device struct {
	AppID string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID string `protobuf:"bytes,2,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	// The device can be of different kinds
	//
	// Types that are valid to be assigned to Device:
	//	*Device_LoRaWANDevice
	Device               isDevice_Device   `protobuf_oneof:"device"`
	Latitude             float32           `protobuf:"fixed32,10,opt,name=latitude,proto3" json:"latitude,omitempty"`
	Longitude            float32           `protobuf:"fixed32,11,opt,name=longitude,proto3" json:"longitude,omitempty"`
	Altitude             int32             `protobuf:"varint,12,opt,name=altitude,proto3" json:"altitude,omitempty"`
	Attributes           map[string]string `` /* 162-byte string literal not displayed */
	Description          string            `protobuf:"bytes,20,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

The Device settings

func NewPopulatedDevice 

func NewPopulatedDevice(r randyHandler, easy bool) *Device

func (*Device) Descriptor 

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

func (*Device) Equal 

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

func (*Device) GetAltitude 

func (m *Device) GetAltitude() int32

func (*Device) GetAppID 

func (m *Device) GetAppID() string

func (*Device) GetAttributes 

func (m *Device) GetAttributes() map[string]string

func (*Device) GetDescription 

func (m *Device) GetDescription() string

func (*Device) GetDevID 

func (m *Device) GetDevID() string

func (*Device) GetDevice 

func (m *Device) GetDevice() isDevice_Device

func (*Device) GetLatitude 

func (m *Device) GetLatitude() float32

func (*Device) GetLoRaWANDevice 

func (m *Device) GetLoRaWANDevice() *lorawan.Device

func (*Device) GetLongitude 

func (m *Device) GetLongitude() float32

func (*Device) Marshal 

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

func (*Device) MarshalTo 

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

func (*Device) MarshalToSizedBuffer 

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

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) Size 

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

func (*Device) String 

func (this *Device) String() string

func (*Device) Unmarshal 

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

func (*Device) Validate 

func (m *Device) Validate() error

Validate implements the api.Validator interface

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

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

func (*Device) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

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

type DeviceActivationResponse 

type DeviceActivationResponse struct {
	Payload              []byte                      `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Message              *protocol.Message           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	DownlinkOption       broker.DownlinkOption       `protobuf:"bytes,11,opt,name=downlink_option,json=downlinkOption,proto3" json:"downlink_option"`
	ActivationMetadata   protocol.ActivationMetadata `protobuf:"bytes,23,opt,name=activation_metadata,json=activationMetadata,proto3" json:"activation_metadata"`
	Trace                *trace.Trace                `protobuf:"bytes,31,opt,name=trace,proto3" json:"trace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func NewPopulatedDeviceActivationResponse 

func NewPopulatedDeviceActivationResponse(r randyHandler, easy bool) *DeviceActivationResponse

func (*DeviceActivationResponse) Descriptor 

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

func (*DeviceActivationResponse) Equal 

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

func (*DeviceActivationResponse) GetActivationMetadata 

func (m *DeviceActivationResponse) GetActivationMetadata() protocol.ActivationMetadata

func (*DeviceActivationResponse) GetDownlinkOption 

func (m *DeviceActivationResponse) GetDownlinkOption() broker.DownlinkOption

func (*DeviceActivationResponse) GetMessage 

func (m *DeviceActivationResponse) GetMessage() *protocol.Message

func (*DeviceActivationResponse) GetPayload 

func (m *DeviceActivationResponse) GetPayload() []byte

func (*DeviceActivationResponse) GetTrace 

func (m *DeviceActivationResponse) GetTrace() *trace.Trace

func (*DeviceActivationResponse) Marshal 

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

func (*DeviceActivationResponse) MarshalTo 

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

func (*DeviceActivationResponse) MarshalToSizedBuffer 

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

func (*DeviceActivationResponse) ProtoMessage 

func (*DeviceActivationResponse) ProtoMessage()

func (*DeviceActivationResponse) Reset 

func (m *DeviceActivationResponse) Reset()

func (*DeviceActivationResponse) Size 

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

func (*DeviceActivationResponse) String 

func (this *DeviceActivationResponse) String() string

func (*DeviceActivationResponse) Unmarshal 

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

func (*DeviceActivationResponse) Validate 

func (m *DeviceActivationResponse) Validate() error

Validate implements the api.Validator interface

func (*DeviceActivationResponse) XXX_DiscardUnknown 

func (m *DeviceActivationResponse) XXX_DiscardUnknown()

func (*DeviceActivationResponse) XXX_Marshal 

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

func (*DeviceActivationResponse) XXX_Merge 

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

func (*DeviceActivationResponse) XXX_Size 

func (m *DeviceActivationResponse) XXX_Size() int

func (*DeviceActivationResponse) XXX_Unmarshal 

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

type DeviceIdentifier 

type DeviceIdentifier struct {
	AppID                string   `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID                string   `protobuf:"bytes,2,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedDeviceIdentifier 

func NewPopulatedDeviceIdentifier(r randyHandler, easy bool) *DeviceIdentifier

func (*DeviceIdentifier) Descriptor 

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

func (*DeviceIdentifier) Equal 

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

func (*DeviceIdentifier) GetAppID 

func (m *DeviceIdentifier) GetAppID() string

func (*DeviceIdentifier) GetDevID 

func (m *DeviceIdentifier) GetDevID() string

func (*DeviceIdentifier) Marshal 

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

func (*DeviceIdentifier) MarshalTo 

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

func (*DeviceIdentifier) MarshalToSizedBuffer 

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

func (*DeviceIdentifier) ProtoMessage 

func (*DeviceIdentifier) ProtoMessage()

func (*DeviceIdentifier) Reset 

func (m *DeviceIdentifier) Reset()

func (*DeviceIdentifier) Size 

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

func (*DeviceIdentifier) String 

func (this *DeviceIdentifier) String() string

func (*DeviceIdentifier) Unmarshal 

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

func (*DeviceIdentifier) Validate 

func (m *DeviceIdentifier) Validate() error

Validate implements the api.Validator interface

func (*DeviceIdentifier) XXX_DiscardUnknown 

func (m *DeviceIdentifier) XXX_DiscardUnknown()

func (*DeviceIdentifier) XXX_Marshal 

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

func (*DeviceIdentifier) XXX_Merge 

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

func (*DeviceIdentifier) XXX_Size 

func (m *DeviceIdentifier) XXX_Size() int

func (*DeviceIdentifier) XXX_Unmarshal 

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

type DeviceList 

type DeviceList struct {
	Devices              []*Device `protobuf:"bytes,1,rep,name=devices,proto3" json:"devices,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func NewPopulatedDeviceList 

func NewPopulatedDeviceList(r randyHandler, easy bool) *DeviceList

func (*DeviceList) Descriptor 

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

func (*DeviceList) Equal 

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

func (*DeviceList) GetDevices 

func (m *DeviceList) GetDevices() []*Device

func (*DeviceList) Marshal 

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

func (*DeviceList) MarshalTo 

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

func (*DeviceList) MarshalToSizedBuffer 

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

func (*DeviceList) ProtoMessage 

func (*DeviceList) ProtoMessage()

func (*DeviceList) Reset 

func (m *DeviceList) Reset()

func (*DeviceList) Size 

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

func (*DeviceList) String 

func (this *DeviceList) String() string

func (*DeviceList) Unmarshal 

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

func (*DeviceList) XXX_DiscardUnknown 

func (m *DeviceList) XXX_DiscardUnknown()

func (*DeviceList) XXX_Marshal 

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

func (*DeviceList) XXX_Merge 

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

func (*DeviceList) XXX_Size 

func (m *DeviceList) XXX_Size() int

func (*DeviceList) XXX_Unmarshal 

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

type Device_LoRaWANDevice 

type Device_LoRaWANDevice struct {
	LoRaWANDevice *lorawan.Device `protobuf:"bytes,3,opt,name=lorawan_device,json=lorawanDevice,proto3,oneof" json:"lorawan_device,omitempty"`
}

func NewPopulatedDevice_LoRaWANDevice 

func NewPopulatedDevice_LoRaWANDevice(r randyHandler, easy bool) *Device_LoRaWANDevice

func (*Device_LoRaWANDevice) Equal 

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

func (*Device_LoRaWANDevice) MarshalTo 

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

func (*Device_LoRaWANDevice) MarshalToSizedBuffer 

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

func (*Device_LoRaWANDevice) Size 

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

func (*Device_LoRaWANDevice) String 

func (this *Device_LoRaWANDevice) String() string

func (*Device_LoRaWANDevice) Validate 

func (m *Device_LoRaWANDevice) Validate() error

Validate implements the api.Validator interface

type DryDownlinkMessage 

type DryDownlinkMessage struct {
	// The binary payload to use
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// JSON-encoded object with fields to encode
	Fields string `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	// The Application containing the payload functions that should be executed
	App Application `protobuf:"bytes,3,opt,name=app,proto3" json:"app"`
	// The port number that should be passed to the payload function
	Port                 uint32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DryDownlinkMessage is a simulated message to test downlink processing

func NewPopulatedDryDownlinkMessage 

func NewPopulatedDryDownlinkMessage(r randyHandler, easy bool) *DryDownlinkMessage

func (*DryDownlinkMessage) Descriptor 

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

func (*DryDownlinkMessage) Equal 

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

func (*DryDownlinkMessage) GetApp 

func (m *DryDownlinkMessage) GetApp() Application

func (*DryDownlinkMessage) GetFields 

func (m *DryDownlinkMessage) GetFields() string

func (*DryDownlinkMessage) GetPayload 

func (m *DryDownlinkMessage) GetPayload() []byte

func (*DryDownlinkMessage) GetPort 

func (m *DryDownlinkMessage) GetPort() uint32

func (*DryDownlinkMessage) Marshal 

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

func (*DryDownlinkMessage) MarshalTo 

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

func (*DryDownlinkMessage) MarshalToSizedBuffer 

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

func (*DryDownlinkMessage) ProtoMessage 

func (*DryDownlinkMessage) ProtoMessage()

func (*DryDownlinkMessage) Reset 

func (m *DryDownlinkMessage) Reset()

func (*DryDownlinkMessage) Size 

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

func (*DryDownlinkMessage) String 

func (this *DryDownlinkMessage) String() string

func (*DryDownlinkMessage) Unmarshal 

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

func (*DryDownlinkMessage) XXX_DiscardUnknown 

func (m *DryDownlinkMessage) XXX_DiscardUnknown()

func (*DryDownlinkMessage) XXX_Marshal 

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

func (*DryDownlinkMessage) XXX_Merge 

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

func (*DryDownlinkMessage) XXX_Size 

func (m *DryDownlinkMessage) XXX_Size() int

func (*DryDownlinkMessage) XXX_Unmarshal 

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

type DryDownlinkResult 

type DryDownlinkResult struct {
	// The payload that was encoded
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// Logs that have been generated while processing
	Logs                 []*LogEntry `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

DryDownlinkResult is the result from a downlink simulation

func NewPopulatedDryDownlinkResult 

func NewPopulatedDryDownlinkResult(r randyHandler, easy bool) *DryDownlinkResult

func (*DryDownlinkResult) Descriptor 

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

func (*DryDownlinkResult) Equal 

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

func (*DryDownlinkResult) GetLogs 

func (m *DryDownlinkResult) GetLogs() []*LogEntry

func (*DryDownlinkResult) GetPayload 

func (m *DryDownlinkResult) GetPayload() []byte

func (*DryDownlinkResult) Marshal 

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

func (*DryDownlinkResult) MarshalTo 

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

func (*DryDownlinkResult) MarshalToSizedBuffer 

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

func (*DryDownlinkResult) ProtoMessage 

func (*DryDownlinkResult) ProtoMessage()

func (*DryDownlinkResult) Reset 

func (m *DryDownlinkResult) Reset()

func (*DryDownlinkResult) Size 

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

func (*DryDownlinkResult) String 

func (this *DryDownlinkResult) String() string

func (*DryDownlinkResult) Unmarshal 

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

func (*DryDownlinkResult) XXX_DiscardUnknown 

func (m *DryDownlinkResult) XXX_DiscardUnknown()

func (*DryDownlinkResult) XXX_Marshal 

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

func (*DryDownlinkResult) XXX_Merge 

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

func (*DryDownlinkResult) XXX_Size 

func (m *DryDownlinkResult) XXX_Size() int

func (*DryDownlinkResult) XXX_Unmarshal 

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

type DryUplinkMessage 

type DryUplinkMessage struct {
	// The binary payload to use
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The Application containing the payload functions that should be executed
	App Application `protobuf:"bytes,2,opt,name=app,proto3" json:"app"`
	// The port number that should be passed to the payload function
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DryUplinkMessage is a simulated message to test uplink processing

func NewPopulatedDryUplinkMessage 

func NewPopulatedDryUplinkMessage(r randyHandler, easy bool) *DryUplinkMessage

func (*DryUplinkMessage) Descriptor 

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

func (*DryUplinkMessage) Equal 

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

func (*DryUplinkMessage) GetApp 

func (m *DryUplinkMessage) GetApp() Application

func (*DryUplinkMessage) GetPayload 

func (m *DryUplinkMessage) GetPayload() []byte

func (*DryUplinkMessage) GetPort 

func (m *DryUplinkMessage) GetPort() uint32

func (*DryUplinkMessage) Marshal 

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

func (*DryUplinkMessage) MarshalTo 

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

func (*DryUplinkMessage) MarshalToSizedBuffer 

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

func (*DryUplinkMessage) ProtoMessage 

func (*DryUplinkMessage) ProtoMessage()

func (*DryUplinkMessage) Reset 

func (m *DryUplinkMessage) Reset()

func (*DryUplinkMessage) Size 

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

func (*DryUplinkMessage) String 

func (this *DryUplinkMessage) String() string

func (*DryUplinkMessage) Unmarshal 

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

func (*DryUplinkMessage) XXX_DiscardUnknown 

func (m *DryUplinkMessage) XXX_DiscardUnknown()

func (*DryUplinkMessage) XXX_Marshal 

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

func (*DryUplinkMessage) XXX_Merge 

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

func (*DryUplinkMessage) XXX_Size 

func (m *DryUplinkMessage) XXX_Size() int

func (*DryUplinkMessage) XXX_Unmarshal 

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

type DryUplinkResult 

type DryUplinkResult struct {
	// The binary payload
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The decoded fields
	Fields string `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	// Was validation of the message successful
	Valid bool `protobuf:"varint,3,opt,name=valid,proto3" json:"valid,omitempty"`
	// Logs that have been generated while processing
	Logs                 []*LogEntry `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

DryUplinkResult is the result from an uplink simulation

func NewPopulatedDryUplinkResult 

func NewPopulatedDryUplinkResult(r randyHandler, easy bool) *DryUplinkResult

func (*DryUplinkResult) Descriptor 

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

func (*DryUplinkResult) Equal 

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

func (*DryUplinkResult) GetFields 

func (m *DryUplinkResult) GetFields() string

func (*DryUplinkResult) GetLogs 

func (m *DryUplinkResult) GetLogs() []*LogEntry

func (*DryUplinkResult) GetPayload 

func (m *DryUplinkResult) GetPayload() []byte

func (*DryUplinkResult) GetValid 

func (m *DryUplinkResult) GetValid() bool

func (*DryUplinkResult) Marshal 

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

func (*DryUplinkResult) MarshalTo 

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

func (*DryUplinkResult) MarshalToSizedBuffer 

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

func (*DryUplinkResult) ProtoMessage 

func (*DryUplinkResult) ProtoMessage()

func (*DryUplinkResult) Reset 

func (m *DryUplinkResult) Reset()

func (*DryUplinkResult) Size 

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

func (*DryUplinkResult) String 

func (this *DryUplinkResult) String() string

func (*DryUplinkResult) Unmarshal 

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

func (*DryUplinkResult) XXX_DiscardUnknown 

func (m *DryUplinkResult) XXX_DiscardUnknown()

func (*DryUplinkResult) XXX_Marshal 

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

func (*DryUplinkResult) XXX_Merge 

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

func (*DryUplinkResult) XXX_Size 

func (m *DryUplinkResult) XXX_Size() int

func (*DryUplinkResult) XXX_Unmarshal 

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

type HandlerClient 

type HandlerClient interface {
	ActivationChallenge(ctx context.Context, in *broker.ActivationChallengeRequest, opts ...grpc.CallOption) (*broker.ActivationChallengeResponse, error)
	Activate(ctx context.Context, in *broker.DeduplicatedDeviceActivationRequest, opts ...grpc.CallOption) (*DeviceActivationResponse, error)
}

HandlerClient is the client API for Handler service.

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

func NewHandlerClient 

func NewHandlerClient(cc *grpc.ClientConn) HandlerClient

type HandlerManagerClient 

type HandlerManagerClient interface {
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*Status, error)
}

HandlerManagerClient is the client API for HandlerManager service.

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

func NewHandlerManagerClient 

func NewHandlerManagerClient(cc *grpc.ClientConn) HandlerManagerClient

type HandlerManagerServer 

type HandlerManagerServer interface {
	GetStatus(context.Context, *StatusRequest) (*Status, error)
}

HandlerManagerServer is the server API for HandlerManager service.

type HandlerServer 

type HandlerServer interface {
	ActivationChallenge(context.Context, *broker.ActivationChallengeRequest) (*broker.ActivationChallengeResponse, error)
	Activate(context.Context, *broker.DeduplicatedDeviceActivationRequest) (*DeviceActivationResponse, error)
}

HandlerServer is the server API for Handler service.

type LogEntry 

type LogEntry struct {
	// The location where the log was created (what payload function)
	Function string `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	// A list of JSON-encoded fields that were logged
	Fields               []string `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func NewPopulatedLogEntry 

func NewPopulatedLogEntry(r randyHandler, easy bool) *LogEntry

func (*LogEntry) Descriptor 

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

func (*LogEntry) Equal 

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

func (*LogEntry) GetFields 

func (m *LogEntry) GetFields() []string

func (*LogEntry) GetFunction 

func (m *LogEntry) GetFunction() string

func (*LogEntry) Marshal 

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

func (*LogEntry) MarshalTo 

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

func (*LogEntry) MarshalToSizedBuffer 

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

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

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

func (*LogEntry) String 

func (this *LogEntry) String() string

func (*LogEntry) Unmarshal 

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

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type SimulatedUplinkMessage 

type SimulatedUplinkMessage struct {
	AppID string `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DevID string `protobuf:"bytes,2,opt,name=dev_id,json=devId,proto3" json:"dev_id,omitempty"`
	// The binary payload to use
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// The port number
	Port                 uint32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SimulatedUplinkMessage is a simulated uplink message

func NewPopulatedSimulatedUplinkMessage 

func NewPopulatedSimulatedUplinkMessage(r randyHandler, easy bool) *SimulatedUplinkMessage

func (*SimulatedUplinkMessage) Descriptor 

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

func (*SimulatedUplinkMessage) Equal 

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

func (*SimulatedUplinkMessage) GetAppID 

func (m *SimulatedUplinkMessage) GetAppID() string

func (*SimulatedUplinkMessage) GetDevID 

func (m *SimulatedUplinkMessage) GetDevID() string

func (*SimulatedUplinkMessage) GetPayload 

func (m *SimulatedUplinkMessage) GetPayload() []byte

func (*SimulatedUplinkMessage) GetPort 

func (m *SimulatedUplinkMessage) GetPort() uint32

func (*SimulatedUplinkMessage) Marshal 

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

func (*SimulatedUplinkMessage) MarshalTo 

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

func (*SimulatedUplinkMessage) MarshalToSizedBuffer 

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

func (*SimulatedUplinkMessage) ProtoMessage 

func (*SimulatedUplinkMessage) ProtoMessage()

func (*SimulatedUplinkMessage) Reset 

func (m *SimulatedUplinkMessage) Reset()

func (*SimulatedUplinkMessage) Size 

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

func (*SimulatedUplinkMessage) String 

func (this *SimulatedUplinkMessage) String() string

func (*SimulatedUplinkMessage) Unmarshal 

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

func (*SimulatedUplinkMessage) Validate 

func (m *SimulatedUplinkMessage) Validate() error

Validate implements the api.Validator interface

func (*SimulatedUplinkMessage) XXX_DiscardUnknown 

func (m *SimulatedUplinkMessage) XXX_DiscardUnknown()

func (*SimulatedUplinkMessage) XXX_Marshal 

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

func (*SimulatedUplinkMessage) XXX_Merge 

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

func (*SimulatedUplinkMessage) XXX_Size 

func (m *SimulatedUplinkMessage) XXX_Size() int

func (*SimulatedUplinkMessage) XXX_Unmarshal 

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

type Status 

type Status struct {
	System               api.SystemStats    `protobuf:"bytes,1,opt,name=system,proto3" json:"system"`
	Component            api.ComponentStats `protobuf:"bytes,2,opt,name=component,proto3" json:"component"`
	Uplink               *api.Rates         `protobuf:"bytes,11,opt,name=uplink,proto3" json:"uplink,omitempty"`
	Downlink             *api.Rates         `protobuf:"bytes,12,opt,name=downlink,proto3" json:"downlink,omitempty"`
	Activations          *api.Rates         `protobuf:"bytes,13,opt,name=activations,proto3" json:"activations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

message Status is the response to the StatusRequest

func NewPopulatedStatus 

func NewPopulatedStatus(r randyHandler, easy bool) *Status

func (*Status) Descriptor 

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

func (*Status) Equal 

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

func (*Status) GetActivations 

func (m *Status) GetActivations() *api.Rates

func (*Status) GetComponent 

func (m *Status) GetComponent() api.ComponentStats
func (m *Status) GetDownlink() *api.Rates

func (*Status) GetSystem 

func (m *Status) GetSystem() api.SystemStats
func (m *Status) GetUplink() *api.Rates

func (*Status) Marshal 

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

func (*Status) MarshalTo 

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

func (*Status) MarshalToSizedBuffer 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

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

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

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

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message StatusRequest is used to request the status of this Handler

func NewPopulatedStatusRequest 

func NewPopulatedStatusRequest(r randyHandler, easy bool) *StatusRequest

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) Equal 

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

func (*StatusRequest) Marshal 

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

func (*StatusRequest) MarshalTo 

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

func (*StatusRequest) MarshalToSizedBuffer 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

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

func (*StatusRequest) String 

func (this *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

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

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type UnimplementedApplicationManagerServer 

type UnimplementedApplicationManagerServer struct {
}

UnimplementedApplicationManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationManagerServer) DeleteApplication 

func (*UnimplementedApplicationManagerServer) DeleteApplication(ctx context.Context, req *ApplicationIdentifier) (*types.Empty, error)

func (*UnimplementedApplicationManagerServer) DeleteDevice 

func (*UnimplementedApplicationManagerServer) DeleteDevice(ctx context.Context, req *DeviceIdentifier) (*types.Empty, error)
func (*UnimplementedApplicationManagerServer) DryDownlink(ctx context.Context, req *DryDownlinkMessage) (*DryDownlinkResult, error)
func (*UnimplementedApplicationManagerServer) DryUplink(ctx context.Context, req *DryUplinkMessage) (*DryUplinkResult, error)

func (*UnimplementedApplicationManagerServer) GetApplication 

func (*UnimplementedApplicationManagerServer) GetApplication(ctx context.Context, req *ApplicationIdentifier) (*Application, error)

func (*UnimplementedApplicationManagerServer) GetDevice 

func (*UnimplementedApplicationManagerServer) GetDevice(ctx context.Context, req *DeviceIdentifier) (*Device, error)

func (*UnimplementedApplicationManagerServer) GetDevicesForApplication 

func (*UnimplementedApplicationManagerServer) GetDevicesForApplication(ctx context.Context, req *ApplicationIdentifier) (*DeviceList, error)

func (*UnimplementedApplicationManagerServer) RegisterApplication 

func (*UnimplementedApplicationManagerServer) RegisterApplication(ctx context.Context, req *ApplicationIdentifier) (*types.Empty, error)

func (*UnimplementedApplicationManagerServer) SetApplication 

func (*UnimplementedApplicationManagerServer) SetApplication(ctx context.Context, req *Application) (*types.Empty, error)

func (*UnimplementedApplicationManagerServer) SetDevice 

func (*UnimplementedApplicationManagerServer) SetDevice(ctx context.Context, req *Device) (*types.Empty, error)
func (*UnimplementedApplicationManagerServer) SimulateUplink(ctx context.Context, req *SimulatedUplinkMessage) (*types.Empty, error)

type UnimplementedHandlerManagerServer 

type UnimplementedHandlerManagerServer struct {
}

UnimplementedHandlerManagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedHandlerManagerServer) GetStatus 

func (*UnimplementedHandlerManagerServer) GetStatus(ctx context.Context, req *StatusRequest) (*Status, error)

type UnimplementedHandlerServer 

type UnimplementedHandlerServer struct {
}

UnimplementedHandlerServer can be embedded to have forward compatible implementations.

func (*UnimplementedHandlerServer) Activate 

func (*UnimplementedHandlerServer) Activate(ctx context.Context, req *broker.DeduplicatedDeviceActivationRequest) (*DeviceActivationResponse, error)

func (*UnimplementedHandlerServer) ActivationChallenge 

func (*UnimplementedHandlerServer) ActivationChallenge(ctx context.Context, req *broker.ActivationChallengeRequest) (*broker.ActivationChallengeResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.