core_client

Documentation

Index

• Constants
• func PublishDeviceCreateRequest(bus *nats.Conn, req *mir_apiv1.CreateDeviceRequest) (*mir_apiv1.CreateDeviceResponse, error)
• func PublishDeviceCreatedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error
• func PublishDeviceDeleteRequest(bus *nats.Conn, req *mir_apiv1.DeleteDeviceRequest) (*mir_apiv1.DeleteDeviceResponse, error)
• func PublishDeviceDeletedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error
• func PublishDeviceListRequest(bus *nats.Conn, req *mir_apiv1.ListDeviceRequest) (*mir_apiv1.ListDeviceResponse, error)
• func PublishDeviceUpdateRequest(bus *nats.Conn, req *mir_apiv1.UpdateDeviceRequest) (*mir_apiv1.UpdateDeviceResponse, error)
• func PublishDeviceUpdatedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error
• func PublishHearthbeatStream(bus *nats.Conn, deviceId string) error

Constants

const (
	CreateDeviceRequest clients.ServerSubject = "client.%s.core.v1alpha.create"
	UpdateDeviceRequest clients.ServerSubject = "client.%s.core.v1alpha.update"
	DeleteDeviceRequest clients.ServerSubject = "client.%s.core.v1alpha.delete"
	ListDeviceRequest   clients.ServerSubject = "client.%s.core.v1alpha.list"

	DeviceOnlineEvent  clients.ServerSubject = "event.%s.core.v1alpha.deviceonline"
	DeviceOfflineEvent clients.ServerSubject = "event.%s.core.v1alpha.deviceoffline"
	DeviceCreatedEvent clients.ServerSubject = "event.%s.core.v1alpha.devicecreated"
	DeviceDeletedEvent clients.ServerSubject = "event.%s.core.v1alpha.devicedeleted"
	DeviceUpdatedEvent clients.ServerSubject = "event.%s.core.v1alpha.deviceupdated"

	HearthbeatDeviceStream clients.ServerSubject = "device.%s.core.v1alpha.hearthbeat"
	SchemaDeviceStream     clients.ServerSubject = "device.%s.core.v1alpha.schema"
)

Functions

func PublishDeviceCreateRequest

func PublishDeviceCreateRequest(bus *nats.Conn, req *mir_apiv1.CreateDeviceRequest) (*mir_apiv1.CreateDeviceResponse, error)

func PublishDeviceCreatedEvent

func PublishDeviceCreatedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error

func PublishDeviceDeleteRequest

func PublishDeviceDeleteRequest(bus *nats.Conn, req *mir_apiv1.DeleteDeviceRequest) (*mir_apiv1.DeleteDeviceResponse, error)

func PublishDeviceDeletedEvent

func PublishDeviceDeletedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error

func PublishDeviceListRequest

func PublishDeviceListRequest(bus *nats.Conn, req *mir_apiv1.ListDeviceRequest) (*mir_apiv1.ListDeviceResponse, error)

func PublishDeviceUpdateRequest

func PublishDeviceUpdateRequest(bus *nats.Conn, req *mir_apiv1.UpdateDeviceRequest) (*mir_apiv1.UpdateDeviceResponse, error)

func PublishDeviceUpdatedEvent

func PublishDeviceUpdatedEvent(bus *nats.Conn, originalInstance string, deviceId string, d mir_v1.Device) error

func PublishHearthbeatStream

func PublishHearthbeatStream(bus *nats.Conn, deviceId string) error