schema_cache

Documentation

Index

• type MirSchemaCache
  • func NewMirSchemaCache(logger zerolog.Logger, m *mir.Mir) (*MirSchemaCache, error)
  • func (c *MirSchemaCache) AddDeviceUpdateSub(...)
  • func (c *MirSchemaCache) FindMessageDescriptor(deviceId string, sch *mir_proto.MirProtoSchema, msgName string) (protoreflect.Descriptor, *mir_proto.MirProtoSchema, error)
  • func (c *MirSchemaCache) GetDeviceSchema(deviceId string, refreshSchema bool) (*mir_proto.MirProtoSchema, mir_v1.Device, error)
  • func (c *MirSchemaCache) GetDeviceSchemaAndDescriptor(deviceId string, descName string, refreshSchema bool) (protoreflect.Descriptor, *mir_proto.MirProtoSchema, mir_v1.Device, error)
  • func (c *MirSchemaCache) GetDynamicMsg(deviceId string, protoMsgName string, data []byte) (*dynamicpb.Message, error)

Types

type MirSchemaCache

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

func NewMirSchemaCache

func NewMirSchemaCache(logger zerolog.Logger, m *mir.Mir) (*MirSchemaCache, error)

func (*MirSchemaCache) AddDeviceUpdateSub

func (c *MirSchemaCache) AddDeviceUpdateSub(fn func(deviceId string, device mir_v1.Device, schema mir_proto.MirProtoSchema))

func (*MirSchemaCache) FindMessageDescriptor

func (c *MirSchemaCache) FindMessageDescriptor(deviceId string, sch *mir_proto.MirProtoSchema, msgName string) (protoreflect.Descriptor, *mir_proto.MirProtoSchema, error)

func (*MirSchemaCache) GetDeviceSchema

func (c *MirSchemaCache) GetDeviceSchema(deviceId string, refreshSchema bool) (*mir_proto.MirProtoSchema, mir_v1.Device, error)

Get the device schema from cache. If missing or refresh schema is true, the cache will be invalidated and schema will be fetch from database or device

func (*MirSchemaCache) GetDeviceSchemaAndDescriptor

func (c *MirSchemaCache) GetDeviceSchemaAndDescriptor(deviceId string, descName string, refreshSchema bool) (protoreflect.Descriptor, *mir_proto.MirProtoSchema, mir_v1.Device, error)

Get device schema and descriptor from cache If schema missing, get from db. If db missing, fetch from device. If refreshSchema is true, force refresh from db

func (*MirSchemaCache) GetDynamicMsg

func (c *MirSchemaCache) GetDynamicMsg(deviceId string, protoMsgName string, data []byte) (*dynamicpb.Message, error)