external

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2023 License: MIT Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Setup 

func Setup(conf config.Config) error

Setup configures the API package.

Types

type ApplicationAPI 

type ApplicationAPI struct {
	// contains filtered or unexported fields
}

ApplicationAPI exports the Application related functions.

func NewApplicationAPI 

func NewApplicationAPI(validator auth.Validator) *ApplicationAPI

NewApplicationAPI creates a new ApplicationAPI.

func (*ApplicationAPI) Create 

func (a *ApplicationAPI) Create(ctx context.Context, req *pb.CreateApplicationRequest) (*pb.CreateApplicationResponse, error)

Create creates the given application.

func (*ApplicationAPI) CreateAWSSNSIntegration 

func (a *ApplicationAPI) CreateAWSSNSIntegration(ctx context.Context, in *pb.CreateAWSSNSIntegrationRequest) (*empty.Empty, error)

CreateAWSSNSIntegration creates a AWS SNS application-integration.

func (*ApplicationAPI) CreateAzureServiceBusIntegration 

func (a *ApplicationAPI) CreateAzureServiceBusIntegration(ctx context.Context, in *pb.CreateAzureServiceBusIntegrationRequest) (*empty.Empty, error)

CreateAzureServiceBusIntegration creates an Azure Service-Bus application-integration.

func (*ApplicationAPI) CreateGCPPubSubIntegration 

func (a *ApplicationAPI) CreateGCPPubSubIntegration(ctx context.Context, in *pb.CreateGCPPubSubIntegrationRequest) (*empty.Empty, error)

CreateGCPPubSubIntegration creates a GCP PubSub application-integration.

func (*ApplicationAPI) CreateHTTPIntegration 

func (a *ApplicationAPI) CreateHTTPIntegration(ctx context.Context, in *pb.CreateHTTPIntegrationRequest) (*empty.Empty, error)

CreateHTTPIntegration creates an HTTP application-integration.

func (*ApplicationAPI) CreateInfluxDBIntegration 

func (a *ApplicationAPI) CreateInfluxDBIntegration(ctx context.Context, in *pb.CreateInfluxDBIntegrationRequest) (*empty.Empty, error)

CreateInfluxDBIntegration create an InfluxDB application-integration.

func (*ApplicationAPI) CreateLoRaCloudIntegration 

func (a *ApplicationAPI) CreateLoRaCloudIntegration(ctx context.Context, in *pb.CreateLoRaCloudIntegrationRequest) (*empty.Empty, error)

CreateLoRaCloudIntegration creates a LoRaCloud application-integration.

func (*ApplicationAPI) CreateMyDevicesIntegration 

func (a *ApplicationAPI) CreateMyDevicesIntegration(ctx context.Context, in *pb.CreateMyDevicesIntegrationRequest) (*empty.Empty, error)

CreateMyDevicesIntegration creates a MyDevices application-integration.

func (*ApplicationAPI) CreatePilotThingsIntegration 

func (a *ApplicationAPI) CreatePilotThingsIntegration(ctx context.Context, in *pb.CreatePilotThingsIntegrationRequest) (*empty.Empty, error)

CreatePilotThingsIntegration creates an Pilot Things application-integration.

func (*ApplicationAPI) CreateThingsBoardIntegration 

func (a *ApplicationAPI) CreateThingsBoardIntegration(ctx context.Context, in *pb.CreateThingsBoardIntegrationRequest) (*empty.Empty, error)

CreateThingsBoardIntegration creates a ThingsBoard application-integration.

func (*ApplicationAPI) Delete 

func (a *ApplicationAPI) Delete(ctx context.Context, req *pb.DeleteApplicationRequest) (*empty.Empty, error)

Delete deletes the given application.

func (*ApplicationAPI) DeleteAWSSNSIntegration 

func (a *ApplicationAPI) DeleteAWSSNSIntegration(ctx context.Context, in *pb.DeleteAWSSNSIntegrationRequest) (*empty.Empty, error)

DeleteAWSSNSIntegration deletes the AWS SNS application-integration.

func (*ApplicationAPI) DeleteAzureServiceBusIntegration 

func (a *ApplicationAPI) DeleteAzureServiceBusIntegration(ctx context.Context, in *pb.DeleteAzureServiceBusIntegrationRequest) (*empty.Empty, error)

DeleteAzureServiceBusIntegration deletes the Azure Service-Bus application-integration.

func (*ApplicationAPI) DeleteGCPPubSubIntegration 

func (a *ApplicationAPI) DeleteGCPPubSubIntegration(ctx context.Context, in *pb.DeleteGCPPubSubIntegrationRequest) (*empty.Empty, error)

DeleteGCPPubSubIntegration deletes the GCP PubSub application-integration.

func (*ApplicationAPI) DeleteHTTPIntegration 

func (a *ApplicationAPI) DeleteHTTPIntegration(ctx context.Context, in *pb.DeleteHTTPIntegrationRequest) (*empty.Empty, error)

DeleteHTTPIntegration deletes the application-integration of the given type.

func (*ApplicationAPI) DeleteInfluxDBIntegration 

func (a *ApplicationAPI) DeleteInfluxDBIntegration(ctx context.Context, in *pb.DeleteInfluxDBIntegrationRequest) (*empty.Empty, error)

DeleteInfluxDBIntegration deletes the InfluxDB application-integration.

func (*ApplicationAPI) DeleteLoRaCloudIntegration 

func (a *ApplicationAPI) DeleteLoRaCloudIntegration(ctx context.Context, in *pb.DeleteLoRaCloudIntegrationRequest) (*empty.Empty, error)

DeleteLoRaCloudIntegration deletes the LoRaCloud application-integration.

func (*ApplicationAPI) DeleteMyDevicesIntegration 

func (a *ApplicationAPI) DeleteMyDevicesIntegration(ctx context.Context, in *pb.DeleteMyDevicesIntegrationRequest) (*empty.Empty, error)

DeleteMyDevicesIntegration deletes the MyDevices application-integration.

func (*ApplicationAPI) DeletePilotThingsIntegration 

func (a *ApplicationAPI) DeletePilotThingsIntegration(ctx context.Context, in *pb.DeletePilotThingsIntegrationRequest) (*empty.Empty, error)

DeletePilotThingsIntegration deletes an Pilot Things application-integration.

func (*ApplicationAPI) DeleteThingsBoardIntegration 

func (a *ApplicationAPI) DeleteThingsBoardIntegration(ctx context.Context, in *pb.DeleteThingsBoardIntegrationRequest) (*empty.Empty, error)

DeleteThingsBoardIntegration deletes the ThingsBoard application-integration.

func (*ApplicationAPI) GenerateMQTTIntegrationClientCertificate 

func (a *ApplicationAPI) GenerateMQTTIntegrationClientCertificate(ctx context.Context, in *pb.GenerateMQTTIntegrationClientCertificateRequest) (*pb.GenerateMQTTIntegrationClientCertificateResponse, error)

GenerateMQTTIntegrationClientCertificate generates an application ID specific TLS certificate to connect to the MQTT broker.

func (*ApplicationAPI) Get 

func (a *ApplicationAPI) Get(ctx context.Context, req *pb.GetApplicationRequest) (*pb.GetApplicationResponse, error)

Get returns the requested application.

func (*ApplicationAPI) GetAWSSNSIntegration 

func (a *ApplicationAPI) GetAWSSNSIntegration(ctx context.Context, in *pb.GetAWSSNSIntegrationRequest) (*pb.GetAWSSNSIntegrationResponse, error)

GetAWSSNSIntegration returns the AWS SNS application-integration.

func (*ApplicationAPI) GetAzureServiceBusIntegration 

func (a *ApplicationAPI) GetAzureServiceBusIntegration(ctx context.Context, in *pb.GetAzureServiceBusIntegrationRequest) (*pb.GetAzureServiceBusIntegrationResponse, error)

GetAzureServiceBusIntegration returns the Azure Service-Bus application-integration.

func (*ApplicationAPI) GetGCPPubSubIntegration 

func (a *ApplicationAPI) GetGCPPubSubIntegration(ctx context.Context, in *pb.GetGCPPubSubIntegrationRequest) (*pb.GetGCPPubSubIntegrationResponse, error)

GetGCPPubSubIntegration returns the GCP PubSub application-integration.

func (*ApplicationAPI) GetHTTPIntegration 

func (a *ApplicationAPI) GetHTTPIntegration(ctx context.Context, in *pb.GetHTTPIntegrationRequest) (*pb.GetHTTPIntegrationResponse, error)

GetHTTPIntegration returns the HTTP application-itegration.

func (*ApplicationAPI) GetInfluxDBIntegration 

func (a *ApplicationAPI) GetInfluxDBIntegration(ctx context.Context, in *pb.GetInfluxDBIntegrationRequest) (*pb.GetInfluxDBIntegrationResponse, error)

GetInfluxDBIntegration returns the InfluxDB application-integration.

func (*ApplicationAPI) GetLoRaCloudIntegration 

func (a *ApplicationAPI) GetLoRaCloudIntegration(ctx context.Context, in *pb.GetLoRaCloudIntegrationRequest) (*pb.GetLoRaCloudIntegrationResponse, error)

GetLoRaCloudIntegration returns the LoRaCloud application-integration.

func (*ApplicationAPI) GetMyDevicesIntegration 

func (a *ApplicationAPI) GetMyDevicesIntegration(ctx context.Context, in *pb.GetMyDevicesIntegrationRequest) (*pb.GetMyDevicesIntegrationResponse, error)

GetMyDevicesIntegration returns the MyDevices application-integration.

func (*ApplicationAPI) GetPilotThingsIntegration 

func (a *ApplicationAPI) GetPilotThingsIntegration(ctx context.Context, in *pb.GetPilotThingsIntegrationRequest) (*pb.GetPilotThingsIntegrationResponse, error)

GetPilotThingsIntegration returns the Pilot Things application-integration.

func (*ApplicationAPI) GetThingsBoardIntegration 

func (a *ApplicationAPI) GetThingsBoardIntegration(ctx context.Context, in *pb.GetThingsBoardIntegrationRequest) (*pb.GetThingsBoardIntegrationResponse, error)

GetThingsBoardIntegration returns the ThingsBoard application-integration.

func (*ApplicationAPI) List 

func (a *ApplicationAPI) List(ctx context.Context, req *pb.ListApplicationRequest) (*pb.ListApplicationResponse, error)

List lists the available applications.

func (*ApplicationAPI) ListIntegrations 

func (a *ApplicationAPI) ListIntegrations(ctx context.Context, in *pb.ListIntegrationRequest) (*pb.ListIntegrationResponse, error)

ListIntegrations lists all configured integrations.

func (*ApplicationAPI) Update 

func (a *ApplicationAPI) Update(ctx context.Context, req *pb.UpdateApplicationRequest) (*empty.Empty, error)

Update updates the given application.

func (*ApplicationAPI) UpdateAWSSNSIntegration 

func (a *ApplicationAPI) UpdateAWSSNSIntegration(ctx context.Context, in *pb.UpdateAWSSNSIntegrationRequest) (*empty.Empty, error)

UpdateAWSSNSIntegration updates the AWS SNS application-integration.

func (*ApplicationAPI) UpdateAzureServiceBusIntegration 

func (a *ApplicationAPI) UpdateAzureServiceBusIntegration(ctx context.Context, in *pb.UpdateAzureServiceBusIntegrationRequest) (*empty.Empty, error)

UpdateAzureServiceBusIntegration updates the Azure Service-Bus application-integration.

func (*ApplicationAPI) UpdateGCPPubSubIntegration 

func (a *ApplicationAPI) UpdateGCPPubSubIntegration(ctx context.Context, in *pb.UpdateGCPPubSubIntegrationRequest) (*empty.Empty, error)

UpdateGCPPubSubIntegration updates the GCP PubSub application-integration.

func (*ApplicationAPI) UpdateHTTPIntegration 

func (a *ApplicationAPI) UpdateHTTPIntegration(ctx context.Context, in *pb.UpdateHTTPIntegrationRequest) (*empty.Empty, error)

UpdateHTTPIntegration updates the HTTP application-integration.

func (*ApplicationAPI) UpdateInfluxDBIntegration 

func (a *ApplicationAPI) UpdateInfluxDBIntegration(ctx context.Context, in *pb.UpdateInfluxDBIntegrationRequest) (*empty.Empty, error)

UpdateInfluxDBIntegration updates the InfluxDB application-integration.

func (*ApplicationAPI) UpdateLoRaCloudIntegration 

func (a *ApplicationAPI) UpdateLoRaCloudIntegration(ctx context.Context, in *pb.UpdateLoRaCloudIntegrationRequest) (*empty.Empty, error)

UpdateLoRaCloudIntegration updates the LoRaCloud application-integration.

func (*ApplicationAPI) UpdateMyDevicesIntegration 

func (a *ApplicationAPI) UpdateMyDevicesIntegration(ctx context.Context, in *pb.UpdateMyDevicesIntegrationRequest) (*empty.Empty, error)

UpdateMyDevicesIntegration updates the MyDevices application-integration.

func (*ApplicationAPI) UpdatePilotThingsIntegration 

func (a *ApplicationAPI) UpdatePilotThingsIntegration(ctx context.Context, in *pb.UpdatePilotThingsIntegrationRequest) (*empty.Empty, error)

UpdatePilotThingsIntegration updates the Pilot Things application-integration.

func (*ApplicationAPI) UpdateThingsBoardIntegration 

func (a *ApplicationAPI) UpdateThingsBoardIntegration(ctx context.Context, in *pb.UpdateThingsBoardIntegrationRequest) (*empty.Empty, error)

UpdateThingsBoardIntegration updates the ThingsBoard application-integration.

type DeviceAPI 

type DeviceAPI struct {
	// contains filtered or unexported fields
}

DeviceAPI exports the Node related functions.

func NewDeviceAPI 

func NewDeviceAPI(validator auth.Validator) *DeviceAPI

NewDeviceAPI creates a new NodeAPI.

func (*DeviceAPI) Activate 

func (a *DeviceAPI) Activate(ctx context.Context, req *pb.ActivateDeviceRequest) (*empty.Empty, error)

Activate activates the node (ABP only).

func (*DeviceAPI) ClearDeviceNonces 

func (a *DeviceAPI) ClearDeviceNonces(ctx context.Context, req *pb.ClearDeviceNoncesRequest) (*empty.Empty, error)

ClearDeviceNonces deletes the device older activation records for the given DevEUI. TODO: These are clear older DevNonce records from device activation records in Network Server TODO: These clears all DevNonce records but keeps latest 20 records for maintain device activation status

func (*DeviceAPI) Create 

func (a *DeviceAPI) Create(ctx context.Context, req *pb.CreateDeviceRequest) (*empty.Empty, error)

Create creates the given device.

func (*DeviceAPI) CreateKeys 

func (a *DeviceAPI) CreateKeys(ctx context.Context, req *pb.CreateDeviceKeysRequest) (*empty.Empty, error)

CreateKeys creates the given device-keys.

func (*DeviceAPI) Deactivate 

func (a *DeviceAPI) Deactivate(ctx context.Context, req *pb.DeactivateDeviceRequest) (*empty.Empty, error)

Deactivate de-activates the device.

func (*DeviceAPI) Delete 

func (a *DeviceAPI) Delete(ctx context.Context, req *pb.DeleteDeviceRequest) (*empty.Empty, error)

Delete deletes the node matching the given name.

func (*DeviceAPI) DeleteKeys 

func (a *DeviceAPI) DeleteKeys(ctx context.Context, req *pb.DeleteDeviceKeysRequest) (*empty.Empty, error)

DeleteKeys deletes the device-keys for the given DevEUI.

func (*DeviceAPI) Get 

func (a *DeviceAPI) Get(ctx context.Context, req *pb.GetDeviceRequest) (*pb.GetDeviceResponse, error)

Get returns the device matching the given DevEUI.

func (*DeviceAPI) GetActivation 

func (a *DeviceAPI) GetActivation(ctx context.Context, req *pb.GetDeviceActivationRequest) (*pb.GetDeviceActivationResponse, error)

GetActivation returns the device activation for the given DevEUI.

func (*DeviceAPI) GetKeys 

func (a *DeviceAPI) GetKeys(ctx context.Context, req *pb.GetDeviceKeysRequest) (*pb.GetDeviceKeysResponse, error)

GetKeys returns the device-keys for the given DevEUI.

func (*DeviceAPI) GetRandomDevAddr 

func (a *DeviceAPI) GetRandomDevAddr(ctx context.Context, req *pb.GetRandomDevAddrRequest) (*pb.GetRandomDevAddrResponse, error)

GetRandomDevAddr returns a random DevAddr taking the NwkID prefix into account.

func (*DeviceAPI) GetStats 

func (a *DeviceAPI) GetStats(ctx context.Context, req *pb.GetDeviceStatsRequest) (*pb.GetDeviceStatsResponse, error)

GetStats returns the device statistics.

func (*DeviceAPI) List 

func (a *DeviceAPI) List(ctx context.Context, req *pb.ListDeviceRequest) (*pb.ListDeviceResponse, error)

List lists the available applications.

func (*DeviceAPI) StreamEventLogs 

func (a *DeviceAPI) StreamEventLogs(req *pb.StreamDeviceEventLogsRequest, srv pb.DeviceService_StreamEventLogsServer) error

StreamEventLogs stream the device events (uplink payloads, ACKs, joins, errors). Note: this endpoint is intended for debugging and should not be used for building integrations.

func (*DeviceAPI) StreamFrameLogs 

func (a *DeviceAPI) StreamFrameLogs(req *pb.StreamDeviceFrameLogsRequest, srv pb.DeviceService_StreamFrameLogsServer) error

StreamFrameLogs streams the uplink and downlink frame-logs for the given DevEUI. Note: these are the raw LoRaWAN frames and this endpoint is intended for debugging.

func (*DeviceAPI) Update 

func (a *DeviceAPI) Update(ctx context.Context, req *pb.UpdateDeviceRequest) (*empty.Empty, error)

Update updates the device matching the given DevEUI.

func (*DeviceAPI) UpdateKeys 

func (a *DeviceAPI) UpdateKeys(ctx context.Context, req *pb.UpdateDeviceKeysRequest) (*empty.Empty, error)

UpdateKeys updates the device-keys.

type DeviceProfileServiceAPI 

type DeviceProfileServiceAPI struct {
	// contains filtered or unexported fields
}

DeviceProfileServiceAPI exports the ServiceProfile related functions.

func NewDeviceProfileServiceAPI 

func NewDeviceProfileServiceAPI(validator auth.Validator) *DeviceProfileServiceAPI

NewDeviceProfileServiceAPI creates a new DeviceProfileServiceAPI.

func (*DeviceProfileServiceAPI) Create 

func (a *DeviceProfileServiceAPI) Create(ctx context.Context, req *pb.CreateDeviceProfileRequest) (*pb.CreateDeviceProfileResponse, error)

Create creates the given device-profile.

func (*DeviceProfileServiceAPI) Delete 

func (a *DeviceProfileServiceAPI) Delete(ctx context.Context, req *pb.DeleteDeviceProfileRequest) (*empty.Empty, error)

Delete deletes the device-profile matching the given id.

func (*DeviceProfileServiceAPI) Get 

func (a *DeviceProfileServiceAPI) Get(ctx context.Context, req *pb.GetDeviceProfileRequest) (*pb.GetDeviceProfileResponse, error)

Get returns the device-profile matching the given id.

func (*DeviceProfileServiceAPI) List 

func (a *DeviceProfileServiceAPI) List(ctx context.Context, req *pb.ListDeviceProfileRequest) (*pb.ListDeviceProfileResponse, error)

List lists the available device-profiles.

func (*DeviceProfileServiceAPI) Update 

func (a *DeviceProfileServiceAPI) Update(ctx context.Context, req *pb.UpdateDeviceProfileRequest) (*empty.Empty, error)

Update updates the given device-profile.

type DeviceQueueAPI 

type DeviceQueueAPI struct {
	// contains filtered or unexported fields
}

DeviceQueueAPI exposes the downlink queue methods.

func NewDeviceQueueAPI 

func NewDeviceQueueAPI(validator auth.Validator) *DeviceQueueAPI

NewDeviceQueueAPI creates a new DeviceQueueAPI.

func (*DeviceQueueAPI) Enqueue 

func (d *DeviceQueueAPI) Enqueue(ctx context.Context, req *pb.EnqueueDeviceQueueItemRequest) (*pb.EnqueueDeviceQueueItemResponse, error)

Enqueue adds the given item to the device-queue.

func (*DeviceQueueAPI) Flush 

func (d *DeviceQueueAPI) Flush(ctx context.Context, req *pb.FlushDeviceQueueRequest) (*empty.Empty, error)

Flush flushes the downlink device-queue.

func (*DeviceQueueAPI) List 

func (d *DeviceQueueAPI) List(ctx context.Context, req *pb.ListDeviceQueueItemsRequest) (*pb.ListDeviceQueueItemsResponse, error)

List lists the items in the device-queue.

type GatewayAPI 

type GatewayAPI struct {
	// contains filtered or unexported fields
}

GatewayAPI exports the Gateway related functions.

func NewGatewayAPI 

func NewGatewayAPI(validator auth.Validator) *GatewayAPI

NewGatewayAPI creates a new GatewayAPI.

func (*GatewayAPI) Create 

func (a *GatewayAPI) Create(ctx context.Context, req *pb.CreateGatewayRequest) (*empty.Empty, error)

Create creates the given gateway.

func (*GatewayAPI) Delete 

func (a *GatewayAPI) Delete(ctx context.Context, req *pb.DeleteGatewayRequest) (*empty.Empty, error)

Delete deletes the gateway matching the given ID.

func (*GatewayAPI) GenerateGatewayClientCertificate 

func (a *GatewayAPI) GenerateGatewayClientCertificate(ctx context.Context, req *pb.GenerateGatewayClientCertificateRequest) (*pb.GenerateGatewayClientCertificateResponse, error)

GenerateGatewayClientCertificate returns a TLS certificate for gateway authentication / authorization.

func (*GatewayAPI) Get 

func (a *GatewayAPI) Get(ctx context.Context, req *pb.GetGatewayRequest) (*pb.GetGatewayResponse, error)

Get returns the gateway matching the given Mac.

func (*GatewayAPI) GetLastPing 

func (a *GatewayAPI) GetLastPing(ctx context.Context, req *pb.GetLastPingRequest) (*pb.GetLastPingResponse, error)

GetLastPing returns the last emitted ping and gateways receiving this ping.

func (*GatewayAPI) GetStats 

func (a *GatewayAPI) GetStats(ctx context.Context, req *pb.GetGatewayStatsRequest) (*pb.GetGatewayStatsResponse, error)

GetStats gets the gateway statistics for the gateway with the given Mac.

func (*GatewayAPI) List 

func (a *GatewayAPI) List(ctx context.Context, req *pb.ListGatewayRequest) (*pb.ListGatewayResponse, error)

List lists the gateways.

func (*GatewayAPI) StreamFrameLogs 

func (a *GatewayAPI) StreamFrameLogs(req *pb.StreamGatewayFrameLogsRequest, srv pb.GatewayService_StreamFrameLogsServer) error

StreamFrameLogs streams the uplink and downlink frame-logs for the given mac. Note: these are the raw LoRaWAN frames and this endpoint is intended for debugging.

func (*GatewayAPI) Update 

func (a *GatewayAPI) Update(ctx context.Context, req *pb.UpdateGatewayRequest) (*empty.Empty, error)

Update updates the given gateway.

type GatewayProfileAPI 

type GatewayProfileAPI struct {
	// contains filtered or unexported fields
}

GatewayProfileAPI exports the GatewayProfile related functions.

func NewGatewayProfileAPI 

func NewGatewayProfileAPI(validator auth.Validator) *GatewayProfileAPI

NewGatewayProfileAPI creates a new GatewayProfileAPI.

func (*GatewayProfileAPI) Create 

func (a *GatewayProfileAPI) Create(ctx context.Context, req *pb.CreateGatewayProfileRequest) (*pb.CreateGatewayProfileResponse, error)

Create creates the given gateway-profile.

func (*GatewayProfileAPI) Delete 

func (a *GatewayProfileAPI) Delete(ctx context.Context, req *pb.DeleteGatewayProfileRequest) (*empty.Empty, error)

Delete deletes the gateway-profile matching the given id.

func (*GatewayProfileAPI) Get 

func (a *GatewayProfileAPI) Get(ctx context.Context, req *pb.GetGatewayProfileRequest) (*pb.GetGatewayProfileResponse, error)

Get returns the gateway-profile matching the given id.

func (*GatewayProfileAPI) List 

func (a *GatewayProfileAPI) List(ctx context.Context, req *pb.ListGatewayProfilesRequest) (*pb.ListGatewayProfilesResponse, error)

List returns the existing gateway-profiles.

func (*GatewayProfileAPI) Update 

func (a *GatewayProfileAPI) Update(ctx context.Context, req *pb.UpdateGatewayProfileRequest) (*empty.Empty, error)

Update updates the given gateway-profile.

type InternalAPI 

type InternalAPI struct {
	// contains filtered or unexported fields
}

InternalAPI exports the internal User related functions.

func NewInternalAPI 

func NewInternalAPI(validator auth.Validator) *InternalAPI

NewInternalAPI creates a new InternalAPI.

func (*InternalAPI) CreateAPIKey 

func (a *InternalAPI) CreateAPIKey(ctx context.Context, req *pb.CreateAPIKeyRequest) (*pb.CreateAPIKeyResponse, error)

CreateAPIKey creates the given API key.

func (*InternalAPI) DeleteAPIKey 

func (a *InternalAPI) DeleteAPIKey(ctx context.Context, req *pb.DeleteAPIKeyRequest) (*empty.Empty, error)

DeleteAPIKey deletes the given API key.

func (*InternalAPI) GetDevicesSummary 

func (a *InternalAPI) GetDevicesSummary(ctx context.Context, req *pb.GetDevicesSummaryRequest) (*pb.GetDevicesSummaryResponse, error)

GetDevicesSummary returns an aggregated devices summary.

func (*InternalAPI) GetGatewaysSummary 

func (a *InternalAPI) GetGatewaysSummary(ctx context.Context, req *pb.GetGatewaysSummaryRequest) (*pb.GetGatewaysSummaryResponse, error)

GetGatewaysSummary returns an aggregated gateways summary.

func (*InternalAPI) GlobalSearch 

func (a *InternalAPI) GlobalSearch(ctx context.Context, req *pb.GlobalSearchRequest) (*pb.GlobalSearchResponse, error)

GlobalSearch performs a global search.

func (*InternalAPI) ListAPIKeys 

func (a *InternalAPI) ListAPIKeys(ctx context.Context, req *pb.ListAPIKeysRequest) (*pb.ListAPIKeysResponse, error)

ListAPIKeys lists the API keys.

func (*InternalAPI) Login 

func (a *InternalAPI) Login(ctx context.Context, req *pb.LoginRequest) (*pb.LoginResponse, error)

Login validates the login request and returns a JWT token.

func (*InternalAPI) OpenIDConnectLogin 

func (a *InternalAPI) OpenIDConnectLogin(ctx context.Context, req *pb.OpenIDConnectLoginRequest) (*pb.OpenIDConnectLoginResponse, error)

OpenIDConnectLogin performs an OpenID Connect login.

func (*InternalAPI) Profile 

func (a *InternalAPI) Profile(ctx context.Context, req *empty.Empty) (*pb.ProfileResponse, error)

Profile returns the user profile.

func (*InternalAPI) Settings 

func (a *InternalAPI) Settings(ctx context.Context, _ *empty.Empty) (*pb.SettingsResponse, error)

Settings returns the global settings.

type MulticastGroupAPI 

type MulticastGroupAPI struct {
	// contains filtered or unexported fields
}

MulticastGroupAPI implements the multicast-group api.

func NewMulticastGroupAPI 

func NewMulticastGroupAPI(validator auth.Validator, routingProfileID uuid.UUID) *MulticastGroupAPI

NewMulticastGroupAPI creates a new multicast-group API.

func (*MulticastGroupAPI) AddDevice 

func (a *MulticastGroupAPI) AddDevice(ctx context.Context, req *pb.AddDeviceToMulticastGroupRequest) (*empty.Empty, error)

AddDevice adds the given device to the multicast-group.

func (*MulticastGroupAPI) Create 

func (a *MulticastGroupAPI) Create(ctx context.Context, req *pb.CreateMulticastGroupRequest) (*pb.CreateMulticastGroupResponse, error)

Create creates the given multicast-group.

func (*MulticastGroupAPI) Delete 

func (a *MulticastGroupAPI) Delete(ctx context.Context, req *pb.DeleteMulticastGroupRequest) (*empty.Empty, error)

Delete deletes a multicast-group given an ID.

func (*MulticastGroupAPI) Enqueue 

func (a *MulticastGroupAPI) Enqueue(ctx context.Context, req *pb.EnqueueMulticastQueueItemRequest) (*pb.EnqueueMulticastQueueItemResponse, error)

Enqueue adds the given item to the multicast-queue.

func (*MulticastGroupAPI) FlushQueue 

func (a *MulticastGroupAPI) FlushQueue(ctx context.Context, req *pb.FlushMulticastGroupQueueItemsRequest) (*empty.Empty, error)

FlushQueue flushes the multicast-group queue.

func (*MulticastGroupAPI) Get 

func (a *MulticastGroupAPI) Get(ctx context.Context, req *pb.GetMulticastGroupRequest) (*pb.GetMulticastGroupResponse, error)

Get returns a multicast-group given an ID.

func (*MulticastGroupAPI) List 

func (a *MulticastGroupAPI) List(ctx context.Context, req *pb.ListMulticastGroupRequest) (*pb.ListMulticastGroupResponse, error)

List lists the available multicast-groups.

func (*MulticastGroupAPI) ListQueue 

func (a *MulticastGroupAPI) ListQueue(ctx context.Context, req *pb.ListMulticastGroupQueueItemsRequest) (*pb.ListMulticastGroupQueueItemsResponse, error)

ListQueue lists the items in the multicast-group queue.

func (*MulticastGroupAPI) RemoveDevice 

func (a *MulticastGroupAPI) RemoveDevice(ctx context.Context, req *pb.RemoveDeviceFromMulticastGroupRequest) (*empty.Empty, error)

RemoveDevice removes the given device from the multicast-group.

func (*MulticastGroupAPI) Update 

func (a *MulticastGroupAPI) Update(ctx context.Context, req *pb.UpdateMulticastGroupRequest) (*empty.Empty, error)

Update updates the given multicast-group.

type NetworkServerAPI 

type NetworkServerAPI struct {
	// contains filtered or unexported fields
}

NetworkServerAPI exports the NetworkServer related functions.

func NewNetworkServerAPI 

func NewNetworkServerAPI(validator auth.Validator) *NetworkServerAPI

NewNetworkServerAPI creates a new NetworkServerAPI.

func (*NetworkServerAPI) Create 

func (a *NetworkServerAPI) Create(ctx context.Context, req *pb.CreateNetworkServerRequest) (*pb.CreateNetworkServerResponse, error)

Create creates the given network-server.

func (*NetworkServerAPI) Delete 

func (a *NetworkServerAPI) Delete(ctx context.Context, req *pb.DeleteNetworkServerRequest) (*empty.Empty, error)

Delete deletes the network-server matching the given id.

func (*NetworkServerAPI) Get 

func (a *NetworkServerAPI) Get(ctx context.Context, req *pb.GetNetworkServerRequest) (*pb.GetNetworkServerResponse, error)

Get returns the network-server matching the given id.

func (*NetworkServerAPI) GetADRAlgorithms 

func (a *NetworkServerAPI) GetADRAlgorithms(ctx context.Context, req *pb.GetADRAlgorithmsRequest) (*pb.GetADRAlgorithmsResponse, error)

GetADRAlgorithms returns the available ADR algorithms.

func (*NetworkServerAPI) List 

func (a *NetworkServerAPI) List(ctx context.Context, req *pb.ListNetworkServerRequest) (*pb.ListNetworkServerResponse, error)

List lists the available network-servers.

func (*NetworkServerAPI) Update 

func (a *NetworkServerAPI) Update(ctx context.Context, req *pb.UpdateNetworkServerRequest) (*empty.Empty, error)

Update updates the given network-server.

type OrganizationAPI 

type OrganizationAPI struct {
	// contains filtered or unexported fields
}

OrganizationAPI exports the organization related functions.

func NewOrganizationAPI 

func NewOrganizationAPI(validator auth.Validator) *OrganizationAPI

NewOrganizationAPI creates a new OrganizationAPI.

func (*OrganizationAPI) AddUser 

func (a *OrganizationAPI) AddUser(ctx context.Context, req *pb.AddOrganizationUserRequest) (*empty.Empty, error)

AddUser creates the given organization-user link. The user is matched by email, not user id.

func (*OrganizationAPI) Create 

func (a *OrganizationAPI) Create(ctx context.Context, req *pb.CreateOrganizationRequest) (*pb.CreateOrganizationResponse, error)

Create creates the given organization.

func (*OrganizationAPI) Delete 

func (a *OrganizationAPI) Delete(ctx context.Context, req *pb.DeleteOrganizationRequest) (*empty.Empty, error)

Delete deletes the organization matching the given ID.

func (*OrganizationAPI) DeleteUser 

func (a *OrganizationAPI) DeleteUser(ctx context.Context, req *pb.DeleteOrganizationUserRequest) (*empty.Empty, error)

DeleteUser deletes the given user from the organization.

func (*OrganizationAPI) Get 

func (a *OrganizationAPI) Get(ctx context.Context, req *pb.GetOrganizationRequest) (*pb.GetOrganizationResponse, error)

Get returns the organization matching the given ID.

func (*OrganizationAPI) GetUser 

func (a *OrganizationAPI) GetUser(ctx context.Context, req *pb.GetOrganizationUserRequest) (*pb.GetOrganizationUserResponse, error)

GetUser returns the user details for the given user ID.

func (*OrganizationAPI) List 

func (a *OrganizationAPI) List(ctx context.Context, req *pb.ListOrganizationRequest) (*pb.ListOrganizationResponse, error)

List lists the organizations to which the user has access.

func (*OrganizationAPI) ListUsers 

func (a *OrganizationAPI) ListUsers(ctx context.Context, req *pb.ListOrganizationUsersRequest) (*pb.ListOrganizationUsersResponse, error)

ListUsers lists the users assigned to the given organization.

func (*OrganizationAPI) Update 

func (a *OrganizationAPI) Update(ctx context.Context, req *pb.UpdateOrganizationRequest) (*empty.Empty, error)

Update updates the given organization.

func (*OrganizationAPI) UpdateUser 

func (a *OrganizationAPI) UpdateUser(ctx context.Context, req *pb.UpdateOrganizationUserRequest) (*empty.Empty, error)

UpdateUser updates the given user.

type ServiceProfileServiceAPI 

type ServiceProfileServiceAPI struct {
	// contains filtered or unexported fields
}

ServiceProfileServiceAPI export the ServiceProfile related functions.

func NewServiceProfileServiceAPI 

func NewServiceProfileServiceAPI(validator auth.Validator) *ServiceProfileServiceAPI

NewServiceProfileServiceAPI creates a new ServiceProfileServiceAPI.

func (*ServiceProfileServiceAPI) Create 

func (a *ServiceProfileServiceAPI) Create(ctx context.Context, req *pb.CreateServiceProfileRequest) (*pb.CreateServiceProfileResponse, error)

Create creates the given service-profile.

func (*ServiceProfileServiceAPI) Delete 

func (a *ServiceProfileServiceAPI) Delete(ctx context.Context, req *pb.DeleteServiceProfileRequest) (*empty.Empty, error)

Delete deletes the service-profile matching the given id.

func (*ServiceProfileServiceAPI) Get 

func (a *ServiceProfileServiceAPI) Get(ctx context.Context, req *pb.GetServiceProfileRequest) (*pb.GetServiceProfileResponse, error)

Get returns the service-profile matching the given id.

func (*ServiceProfileServiceAPI) List 

func (a *ServiceProfileServiceAPI) List(ctx context.Context, req *pb.ListServiceProfileRequest) (*pb.ListServiceProfileResponse, error)

List lists the available service-profiles.

func (*ServiceProfileServiceAPI) Update 

func (a *ServiceProfileServiceAPI) Update(ctx context.Context, req *pb.UpdateServiceProfileRequest) (*empty.Empty, error)

Update updates the given serviceprofile.

type UserAPI 

type UserAPI struct {
	// contains filtered or unexported fields
}

UserAPI exports the User related functions.

func NewUserAPI 

func NewUserAPI(validator auth.Validator) *UserAPI

NewUserAPI creates a new UserAPI.

func (*UserAPI) Create 

func (a *UserAPI) Create(ctx context.Context, req *pb.CreateUserRequest) (*pb.CreateUserResponse, error)

Create creates the given user.

func (*UserAPI) Delete 

func (a *UserAPI) Delete(ctx context.Context, req *pb.DeleteUserRequest) (*empty.Empty, error)

Delete deletes the user matching the given ID.

func (*UserAPI) Get 

func (a *UserAPI) Get(ctx context.Context, req *pb.GetUserRequest) (*pb.GetUserResponse, error)

Get returns the user matching the given ID.

func (*UserAPI) List 

func (a *UserAPI) List(ctx context.Context, req *pb.ListUserRequest) (*pb.ListUserResponse, error)

List lists the users.

func (*UserAPI) Update 

func (a *UserAPI) Update(ctx context.Context, req *pb.UpdateUserRequest) (*empty.Empty, error)

Update updates the given user.

func (*UserAPI) UpdatePassword 

func (a *UserAPI) UpdatePassword(ctx context.Context, req *pb.UpdateUserPasswordRequest) (*empty.Empty, error)

UpdatePassword updates the password for the user matching the given ID.

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.