// Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.2.0 // - protoc v3.18.1 // source: api/application.proto package api import ( context "context" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" emptypb "google.golang.org/protobuf/types/known/emptypb" ) // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 // ApplicationServiceClient is the client API for ApplicationService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type ApplicationServiceClient interface { // Create creates the given application. Create(ctx context.Context, in *CreateApplicationRequest, opts ...grpc.CallOption) (*CreateApplicationResponse, error) // Get the application for the given ID. Get(ctx context.Context, in *GetApplicationRequest, opts ...grpc.CallOption) (*GetApplicationResponse, error) // Update updates the given application. Update(ctx context.Context, in *UpdateApplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete the application for the given ID. Delete(ctx context.Context, in *DeleteApplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get the list of applications. List(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error) // List all configured integrations. ListIntegrations(ctx context.Context, in *ListIntegrationsRequest, opts ...grpc.CallOption) (*ListIntegrationsResponse, error) // Create HTTP integration. CreateHttpIntegration(ctx context.Context, in *CreateHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get the configured HTTP integration. GetHttpIntegration(ctx context.Context, in *GetHttpIntegrationRequest, opts ...grpc.CallOption) (*GetHttpIntegrationResponse, error) // Update the HTTP integration. UpdateHttpIntegration(ctx context.Context, in *UpdateHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete the HTTP integration. DeleteHttpIntegration(ctx context.Context, in *DeleteHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create InfluxDb integration. CreateInfluxDbIntegration(ctx context.Context, in *CreateInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get InfluxDb integration. GetInfluxDbIntegration(ctx context.Context, in *GetInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*GetInfluxDbIntegrationResponse, error) // Update InfluxDb integration. UpdateInfluxDbIntegration(ctx context.Context, in *UpdateInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete InfluxDb integration. DeleteInfluxDbIntegration(ctx context.Context, in *DeleteInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create ThingsBoard integration. CreateThingsBoardIntegration(ctx context.Context, in *CreateThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get ThingsBoard integration. GetThingsBoardIntegration(ctx context.Context, in *GetThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*GetThingsBoardIntegrationResponse, error) // Update ThingsBoard integration. UpdateThingsBoardIntegration(ctx context.Context, in *UpdateThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete ThingsBoard integration. DeleteThingsBoardIntegration(ctx context.Context, in *DeleteThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create myDevices integration. CreateMyDevicesIntegration(ctx context.Context, in *CreateMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get myDevices integration. GetMyDevicesIntegration(ctx context.Context, in *GetMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*GetMyDevicesIntegrationResponse, error) // Update myDevices integration. UpdateMyDevicesIntegration(ctx context.Context, in *UpdateMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete myDevices integration. DeleteMyDevicesIntegration(ctx context.Context, in *DeleteMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create LoRaCloud integration. CreateLoraCloudIntegration(ctx context.Context, in *CreateLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get LoRaCloud integration. GetLoraCloudIntegration(ctx context.Context, in *GetLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*GetLoraCloudIntegrationResponse, error) // Update LoRaCloud integration. UpdateLoraCloudIntegration(ctx context.Context, in *UpdateLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete LoRaCloud integration. DeleteLoraCloudIntegration(ctx context.Context, in *DeleteLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create GCP Pub/Sub integration. CreateGcpPubSubIntegration(ctx context.Context, in *CreateGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get GCP Pub/Sub integration. GetGcpPubSubIntegration(ctx context.Context, in *GetGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*GetGcpPubSubIntegrationResponse, error) // Update GCP Pub/Sub integration. UpdateGcpPubSubIntegration(ctx context.Context, in *UpdateGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete GCP Pub/Sub integration. DeleteGcpPubSubIntegration(ctx context.Context, in *DeleteGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create AWS SNS integration. CreateAwsSnsIntegration(ctx context.Context, in *CreateAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get AWS SNS integration. GetAwsSnsIntegration(ctx context.Context, in *GetAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*GetAwsSnsIntegrationResponse, error) // Update AWS SNS integration. UpdateAwsSnsIntegration(ctx context.Context, in *UpdateAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete AWS SNS integration. DeleteAwsSnsIntegration(ctx context.Context, in *DeleteAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create Azure Service-Bus integration. CreateAzureServiceBusIntegration(ctx context.Context, in *CreateAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get Azure Service-Bus integration. GetAzureServiceBusIntegration(ctx context.Context, in *GetAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*GetAzureServiceBusIntegrationResponse, error) // Update Azure Service-Bus integration. UpdateAzureServiceBusIntegration(ctx context.Context, in *UpdateAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete Azure Service-Bus integration. DeleteAzureServiceBusIntegration(ctx context.Context, in *DeleteAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Create Pilot Things integration. CreatePilotThingsIntegration(ctx context.Context, in *CreatePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Get Pilot Things integration. GetPilotThingsIntegration(ctx context.Context, in *GetPilotThingsIntegrationRequest, opts ...grpc.CallOption) (*GetPilotThingsIntegrationResponse, error) // Update Pilot Things integration. UpdatePilotThingsIntegration(ctx context.Context, in *UpdatePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Delete Pilot Things integration. DeletePilotThingsIntegration(ctx context.Context, in *DeletePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // Generates application ID specific client-certificate. GenerateMqttIntegrationClientCertificate(ctx context.Context, in *GenerateMqttIntegrationClientCertificateRequest, opts ...grpc.CallOption) (*GenerateMqttIntegrationClientCertificateResponse, error) } type applicationServiceClient struct { cc grpc.ClientConnInterface } func NewApplicationServiceClient(cc grpc.ClientConnInterface) ApplicationServiceClient { return &applicationServiceClient{cc} } func (c *applicationServiceClient) Create(ctx context.Context, in *CreateApplicationRequest, opts ...grpc.CallOption) (*CreateApplicationResponse, error) { out := new(CreateApplicationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/Create", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) Get(ctx context.Context, in *GetApplicationRequest, opts ...grpc.CallOption) (*GetApplicationResponse, error) { out := new(GetApplicationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/Get", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) Update(ctx context.Context, in *UpdateApplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/Update", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) Delete(ctx context.Context, in *DeleteApplicationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/Delete", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) List(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error) { out := new(ListApplicationsResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/List", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) ListIntegrations(ctx context.Context, in *ListIntegrationsRequest, opts ...grpc.CallOption) (*ListIntegrationsResponse, error) { out := new(ListIntegrationsResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/ListIntegrations", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateHttpIntegration(ctx context.Context, in *CreateHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateHttpIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetHttpIntegration(ctx context.Context, in *GetHttpIntegrationRequest, opts ...grpc.CallOption) (*GetHttpIntegrationResponse, error) { out := new(GetHttpIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetHttpIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateHttpIntegration(ctx context.Context, in *UpdateHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateHttpIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteHttpIntegration(ctx context.Context, in *DeleteHttpIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteHttpIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateInfluxDbIntegration(ctx context.Context, in *CreateInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateInfluxDbIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetInfluxDbIntegration(ctx context.Context, in *GetInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*GetInfluxDbIntegrationResponse, error) { out := new(GetInfluxDbIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetInfluxDbIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateInfluxDbIntegration(ctx context.Context, in *UpdateInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateInfluxDbIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteInfluxDbIntegration(ctx context.Context, in *DeleteInfluxDbIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteInfluxDbIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateThingsBoardIntegration(ctx context.Context, in *CreateThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateThingsBoardIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetThingsBoardIntegration(ctx context.Context, in *GetThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*GetThingsBoardIntegrationResponse, error) { out := new(GetThingsBoardIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetThingsBoardIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateThingsBoardIntegration(ctx context.Context, in *UpdateThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateThingsBoardIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteThingsBoardIntegration(ctx context.Context, in *DeleteThingsBoardIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteThingsBoardIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateMyDevicesIntegration(ctx context.Context, in *CreateMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateMyDevicesIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetMyDevicesIntegration(ctx context.Context, in *GetMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*GetMyDevicesIntegrationResponse, error) { out := new(GetMyDevicesIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetMyDevicesIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateMyDevicesIntegration(ctx context.Context, in *UpdateMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateMyDevicesIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteMyDevicesIntegration(ctx context.Context, in *DeleteMyDevicesIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteMyDevicesIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateLoraCloudIntegration(ctx context.Context, in *CreateLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateLoraCloudIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetLoraCloudIntegration(ctx context.Context, in *GetLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*GetLoraCloudIntegrationResponse, error) { out := new(GetLoraCloudIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetLoraCloudIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateLoraCloudIntegration(ctx context.Context, in *UpdateLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateLoraCloudIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteLoraCloudIntegration(ctx context.Context, in *DeleteLoraCloudIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteLoraCloudIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateGcpPubSubIntegration(ctx context.Context, in *CreateGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateGcpPubSubIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetGcpPubSubIntegration(ctx context.Context, in *GetGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*GetGcpPubSubIntegrationResponse, error) { out := new(GetGcpPubSubIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetGcpPubSubIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateGcpPubSubIntegration(ctx context.Context, in *UpdateGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateGcpPubSubIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteGcpPubSubIntegration(ctx context.Context, in *DeleteGcpPubSubIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteGcpPubSubIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateAwsSnsIntegration(ctx context.Context, in *CreateAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateAwsSnsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetAwsSnsIntegration(ctx context.Context, in *GetAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*GetAwsSnsIntegrationResponse, error) { out := new(GetAwsSnsIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetAwsSnsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateAwsSnsIntegration(ctx context.Context, in *UpdateAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateAwsSnsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteAwsSnsIntegration(ctx context.Context, in *DeleteAwsSnsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteAwsSnsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreateAzureServiceBusIntegration(ctx context.Context, in *CreateAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreateAzureServiceBusIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetAzureServiceBusIntegration(ctx context.Context, in *GetAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*GetAzureServiceBusIntegrationResponse, error) { out := new(GetAzureServiceBusIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetAzureServiceBusIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdateAzureServiceBusIntegration(ctx context.Context, in *UpdateAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdateAzureServiceBusIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeleteAzureServiceBusIntegration(ctx context.Context, in *DeleteAzureServiceBusIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeleteAzureServiceBusIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) CreatePilotThingsIntegration(ctx context.Context, in *CreatePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/CreatePilotThingsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GetPilotThingsIntegration(ctx context.Context, in *GetPilotThingsIntegrationRequest, opts ...grpc.CallOption) (*GetPilotThingsIntegrationResponse, error) { out := new(GetPilotThingsIntegrationResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GetPilotThingsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) UpdatePilotThingsIntegration(ctx context.Context, in *UpdatePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/UpdatePilotThingsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) DeletePilotThingsIntegration(ctx context.Context, in *DeletePilotThingsIntegrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { out := new(emptypb.Empty) err := c.cc.Invoke(ctx, "/api.ApplicationService/DeletePilotThingsIntegration", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *applicationServiceClient) GenerateMqttIntegrationClientCertificate(ctx context.Context, in *GenerateMqttIntegrationClientCertificateRequest, opts ...grpc.CallOption) (*GenerateMqttIntegrationClientCertificateResponse, error) { out := new(GenerateMqttIntegrationClientCertificateResponse) err := c.cc.Invoke(ctx, "/api.ApplicationService/GenerateMqttIntegrationClientCertificate", in, out, opts...) if err != nil { return nil, err } return out, nil } // ApplicationServiceServer is the server API for ApplicationService service. // All implementations must embed UnimplementedApplicationServiceServer // for forward compatibility type ApplicationServiceServer interface { // Create creates the given application. Create(context.Context, *CreateApplicationRequest) (*CreateApplicationResponse, error) // Get the application for the given ID. Get(context.Context, *GetApplicationRequest) (*GetApplicationResponse, error) // Update updates the given application. Update(context.Context, *UpdateApplicationRequest) (*emptypb.Empty, error) // Delete the application for the given ID. Delete(context.Context, *DeleteApplicationRequest) (*emptypb.Empty, error) // Get the list of applications. List(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error) // List all configured integrations. ListIntegrations(context.Context, *ListIntegrationsRequest) (*ListIntegrationsResponse, error) // Create HTTP integration. CreateHttpIntegration(context.Context, *CreateHttpIntegrationRequest) (*emptypb.Empty, error) // Get the configured HTTP integration. GetHttpIntegration(context.Context, *GetHttpIntegrationRequest) (*GetHttpIntegrationResponse, error) // Update the HTTP integration. UpdateHttpIntegration(context.Context, *UpdateHttpIntegrationRequest) (*emptypb.Empty, error) // Delete the HTTP integration. DeleteHttpIntegration(context.Context, *DeleteHttpIntegrationRequest) (*emptypb.Empty, error) // Create InfluxDb integration. CreateInfluxDbIntegration(context.Context, *CreateInfluxDbIntegrationRequest) (*emptypb.Empty, error) // Get InfluxDb integration. GetInfluxDbIntegration(context.Context, *GetInfluxDbIntegrationRequest) (*GetInfluxDbIntegrationResponse, error) // Update InfluxDb integration. UpdateInfluxDbIntegration(context.Context, *UpdateInfluxDbIntegrationRequest) (*emptypb.Empty, error) // Delete InfluxDb integration. DeleteInfluxDbIntegration(context.Context, *DeleteInfluxDbIntegrationRequest) (*emptypb.Empty, error) // Create ThingsBoard integration. CreateThingsBoardIntegration(context.Context, *CreateThingsBoardIntegrationRequest) (*emptypb.Empty, error) // Get ThingsBoard integration. GetThingsBoardIntegration(context.Context, *GetThingsBoardIntegrationRequest) (*GetThingsBoardIntegrationResponse, error) // Update ThingsBoard integration. UpdateThingsBoardIntegration(context.Context, *UpdateThingsBoardIntegrationRequest) (*emptypb.Empty, error) // Delete ThingsBoard integration. DeleteThingsBoardIntegration(context.Context, *DeleteThingsBoardIntegrationRequest) (*emptypb.Empty, error) // Create myDevices integration. CreateMyDevicesIntegration(context.Context, *CreateMyDevicesIntegrationRequest) (*emptypb.Empty, error) // Get myDevices integration. GetMyDevicesIntegration(context.Context, *GetMyDevicesIntegrationRequest) (*GetMyDevicesIntegrationResponse, error) // Update myDevices integration. UpdateMyDevicesIntegration(context.Context, *UpdateMyDevicesIntegrationRequest) (*emptypb.Empty, error) // Delete myDevices integration. DeleteMyDevicesIntegration(context.Context, *DeleteMyDevicesIntegrationRequest) (*emptypb.Empty, error) // Create LoRaCloud integration. CreateLoraCloudIntegration(context.Context, *CreateLoraCloudIntegrationRequest) (*emptypb.Empty, error) // Get LoRaCloud integration. GetLoraCloudIntegration(context.Context, *GetLoraCloudIntegrationRequest) (*GetLoraCloudIntegrationResponse, error) // Update LoRaCloud integration. UpdateLoraCloudIntegration(context.Context, *UpdateLoraCloudIntegrationRequest) (*emptypb.Empty, error) // Delete LoRaCloud integration. DeleteLoraCloudIntegration(context.Context, *DeleteLoraCloudIntegrationRequest) (*emptypb.Empty, error) // Create GCP Pub/Sub integration. CreateGcpPubSubIntegration(context.Context, *CreateGcpPubSubIntegrationRequest) (*emptypb.Empty, error) // Get GCP Pub/Sub integration. GetGcpPubSubIntegration(context.Context, *GetGcpPubSubIntegrationRequest) (*GetGcpPubSubIntegrationResponse, error) // Update GCP Pub/Sub integration. UpdateGcpPubSubIntegration(context.Context, *UpdateGcpPubSubIntegrationRequest) (*emptypb.Empty, error) // Delete GCP Pub/Sub integration. DeleteGcpPubSubIntegration(context.Context, *DeleteGcpPubSubIntegrationRequest) (*emptypb.Empty, error) // Create AWS SNS integration. CreateAwsSnsIntegration(context.Context, *CreateAwsSnsIntegrationRequest) (*emptypb.Empty, error) // Get AWS SNS integration. GetAwsSnsIntegration(context.Context, *GetAwsSnsIntegrationRequest) (*GetAwsSnsIntegrationResponse, error) // Update AWS SNS integration. UpdateAwsSnsIntegration(context.Context, *UpdateAwsSnsIntegrationRequest) (*emptypb.Empty, error) // Delete AWS SNS integration. DeleteAwsSnsIntegration(context.Context, *DeleteAwsSnsIntegrationRequest) (*emptypb.Empty, error) // Create Azure Service-Bus integration. CreateAzureServiceBusIntegration(context.Context, *CreateAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) // Get Azure Service-Bus integration. GetAzureServiceBusIntegration(context.Context, *GetAzureServiceBusIntegrationRequest) (*GetAzureServiceBusIntegrationResponse, error) // Update Azure Service-Bus integration. UpdateAzureServiceBusIntegration(context.Context, *UpdateAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) // Delete Azure Service-Bus integration. DeleteAzureServiceBusIntegration(context.Context, *DeleteAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) // Create Pilot Things integration. CreatePilotThingsIntegration(context.Context, *CreatePilotThingsIntegrationRequest) (*emptypb.Empty, error) // Get Pilot Things integration. GetPilotThingsIntegration(context.Context, *GetPilotThingsIntegrationRequest) (*GetPilotThingsIntegrationResponse, error) // Update Pilot Things integration. UpdatePilotThingsIntegration(context.Context, *UpdatePilotThingsIntegrationRequest) (*emptypb.Empty, error) // Delete Pilot Things integration. DeletePilotThingsIntegration(context.Context, *DeletePilotThingsIntegrationRequest) (*emptypb.Empty, error) // Generates application ID specific client-certificate. GenerateMqttIntegrationClientCertificate(context.Context, *GenerateMqttIntegrationClientCertificateRequest) (*GenerateMqttIntegrationClientCertificateResponse, error) mustEmbedUnimplementedApplicationServiceServer() } // UnimplementedApplicationServiceServer must be embedded to have forward compatible implementations. type UnimplementedApplicationServiceServer struct { } func (UnimplementedApplicationServiceServer) Create(context.Context, *CreateApplicationRequest) (*CreateApplicationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Create not implemented") } func (UnimplementedApplicationServiceServer) Get(context.Context, *GetApplicationRequest) (*GetApplicationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method Get not implemented") } func (UnimplementedApplicationServiceServer) Update(context.Context, *UpdateApplicationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method Update not implemented") } func (UnimplementedApplicationServiceServer) Delete(context.Context, *DeleteApplicationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method Delete not implemented") } func (UnimplementedApplicationServiceServer) List(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method List not implemented") } func (UnimplementedApplicationServiceServer) ListIntegrations(context.Context, *ListIntegrationsRequest) (*ListIntegrationsResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method ListIntegrations not implemented") } func (UnimplementedApplicationServiceServer) CreateHttpIntegration(context.Context, *CreateHttpIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateHttpIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetHttpIntegration(context.Context, *GetHttpIntegrationRequest) (*GetHttpIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetHttpIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateHttpIntegration(context.Context, *UpdateHttpIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateHttpIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteHttpIntegration(context.Context, *DeleteHttpIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteHttpIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateInfluxDbIntegration(context.Context, *CreateInfluxDbIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateInfluxDbIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetInfluxDbIntegration(context.Context, *GetInfluxDbIntegrationRequest) (*GetInfluxDbIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetInfluxDbIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateInfluxDbIntegration(context.Context, *UpdateInfluxDbIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateInfluxDbIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteInfluxDbIntegration(context.Context, *DeleteInfluxDbIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteInfluxDbIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateThingsBoardIntegration(context.Context, *CreateThingsBoardIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateThingsBoardIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetThingsBoardIntegration(context.Context, *GetThingsBoardIntegrationRequest) (*GetThingsBoardIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetThingsBoardIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateThingsBoardIntegration(context.Context, *UpdateThingsBoardIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateThingsBoardIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteThingsBoardIntegration(context.Context, *DeleteThingsBoardIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteThingsBoardIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateMyDevicesIntegration(context.Context, *CreateMyDevicesIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateMyDevicesIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetMyDevicesIntegration(context.Context, *GetMyDevicesIntegrationRequest) (*GetMyDevicesIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetMyDevicesIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateMyDevicesIntegration(context.Context, *UpdateMyDevicesIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateMyDevicesIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteMyDevicesIntegration(context.Context, *DeleteMyDevicesIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteMyDevicesIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateLoraCloudIntegration(context.Context, *CreateLoraCloudIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateLoraCloudIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetLoraCloudIntegration(context.Context, *GetLoraCloudIntegrationRequest) (*GetLoraCloudIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetLoraCloudIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateLoraCloudIntegration(context.Context, *UpdateLoraCloudIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateLoraCloudIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteLoraCloudIntegration(context.Context, *DeleteLoraCloudIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteLoraCloudIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateGcpPubSubIntegration(context.Context, *CreateGcpPubSubIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateGcpPubSubIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetGcpPubSubIntegration(context.Context, *GetGcpPubSubIntegrationRequest) (*GetGcpPubSubIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetGcpPubSubIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateGcpPubSubIntegration(context.Context, *UpdateGcpPubSubIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateGcpPubSubIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteGcpPubSubIntegration(context.Context, *DeleteGcpPubSubIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteGcpPubSubIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateAwsSnsIntegration(context.Context, *CreateAwsSnsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAwsSnsIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetAwsSnsIntegration(context.Context, *GetAwsSnsIntegrationRequest) (*GetAwsSnsIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAwsSnsIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateAwsSnsIntegration(context.Context, *UpdateAwsSnsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateAwsSnsIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteAwsSnsIntegration(context.Context, *DeleteAwsSnsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteAwsSnsIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreateAzureServiceBusIntegration(context.Context, *CreateAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateAzureServiceBusIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetAzureServiceBusIntegration(context.Context, *GetAzureServiceBusIntegrationRequest) (*GetAzureServiceBusIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetAzureServiceBusIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdateAzureServiceBusIntegration(context.Context, *UpdateAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateAzureServiceBusIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeleteAzureServiceBusIntegration(context.Context, *DeleteAzureServiceBusIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteAzureServiceBusIntegration not implemented") } func (UnimplementedApplicationServiceServer) CreatePilotThingsIntegration(context.Context, *CreatePilotThingsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method CreatePilotThingsIntegration not implemented") } func (UnimplementedApplicationServiceServer) GetPilotThingsIntegration(context.Context, *GetPilotThingsIntegrationRequest) (*GetPilotThingsIntegrationResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetPilotThingsIntegration not implemented") } func (UnimplementedApplicationServiceServer) UpdatePilotThingsIntegration(context.Context, *UpdatePilotThingsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdatePilotThingsIntegration not implemented") } func (UnimplementedApplicationServiceServer) DeletePilotThingsIntegration(context.Context, *DeletePilotThingsIntegrationRequest) (*emptypb.Empty, error) { return nil, status.Errorf(codes.Unimplemented, "method DeletePilotThingsIntegration not implemented") } func (UnimplementedApplicationServiceServer) GenerateMqttIntegrationClientCertificate(context.Context, *GenerateMqttIntegrationClientCertificateRequest) (*GenerateMqttIntegrationClientCertificateResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GenerateMqttIntegrationClientCertificate not implemented") } func (UnimplementedApplicationServiceServer) mustEmbedUnimplementedApplicationServiceServer() {} // UnsafeApplicationServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ApplicationServiceServer will // result in compilation errors. type UnsafeApplicationServiceServer interface { mustEmbedUnimplementedApplicationServiceServer() } func RegisterApplicationServiceServer(s grpc.ServiceRegistrar, srv ApplicationServiceServer) { s.RegisterService(&ApplicationService_ServiceDesc, srv) } func _ApplicationService_Create_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateApplicationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).Create(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/Create", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).Create(ctx, req.(*CreateApplicationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_Get_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetApplicationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).Get(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/Get", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).Get(ctx, req.(*GetApplicationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_Update_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateApplicationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).Update(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/Update", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).Update(ctx, req.(*UpdateApplicationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_Delete_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteApplicationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).Delete(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/Delete", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).Delete(ctx, req.(*DeleteApplicationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListApplicationsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).List(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/List", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).List(ctx, req.(*ListApplicationsRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_ListIntegrations_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ListIntegrationsRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).ListIntegrations(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/ListIntegrations", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).ListIntegrations(ctx, req.(*ListIntegrationsRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateHttpIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateHttpIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateHttpIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateHttpIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateHttpIntegration(ctx, req.(*CreateHttpIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetHttpIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetHttpIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetHttpIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetHttpIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetHttpIntegration(ctx, req.(*GetHttpIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateHttpIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateHttpIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateHttpIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateHttpIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateHttpIntegration(ctx, req.(*UpdateHttpIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteHttpIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteHttpIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteHttpIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteHttpIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteHttpIntegration(ctx, req.(*DeleteHttpIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateInfluxDbIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateInfluxDbIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateInfluxDbIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateInfluxDbIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateInfluxDbIntegration(ctx, req.(*CreateInfluxDbIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetInfluxDbIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetInfluxDbIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetInfluxDbIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetInfluxDbIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetInfluxDbIntegration(ctx, req.(*GetInfluxDbIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateInfluxDbIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateInfluxDbIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateInfluxDbIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateInfluxDbIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateInfluxDbIntegration(ctx, req.(*UpdateInfluxDbIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteInfluxDbIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteInfluxDbIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteInfluxDbIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteInfluxDbIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteInfluxDbIntegration(ctx, req.(*DeleteInfluxDbIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateThingsBoardIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateThingsBoardIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateThingsBoardIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateThingsBoardIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateThingsBoardIntegration(ctx, req.(*CreateThingsBoardIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetThingsBoardIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetThingsBoardIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetThingsBoardIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetThingsBoardIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetThingsBoardIntegration(ctx, req.(*GetThingsBoardIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateThingsBoardIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateThingsBoardIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateThingsBoardIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateThingsBoardIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateThingsBoardIntegration(ctx, req.(*UpdateThingsBoardIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteThingsBoardIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteThingsBoardIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteThingsBoardIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteThingsBoardIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteThingsBoardIntegration(ctx, req.(*DeleteThingsBoardIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateMyDevicesIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateMyDevicesIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateMyDevicesIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateMyDevicesIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateMyDevicesIntegration(ctx, req.(*CreateMyDevicesIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetMyDevicesIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetMyDevicesIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetMyDevicesIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetMyDevicesIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetMyDevicesIntegration(ctx, req.(*GetMyDevicesIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateMyDevicesIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateMyDevicesIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateMyDevicesIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateMyDevicesIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateMyDevicesIntegration(ctx, req.(*UpdateMyDevicesIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteMyDevicesIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteMyDevicesIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteMyDevicesIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteMyDevicesIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteMyDevicesIntegration(ctx, req.(*DeleteMyDevicesIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateLoraCloudIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateLoraCloudIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateLoraCloudIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateLoraCloudIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateLoraCloudIntegration(ctx, req.(*CreateLoraCloudIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetLoraCloudIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetLoraCloudIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetLoraCloudIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetLoraCloudIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetLoraCloudIntegration(ctx, req.(*GetLoraCloudIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateLoraCloudIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateLoraCloudIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateLoraCloudIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateLoraCloudIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateLoraCloudIntegration(ctx, req.(*UpdateLoraCloudIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteLoraCloudIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteLoraCloudIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteLoraCloudIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteLoraCloudIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteLoraCloudIntegration(ctx, req.(*DeleteLoraCloudIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateGcpPubSubIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateGcpPubSubIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateGcpPubSubIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateGcpPubSubIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateGcpPubSubIntegration(ctx, req.(*CreateGcpPubSubIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetGcpPubSubIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetGcpPubSubIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetGcpPubSubIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetGcpPubSubIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetGcpPubSubIntegration(ctx, req.(*GetGcpPubSubIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateGcpPubSubIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateGcpPubSubIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateGcpPubSubIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateGcpPubSubIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateGcpPubSubIntegration(ctx, req.(*UpdateGcpPubSubIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteGcpPubSubIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteGcpPubSubIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteGcpPubSubIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteGcpPubSubIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteGcpPubSubIntegration(ctx, req.(*DeleteGcpPubSubIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateAwsSnsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateAwsSnsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateAwsSnsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateAwsSnsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateAwsSnsIntegration(ctx, req.(*CreateAwsSnsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetAwsSnsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAwsSnsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetAwsSnsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetAwsSnsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetAwsSnsIntegration(ctx, req.(*GetAwsSnsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateAwsSnsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateAwsSnsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateAwsSnsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateAwsSnsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateAwsSnsIntegration(ctx, req.(*UpdateAwsSnsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteAwsSnsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteAwsSnsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteAwsSnsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteAwsSnsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteAwsSnsIntegration(ctx, req.(*DeleteAwsSnsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreateAzureServiceBusIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreateAzureServiceBusIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreateAzureServiceBusIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreateAzureServiceBusIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreateAzureServiceBusIntegration(ctx, req.(*CreateAzureServiceBusIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetAzureServiceBusIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetAzureServiceBusIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetAzureServiceBusIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetAzureServiceBusIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetAzureServiceBusIntegration(ctx, req.(*GetAzureServiceBusIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdateAzureServiceBusIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateAzureServiceBusIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdateAzureServiceBusIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdateAzureServiceBusIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdateAzureServiceBusIntegration(ctx, req.(*UpdateAzureServiceBusIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeleteAzureServiceBusIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteAzureServiceBusIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeleteAzureServiceBusIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeleteAzureServiceBusIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeleteAzureServiceBusIntegration(ctx, req.(*DeleteAzureServiceBusIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_CreatePilotThingsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(CreatePilotThingsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).CreatePilotThingsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/CreatePilotThingsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).CreatePilotThingsIntegration(ctx, req.(*CreatePilotThingsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GetPilotThingsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetPilotThingsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GetPilotThingsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GetPilotThingsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GetPilotThingsIntegration(ctx, req.(*GetPilotThingsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_UpdatePilotThingsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdatePilotThingsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).UpdatePilotThingsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/UpdatePilotThingsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).UpdatePilotThingsIntegration(ctx, req.(*UpdatePilotThingsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_DeletePilotThingsIntegration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeletePilotThingsIntegrationRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).DeletePilotThingsIntegration(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/DeletePilotThingsIntegration", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).DeletePilotThingsIntegration(ctx, req.(*DeletePilotThingsIntegrationRequest)) } return interceptor(ctx, in, info, handler) } func _ApplicationService_GenerateMqttIntegrationClientCertificate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GenerateMqttIntegrationClientCertificateRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(ApplicationServiceServer).GenerateMqttIntegrationClientCertificate(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/api.ApplicationService/GenerateMqttIntegrationClientCertificate", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ApplicationServiceServer).GenerateMqttIntegrationClientCertificate(ctx, req.(*GenerateMqttIntegrationClientCertificateRequest)) } return interceptor(ctx, in, info, handler) } // ApplicationService_ServiceDesc is the grpc.ServiceDesc for ApplicationService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) var ApplicationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "api.ApplicationService", HandlerType: (*ApplicationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _ApplicationService_Create_Handler, }, { MethodName: "Get", Handler: _ApplicationService_Get_Handler, }, { MethodName: "Update", Handler: _ApplicationService_Update_Handler, }, { MethodName: "Delete", Handler: _ApplicationService_Delete_Handler, }, { MethodName: "List", Handler: _ApplicationService_List_Handler, }, { MethodName: "ListIntegrations", Handler: _ApplicationService_ListIntegrations_Handler, }, { MethodName: "CreateHttpIntegration", Handler: _ApplicationService_CreateHttpIntegration_Handler, }, { MethodName: "GetHttpIntegration", Handler: _ApplicationService_GetHttpIntegration_Handler, }, { MethodName: "UpdateHttpIntegration", Handler: _ApplicationService_UpdateHttpIntegration_Handler, }, { MethodName: "DeleteHttpIntegration", Handler: _ApplicationService_DeleteHttpIntegration_Handler, }, { MethodName: "CreateInfluxDbIntegration", Handler: _ApplicationService_CreateInfluxDbIntegration_Handler, }, { MethodName: "GetInfluxDbIntegration", Handler: _ApplicationService_GetInfluxDbIntegration_Handler, }, { MethodName: "UpdateInfluxDbIntegration", Handler: _ApplicationService_UpdateInfluxDbIntegration_Handler, }, { MethodName: "DeleteInfluxDbIntegration", Handler: _ApplicationService_DeleteInfluxDbIntegration_Handler, }, { MethodName: "CreateThingsBoardIntegration", Handler: _ApplicationService_CreateThingsBoardIntegration_Handler, }, { MethodName: "GetThingsBoardIntegration", Handler: _ApplicationService_GetThingsBoardIntegration_Handler, }, { MethodName: "UpdateThingsBoardIntegration", Handler: _ApplicationService_UpdateThingsBoardIntegration_Handler, }, { MethodName: "DeleteThingsBoardIntegration", Handler: _ApplicationService_DeleteThingsBoardIntegration_Handler, }, { MethodName: "CreateMyDevicesIntegration", Handler: _ApplicationService_CreateMyDevicesIntegration_Handler, }, { MethodName: "GetMyDevicesIntegration", Handler: _ApplicationService_GetMyDevicesIntegration_Handler, }, { MethodName: "UpdateMyDevicesIntegration", Handler: _ApplicationService_UpdateMyDevicesIntegration_Handler, }, { MethodName: "DeleteMyDevicesIntegration", Handler: _ApplicationService_DeleteMyDevicesIntegration_Handler, }, { MethodName: "CreateLoraCloudIntegration", Handler: _ApplicationService_CreateLoraCloudIntegration_Handler, }, { MethodName: "GetLoraCloudIntegration", Handler: _ApplicationService_GetLoraCloudIntegration_Handler, }, { MethodName: "UpdateLoraCloudIntegration", Handler: _ApplicationService_UpdateLoraCloudIntegration_Handler, }, { MethodName: "DeleteLoraCloudIntegration", Handler: _ApplicationService_DeleteLoraCloudIntegration_Handler, }, { MethodName: "CreateGcpPubSubIntegration", Handler: _ApplicationService_CreateGcpPubSubIntegration_Handler, }, { MethodName: "GetGcpPubSubIntegration", Handler: _ApplicationService_GetGcpPubSubIntegration_Handler, }, { MethodName: "UpdateGcpPubSubIntegration", Handler: _ApplicationService_UpdateGcpPubSubIntegration_Handler, }, { MethodName: "DeleteGcpPubSubIntegration", Handler: _ApplicationService_DeleteGcpPubSubIntegration_Handler, }, { MethodName: "CreateAwsSnsIntegration", Handler: _ApplicationService_CreateAwsSnsIntegration_Handler, }, { MethodName: "GetAwsSnsIntegration", Handler: _ApplicationService_GetAwsSnsIntegration_Handler, }, { MethodName: "UpdateAwsSnsIntegration", Handler: _ApplicationService_UpdateAwsSnsIntegration_Handler, }, { MethodName: "DeleteAwsSnsIntegration", Handler: _ApplicationService_DeleteAwsSnsIntegration_Handler, }, { MethodName: "CreateAzureServiceBusIntegration", Handler: _ApplicationService_CreateAzureServiceBusIntegration_Handler, }, { MethodName: "GetAzureServiceBusIntegration", Handler: _ApplicationService_GetAzureServiceBusIntegration_Handler, }, { MethodName: "UpdateAzureServiceBusIntegration", Handler: _ApplicationService_UpdateAzureServiceBusIntegration_Handler, }, { MethodName: "DeleteAzureServiceBusIntegration", Handler: _ApplicationService_DeleteAzureServiceBusIntegration_Handler, }, { MethodName: "CreatePilotThingsIntegration", Handler: _ApplicationService_CreatePilotThingsIntegration_Handler, }, { MethodName: "GetPilotThingsIntegration", Handler: _ApplicationService_GetPilotThingsIntegration_Handler, }, { MethodName: "UpdatePilotThingsIntegration", Handler: _ApplicationService_UpdatePilotThingsIntegration_Handler, }, { MethodName: "DeletePilotThingsIntegration", Handler: _ApplicationService_DeletePilotThingsIntegration_Handler, }, { MethodName: "GenerateMqttIntegrationClientCertificate", Handler: _ApplicationService_GenerateMqttIntegrationClientCertificate_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "api/application.proto", }