Versions in this module Expand all Collapse all v4 v4.0.1 Mar 30, 2025 Changes in this version + type AuthClient struct + func NewAuthClient(t interface{ ... }) *AuthClient + func (_m *AuthClient) AddKey(ctx context.Context, req requests.AddKeyDataRequest) (common.BaseResponse, errors.EdgeX) + func (_m *AuthClient) VerificationKeyByIssuer(ctx context.Context, issuer string) (responses.KeyDataResponse, errors.EdgeX) + type AuthenticationInjector struct + func NewAuthenticationInjector(t interface{ ... }) *AuthenticationInjector + func (_m *AuthenticationInjector) AddAuthenticationData(_a0 *http.Request) error + func (_m *AuthenticationInjector) RoundTripper() http.RoundTripper + type CommandClient struct + func NewCommandClient(t interface{ ... }) *CommandClient + func (_m *CommandClient) AllDeviceCoreCommands(ctx context.Context, offset int, limit int) (responses.MultiDeviceCoreCommandsResponse, errors.EdgeX) + func (_m *CommandClient) DeviceCoreCommandsByDeviceName(ctx context.Context, deviceName string) (responses.DeviceCoreCommandResponse, errors.EdgeX) + func (_m *CommandClient) IssueGetCommandByName(ctx context.Context, deviceName string, commandName string, dsPushEvent bool, ...) (*responses.EventResponse, errors.EdgeX) + func (_m *CommandClient) IssueGetCommandByNameWithQueryParams(ctx context.Context, deviceName string, commandName string, ...) (*responses.EventResponse, errors.EdgeX) + func (_m *CommandClient) IssueSetCommandByName(ctx context.Context, deviceName string, commandName string, ...) (common.BaseResponse, errors.EdgeX) + type CommonClient struct + func NewCommonClient(t mockConstructorTestingTNewCommonClient) *CommonClient + func (_m *CommonClient) AddSecret(ctx context.Context, request common.SecretRequest) (common.BaseResponse, errors.EdgeX) + func (_m *CommonClient) Configuration(ctx context.Context) (common.ConfigResponse, errors.EdgeX) + func (_m *CommonClient) Ping(ctx context.Context) (common.PingResponse, errors.EdgeX) + func (_m *CommonClient) Version(ctx context.Context) (common.VersionResponse, errors.EdgeX) + type DeviceClient struct + func NewDeviceClient(t interface{ ... }) *DeviceClient + func (_m *DeviceClient) Add(ctx context.Context, reqs []requests.AddDeviceRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *DeviceClient) AddWithQueryParams(ctx context.Context, reqs []requests.AddDeviceRequest, ...) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *DeviceClient) AllDevices(ctx context.Context, labels []string, offset int, limit int) (responses.MultiDevicesResponse, errors.EdgeX) + func (_m *DeviceClient) AllDevicesWithChildren(ctx context.Context, parent string, maxLevels uint, labels []string, ...) (responses.MultiDevicesResponse, errors.EdgeX) + func (_m *DeviceClient) DeleteDeviceByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceClient) DeviceByName(ctx context.Context, name string) (responses.DeviceResponse, errors.EdgeX) + func (_m *DeviceClient) DeviceNameExists(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceClient) DevicesByProfileName(ctx context.Context, name string, offset int, limit int) (responses.MultiDevicesResponse, errors.EdgeX) + func (_m *DeviceClient) DevicesByServiceName(ctx context.Context, name string, offset int, limit int) (responses.MultiDevicesResponse, errors.EdgeX) + func (_m *DeviceClient) Update(ctx context.Context, reqs []requests.UpdateDeviceRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceClient) UpdateWithQueryParams(ctx context.Context, reqs []requests.UpdateDeviceRequest, ...) ([]common.BaseResponse, errors.EdgeX) + type DeviceProfileClient struct + func NewDeviceProfileClient(t interface{ ... }) *DeviceProfileClient + func (_m *DeviceProfileClient) Add(ctx context.Context, reqs []requests.DeviceProfileRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *DeviceProfileClient) AddByYaml(ctx context.Context, yamlFilePath string) (common.BaseWithIdResponse, errors.EdgeX) + func (_m *DeviceProfileClient) AddDeviceProfileDeviceCommand(ctx context.Context, reqs []requests.AddDeviceCommandRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) AddDeviceProfileResource(ctx context.Context, reqs []requests.AddDeviceResourceRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) AllDeviceProfileBasicInfos(ctx context.Context, labels []string, offset int, limit int) (responses.MultiDeviceProfileBasicInfoResponse, errors.EdgeX) + func (_m *DeviceProfileClient) AllDeviceProfiles(ctx context.Context, labels []string, offset int, limit int) (responses.MultiDeviceProfilesResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeleteByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeleteDeviceCommandByName(ctx context.Context, profileName string, commandName string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeleteDeviceResourceByName(ctx context.Context, profileName string, resourceName string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeviceProfileByName(ctx context.Context, name string) (responses.DeviceProfileResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeviceProfilesByManufacturer(ctx context.Context, manufacturer string, offset int, limit int) (responses.MultiDeviceProfilesResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeviceProfilesByManufacturerAndModel(ctx context.Context, manufacturer string, model string, offset int, limit int) (responses.MultiDeviceProfilesResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeviceProfilesByModel(ctx context.Context, model string, offset int, limit int) (responses.MultiDeviceProfilesResponse, errors.EdgeX) + func (_m *DeviceProfileClient) DeviceResourceByProfileNameAndResourceName(ctx context.Context, profileName string, resourceName string) (responses.DeviceResourceResponse, errors.EdgeX) + func (_m *DeviceProfileClient) Update(ctx context.Context, reqs []requests.DeviceProfileRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) UpdateByYaml(ctx context.Context, yamlFilePath string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) UpdateDeviceProfileBasicInfo(ctx context.Context, reqs []requests.DeviceProfileBasicInfoRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) UpdateDeviceProfileDeviceCommand(ctx context.Context, reqs []requests.UpdateDeviceCommandRequest) ([]common.BaseResponse, errors.EdgeX) + func (_m *DeviceProfileClient) UpdateDeviceProfileResource(ctx context.Context, reqs []requests.UpdateDeviceResourceRequest) ([]common.BaseResponse, errors.EdgeX) + type DeviceServiceClient struct + func NewDeviceServiceClient(t mockConstructorTestingTNewDeviceServiceClient) *DeviceServiceClient + func (_m *DeviceServiceClient) Add(ctx context.Context, reqs []requests.AddDeviceServiceRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *DeviceServiceClient) AllDeviceServices(ctx context.Context, labels []string, offset int, limit int) (responses.MultiDeviceServicesResponse, errors.EdgeX) + func (_m *DeviceServiceClient) DeleteByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceClient) DeviceServiceByName(ctx context.Context, name string) (responses.DeviceServiceResponse, errors.EdgeX) + func (_m *DeviceServiceClient) Update(ctx context.Context, reqs []requests.UpdateDeviceServiceRequest) ([]common.BaseResponse, errors.EdgeX) + type DeviceServiceCommandClient struct + func NewDeviceServiceCommandClient(t interface{ ... }) *DeviceServiceCommandClient + func (_m *DeviceServiceCommandClient) Discovery(ctx context.Context, baseUrl string) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) GetCommand(ctx context.Context, baseUrl string, deviceName string, commandName string, ...) (*responses.EventResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) ProfileScan(ctx context.Context, baseUrl string, req requests.ProfileScanRequest) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) SetCommand(ctx context.Context, baseUrl string, deviceName string, commandName string, ...) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) SetCommandWithObject(ctx context.Context, baseUrl string, deviceName string, commandName string, ...) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) StopDeviceDiscovery(ctx context.Context, baseUrl string, requestId string, ...) (common.BaseResponse, errors.EdgeX) + func (_m *DeviceServiceCommandClient) StopProfileScan(ctx context.Context, baseUrl string, deviceName string, ...) (common.BaseResponse, errors.EdgeX) + type EventClient struct + func NewEventClient(t interface{ ... }) *EventClient + func (_m *EventClient) Add(ctx context.Context, serviceName string, req requests.AddEventRequest) (common.BaseWithIdResponse, errors.EdgeX) + func (_m *EventClient) AllEvents(ctx context.Context, offset int, limit int) (responses.MultiEventsResponse, errors.EdgeX) + func (_m *EventClient) DeleteByAge(ctx context.Context, age int) (common.BaseResponse, errors.EdgeX) + func (_m *EventClient) DeleteByDeviceName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *EventClient) DeleteById(ctx context.Context, id string) (common.BaseResponse, errors.EdgeX) + func (_m *EventClient) EventCount(ctx context.Context) (common.CountResponse, errors.EdgeX) + func (_m *EventClient) EventCountByDeviceName(ctx context.Context, name string) (common.CountResponse, errors.EdgeX) + func (_m *EventClient) EventsByDeviceName(ctx context.Context, name string, offset int, limit int) (responses.MultiEventsResponse, errors.EdgeX) + func (_m *EventClient) EventsByTimeRange(ctx context.Context, start int64, end int64, offset int, limit int) (responses.MultiEventsResponse, errors.EdgeX) + type GeneralClient struct + func NewGeneralClient(t mockConstructorTestingTNewGeneralClient) *GeneralClient + func (_m *GeneralClient) FetchConfiguration(ctx context.Context) (common.ConfigResponse, errors.EdgeX) + type KVSClient struct + func NewKVSClient(t interface{ ... }) *KVSClient + func (_m *KVSClient) DeleteKey(ctx context.Context, key string) (responses.KeysResponse, errors.EdgeX) + func (_m *KVSClient) DeleteKeysByPrefix(ctx context.Context, key string) (responses.KeysResponse, errors.EdgeX) + func (_m *KVSClient) ListKeys(ctx context.Context, key string) (responses.KeysResponse, errors.EdgeX) + func (_m *KVSClient) UpdateValuesByKey(ctx context.Context, key string, flatten bool, reqs requests.UpdateKeysRequest) (responses.KeysResponse, errors.EdgeX) + func (_m *KVSClient) ValuesByKey(ctx context.Context, key string) (responses.MultiKeyValueResponse, errors.EdgeX) + type NotificationClient struct + func NewNotificationClient(t interface{ ... }) *NotificationClient + func (_m *NotificationClient) CleanupNotifications(ctx context.Context) (common.BaseResponse, errors.EdgeX) + func (_m *NotificationClient) CleanupNotificationsByAge(ctx context.Context, age int) (common.BaseResponse, errors.EdgeX) + func (_m *NotificationClient) DeleteNotificationById(ctx context.Context, id string) (common.BaseResponse, errors.EdgeX) + func (_m *NotificationClient) DeleteNotificationByIds(ctx context.Context, ids []string) (common.BaseResponse, errors.EdgeX) + func (_m *NotificationClient) DeleteProcessedNotificationsByAge(ctx context.Context, age int) (common.BaseResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationById(ctx context.Context, id string) (responses.NotificationResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsByCategory(ctx context.Context, category string, offset int, limit int, ack string) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsByLabel(ctx context.Context, label string, offset int, limit int, ack string) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsByQueryConditions(ctx context.Context, offset int, limit int, ack string, ...) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsByStatus(ctx context.Context, status string, offset int, limit int, ack string) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsBySubscriptionName(ctx context.Context, subscriptionName string, offset int, limit int, ...) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) NotificationsByTimeRange(ctx context.Context, start int64, end int64, offset int, limit int, ack string) (responses.MultiNotificationsResponse, errors.EdgeX) + func (_m *NotificationClient) SendNotification(ctx context.Context, reqs []requests.AddNotificationRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *NotificationClient) UpdateNotificationAckStatusByIds(ctx context.Context, ack bool, ids []string) (common.BaseResponse, errors.EdgeX) + type ProvisionWatcherClient struct + func NewProvisionWatcherClient(t mockConstructorTestingTNewProvisionWatcherClient) *ProvisionWatcherClient + func (_m *ProvisionWatcherClient) Add(ctx context.Context, reqs []requests.AddProvisionWatcherRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) AllProvisionWatchers(ctx context.Context, labels []string, offset int, limit int) (responses.MultiProvisionWatchersResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) DeleteProvisionWatcherByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) ProvisionWatcherByName(ctx context.Context, name string) (responses.ProvisionWatcherResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) ProvisionWatchersByProfileName(ctx context.Context, name string, offset int, limit int) (responses.MultiProvisionWatchersResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) ProvisionWatchersByServiceName(ctx context.Context, name string, offset int, limit int) (responses.MultiProvisionWatchersResponse, errors.EdgeX) + func (_m *ProvisionWatcherClient) Update(ctx context.Context, reqs []requests.UpdateProvisionWatcherRequest) ([]common.BaseResponse, errors.EdgeX) + type ReadingClient struct + func NewReadingClient(t interface{ ... }) *ReadingClient + func (_m *ReadingClient) AllReadings(ctx context.Context, offset int, limit int) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingCount(ctx context.Context) (common.CountResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingCountByDeviceName(ctx context.Context, name string) (common.CountResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByDeviceName(ctx context.Context, name string, offset int, limit int) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByDeviceNameAndResourceName(ctx context.Context, deviceName string, resourceName string, offset int, ...) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByDeviceNameAndResourceNameAndTimeRange(ctx context.Context, deviceName string, resourceName string, start int64, ...) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByDeviceNameAndResourceNamesAndTimeRange(ctx context.Context, deviceName string, resourceNames []string, start int64, ...) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByResourceName(ctx context.Context, name string, offset int, limit int) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByResourceNameAndTimeRange(ctx context.Context, name string, start int64, end int64, offset int, ...) (responses.MultiReadingsResponse, errors.EdgeX) + func (_m *ReadingClient) ReadingsByTimeRange(ctx context.Context, start int64, end int64, offset int, limit int) (responses.MultiReadingsResponse, errors.EdgeX) + type ScheduleActionRecordClient struct + func NewScheduleActionRecordClient(t interface{ ... }) *ScheduleActionRecordClient + func (_m *ScheduleActionRecordClient) AllScheduleActionRecords(ctx context.Context, start int64, end int64, offset int, limit int) (responses.MultiScheduleActionRecordsResponse, errors.EdgeX) + func (_m *ScheduleActionRecordClient) LatestScheduleActionRecordsByJobName(ctx context.Context, jobName string) (responses.MultiScheduleActionRecordsResponse, errors.EdgeX) + func (_m *ScheduleActionRecordClient) ScheduleActionRecordsByJobName(ctx context.Context, jobName string, start int64, end int64, offset int, ...) (responses.MultiScheduleActionRecordsResponse, errors.EdgeX) + func (_m *ScheduleActionRecordClient) ScheduleActionRecordsByJobNameAndStatus(ctx context.Context, jobName string, status string, start int64, end int64, ...) (responses.MultiScheduleActionRecordsResponse, errors.EdgeX) + func (_m *ScheduleActionRecordClient) ScheduleActionRecordsByStatus(ctx context.Context, status string, start int64, end int64, offset int, ...) (responses.MultiScheduleActionRecordsResponse, errors.EdgeX) + type ScheduleJobClient struct + func NewScheduleJobClient(t interface{ ... }) *ScheduleJobClient + func (_m *ScheduleJobClient) Add(ctx context.Context, reqs []requests.AddScheduleJobRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *ScheduleJobClient) AllScheduleJobs(ctx context.Context, labels []string, offset int, limit int) (responses.MultiScheduleJobsResponse, errors.EdgeX) + func (_m *ScheduleJobClient) DeleteScheduleJobByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *ScheduleJobClient) ScheduleJobByName(ctx context.Context, name string) (responses.ScheduleJobResponse, errors.EdgeX) + func (_m *ScheduleJobClient) TriggerScheduleJobByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *ScheduleJobClient) Update(ctx context.Context, reqs []requests.UpdateScheduleJobRequest) ([]common.BaseResponse, errors.EdgeX) + type SecretStoreTokenClient struct + func NewSecretStoreTokenClient(t interface{ ... }) *SecretStoreTokenClient + func (_m *SecretStoreTokenClient) RegenToken(ctx context.Context, entityId string) (common.BaseResponse, errors.EdgeX) + type SubscriptionClient struct + func NewSubscriptionClient(t mockConstructorTestingTNewSubscriptionClient) *SubscriptionClient + func (_m *SubscriptionClient) Add(ctx context.Context, reqs []requests.AddSubscriptionRequest) ([]common.BaseWithIdResponse, errors.EdgeX) + func (_m *SubscriptionClient) AllSubscriptions(ctx context.Context, offset int, limit int) (responses.MultiSubscriptionsResponse, errors.EdgeX) + func (_m *SubscriptionClient) DeleteSubscriptionByName(ctx context.Context, name string) (common.BaseResponse, errors.EdgeX) + func (_m *SubscriptionClient) SubscriptionByName(ctx context.Context, name string) (responses.SubscriptionResponse, errors.EdgeX) + func (_m *SubscriptionClient) SubscriptionsByCategory(ctx context.Context, category string, offset int, limit int) (responses.MultiSubscriptionsResponse, errors.EdgeX) + func (_m *SubscriptionClient) SubscriptionsByLabel(ctx context.Context, label string, offset int, limit int) (responses.MultiSubscriptionsResponse, errors.EdgeX) + func (_m *SubscriptionClient) SubscriptionsByReceiver(ctx context.Context, receiver string, offset int, limit int) (responses.MultiSubscriptionsResponse, errors.EdgeX) + func (_m *SubscriptionClient) Update(ctx context.Context, reqs []requests.UpdateSubscriptionRequest) ([]common.BaseResponse, errors.EdgeX) + type TransmissionClient struct + func NewTransmissionClient(t interface{ ... }) *TransmissionClient + func (_m *TransmissionClient) AllTransmissions(ctx context.Context, offset int, limit int) (responses.MultiTransmissionsResponse, errors.EdgeX) + func (_m *TransmissionClient) DeleteProcessedTransmissionsByAge(ctx context.Context, age int) (common.BaseResponse, errors.EdgeX) + func (_m *TransmissionClient) TransmissionById(ctx context.Context, id string) (responses.TransmissionResponse, errors.EdgeX) + func (_m *TransmissionClient) TransmissionsByNotificationId(ctx context.Context, id string, offset int, limit int) (responses.MultiTransmissionsResponse, errors.EdgeX) + func (_m *TransmissionClient) TransmissionsByStatus(ctx context.Context, status string, offset int, limit int) (responses.MultiTransmissionsResponse, errors.EdgeX) + func (_m *TransmissionClient) TransmissionsBySubscriptionName(ctx context.Context, subscriptionName string, offset int, limit int) (responses.MultiTransmissionsResponse, errors.EdgeX) + func (_m *TransmissionClient) TransmissionsByTimeRange(ctx context.Context, start int64, end int64, offset int, limit int) (responses.MultiTransmissionsResponse, errors.EdgeX) Other modules containing this package github.com/agile-edge/go-mod-core-contracts/v3
Go to main page