events

Documentation

Index

• Constants
• Variables
• func GetDevicesRegisteredSubject(owner string) string
• func GetDevicesUnregisteredSubject(owner string) string
• func GetRegistrationSubject(owner string) string
• func OwnerToUUID(owner string) string
• func ToSubject(template string, opts ...func(values map[string]string)) string
• func WithEventType(eventType string) func(values map[string]string)
• func WithOwner(owner string) func(values map[string]string)
• type AuditContext
  • func (*AuditContext) Descriptor() ([]byte, []int)
  • func (x *AuditContext) GetUserId() string
  • func (*AuditContext) ProtoMessage()
  • func (x *AuditContext) ProtoReflect() protoreflect.Message
  • func (x *AuditContext) Reset()
  • func (x *AuditContext) String() string
• type DevicesRegistered
  • func (*DevicesRegistered) Descriptor() ([]byte, []int)
  • func (x *DevicesRegistered) GetAuditContext() *AuditContext
  • func (x *DevicesRegistered) GetDeviceIds() []string
  • func (x *DevicesRegistered) GetOwner() string
  • func (x *DevicesRegistered) GetTimestamp() int64
  • func (*DevicesRegistered) ProtoMessage()
  • func (x *DevicesRegistered) ProtoReflect() protoreflect.Message
  • func (x *DevicesRegistered) Reset()
  • func (x *DevicesRegistered) String() string
• type DevicesUnregistered
  • func (*DevicesUnregistered) Descriptor() ([]byte, []int)
  • func (x *DevicesUnregistered) GetAuditContext() *AuditContext
  • func (x *DevicesUnregistered) GetDeviceIds() []string
  • func (x *DevicesUnregistered) GetOwner() string
  • func (x *DevicesUnregistered) GetTimestamp() int64
  • func (*DevicesUnregistered) ProtoMessage()
  • func (x *DevicesUnregistered) ProtoReflect() protoreflect.Message
  • func (x *DevicesUnregistered) Reset()
  • func (x *DevicesUnregistered) String() string
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetDevicesRegistered() *DevicesRegistered
  • func (x *Event) GetDevicesUnregistered() *DevicesUnregistered
  • func (m *Event) GetType() isEvent_Type
  • func (e *Event) Marshal() ([]byte, error)
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (x *Event) Reset()
  • func (x *Event) String() string
  • func (e *Event) Unmarshal(b []byte) error
• type Event_DevicesRegistered
• type Event_DevicesUnregistered

Constants

const DevicesRegisteredEvent = "devicesregistered"

const DevicesUnregisteredEvent = "devicesunregistered"

const EventTypeKey = "eventType"

const OwnerIdKey = "ownerId"

const Plgd = "plgd"

const PlgdOwners = Plgd + ".owners"

const PlgdOwnersOwner = PlgdOwners + ".{" + OwnerIdKey + "}"

const PlgdOwnersOwnerRegistrations = PlgdOwnersOwner + "." + Registrations

const PlgdOwnersOwnerRegistrationsEvent = PlgdOwnersOwnerRegistrations + ".{" + EventTypeKey + "}"

const Registrations = "registrations"

Variables

var File_github_com_plgd_dev_hub_identity_store_pb_events_proto protoreflect.FileDescriptor

Functions

func GetDevicesRegisteredSubject

func GetDevicesRegisteredSubject(owner string) string

func GetDevicesUnregisteredSubject

func GetDevicesUnregisteredSubject(owner string) string

func GetRegistrationSubject

func GetRegistrationSubject(owner string) string

func OwnerToUUID

func OwnerToUUID(owner string) string

func ToSubject

func ToSubject(template string, opts ...func(values map[string]string)) string

func WithEventType

func WithEventType(eventType string) func(values map[string]string)

func WithOwner

func WithOwner(owner string) func(values map[string]string)

Types

type AuditContext

type AuditContext struct {
	UserId string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

provides who register/unregister the device

func (*AuditContext) Descriptor

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

Deprecated: Use AuditContext.ProtoReflect.Descriptor instead.

func (*AuditContext) GetUserId

func (x *AuditContext) GetUserId() string

func (*AuditContext) ProtoMessage

func (*AuditContext) ProtoMessage()

func (*AuditContext) ProtoReflect

func (x *AuditContext) ProtoReflect() protoreflect.Message

func (*AuditContext) Reset

func (x *AuditContext) Reset()

func (*AuditContext) String

func (x *AuditContext) String() string

type DevicesRegistered

type DevicesRegistered struct {
	Owner        string        `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`                                   // new owner of devices.
	DeviceIds    []string      `protobuf:"bytes,2,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`          // list of device ids added to owner.
	Timestamp    int64         `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                          // unix timestamp in nanoseconds of creation event.
	AuditContext *AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // provides who register/unregister the device
	// contains filtered or unexported fields
}

devices was registered to owner.

func (*DevicesRegistered) Descriptor

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

Deprecated: Use DevicesRegistered.ProtoReflect.Descriptor instead.

func (*DevicesRegistered) GetAuditContext

func (x *DevicesRegistered) GetAuditContext() *AuditContext

func (*DevicesRegistered) GetDeviceIds

func (x *DevicesRegistered) GetDeviceIds() []string

func (*DevicesRegistered) GetOwner

func (x *DevicesRegistered) GetOwner() string

func (*DevicesRegistered) GetTimestamp

func (x *DevicesRegistered) GetTimestamp() int64

func (*DevicesRegistered) ProtoMessage

func (*DevicesRegistered) ProtoMessage()

func (*DevicesRegistered) ProtoReflect

func (x *DevicesRegistered) ProtoReflect() protoreflect.Message

func (*DevicesRegistered) Reset

func (x *DevicesRegistered) Reset()

func (*DevicesRegistered) String

func (x *DevicesRegistered) String() string

type DevicesUnregistered

type DevicesUnregistered struct {
	Owner        string        `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`                                   // owner, which lose devices.
	DeviceIds    []string      `protobuf:"bytes,2,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`          // list of device ids deleted from owner.
	Timestamp    int64         `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                          // unix timestamp in nanoseconds of creation event.
	AuditContext *AuditContext `protobuf:"bytes,4,opt,name=audit_context,json=auditContext,proto3" json:"audit_context,omitempty"` // provides who register/unregister the device
	// contains filtered or unexported fields
}

devices was deregistered from owner.

func (*DevicesUnregistered) Descriptor

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

Deprecated: Use DevicesUnregistered.ProtoReflect.Descriptor instead.

func (*DevicesUnregistered) GetAuditContext

func (x *DevicesUnregistered) GetAuditContext() *AuditContext

func (*DevicesUnregistered) GetDeviceIds

func (x *DevicesUnregistered) GetDeviceIds() []string

func (*DevicesUnregistered) GetOwner

func (x *DevicesUnregistered) GetOwner() string

func (*DevicesUnregistered) GetTimestamp

func (x *DevicesUnregistered) GetTimestamp() int64

func (*DevicesUnregistered) ProtoMessage

func (*DevicesUnregistered) ProtoMessage()

func (*DevicesUnregistered) ProtoReflect

func (x *DevicesUnregistered) ProtoReflect() protoreflect.Message

func (*DevicesUnregistered) Reset

func (x *DevicesUnregistered) Reset()

func (*DevicesUnregistered) String

func (x *DevicesUnregistered) String() string

type Event

type Event struct {

	// Types that are assignable to Type:
	//	*Event_DevicesRegistered
	//	*Event_DevicesUnregistered
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

nats: owners.{owner}.>

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetDevicesRegistered

func (x *Event) GetDevicesRegistered() *DevicesRegistered

func (*Event) GetDevicesUnregistered

func (x *Event) GetDevicesUnregistered() *DevicesUnregistered

func (*Event) GetType

func (m *Event) GetType() isEvent_Type

func (*Event) Marshal

func (e *Event) Marshal() ([]byte, error)

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

func (*Event) Unmarshal

func (e *Event) Unmarshal(b []byte) error

type Event_DevicesRegistered

type Event_DevicesRegistered struct {
	// nats: owners.{owner}.registered
	DevicesRegistered *DevicesRegistered `protobuf:"bytes,1,opt,name=devices_registered,json=devicesRegistered,proto3,oneof"`
}

type Event_DevicesUnregistered

type Event_DevicesUnregistered struct {
	// nats: owners.{owner}.unregistered
	DevicesUnregistered *DevicesUnregistered `protobuf:"bytes,2,opt,name=devices_unregistered,json=devicesUnregistered,proto3,oneof"`
}