core

package
v0.0.0-...-886a5b3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 23, 2024 License: BSD-3-Clause Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UPLOAD_PREFIX              = "__"
	UPLOAD_SOURCE              = "__src"
	UPLOAD_TIMESTAMP           = "__ts"
	UPLOAD_TYPE                = "__type"
	UPLOAD_TYPE_NAME    uint32 = 0
	UPLOAD_TYPE_ADDRESS uint32 = 1
	UPLOAD_NAME                = "__name"
	UPLOAD_VALUES              = "__vs"
)

Variables

This section is empty.

Functions

func CreateSchema 

func CreateSchema(db bun.IDB) error

func Seed 

func Seed(db *bun.DB) error

Types

type AttrService 

type AttrService struct {
	cores.UnimplementedAttrServiceServer
	// contains filtered or unexported fields
}

func (*AttrService) Clone 

func (s *AttrService) Clone(ctx context.Context, in *cores.AttrCloneRequest) (*pb.MyBool, error)

func (*AttrService) Create 

func (s *AttrService) Create(ctx context.Context, in *pb.Attr) (*pb.Attr, error)

func (*AttrService) Delete 

func (s *AttrService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*AttrService) GC 

func (s *AttrService) GC()

func (*AttrService) GetValue 

func (s *AttrService) GetValue(ctx context.Context, in *pb.Id) (*pb.AttrValue, error)

func (*AttrService) GetValueByName 

func (s *AttrService) GetValueByName(ctx context.Context, in *cores.AttrGetValueByNameRequest) (*cores.AttrNameValue, error)

func (*AttrService) List 

func (s *AttrService) List(ctx context.Context, in *cores.AttrListRequest) (*cores.AttrListResponse, error)

func (*AttrService) Name 

func (s *AttrService) Name(ctx context.Context, in *cores.AttrNameRequest) (*pb.Attr, error)

func (*AttrService) NameFull 

func (s *AttrService) NameFull(ctx context.Context, in *pb.Name) (*pb.Attr, error)

func (*AttrService) Pull 

func (s *AttrService) Pull(ctx context.Context, in *cores.AttrPullRequest) (*cores.AttrPullResponse, error)

func (*AttrService) SetValue 

func (s *AttrService) SetValue(ctx context.Context, in *pb.AttrValue) (*pb.MyBool, error)

func (*AttrService) SetValueByName 

func (s *AttrService) SetValueByName(ctx context.Context, in *cores.AttrNameValue) (*pb.MyBool, error)

func (*AttrService) SetValueByNameForce 

func (s *AttrService) SetValueByNameForce(ctx context.Context, in *cores.AttrNameValue) (*pb.MyBool, error)

func (*AttrService) SetValueForce 

func (s *AttrService) SetValueForce(ctx context.Context, in *pb.AttrValue) (*pb.MyBool, error)

func (*AttrService) Sync 

func (s *AttrService) Sync(ctx context.Context, in *pb.Attr) (*pb.MyBool, error)

func (*AttrService) Update 

func (s *AttrService) Update(ctx context.Context, in *pb.Attr) (*pb.Attr, error)

func (*AttrService) Upload 

func (s *AttrService) Upload(ctx context.Context, in *cores.AttrValueUploadRequest) (*cores.AttrValueUploadResponse, error)

func (*AttrService) View 

func (s *AttrService) View(ctx context.Context, in *pb.Id) (*pb.Attr, error)

func (*AttrService) ViewByClassIDAndName 

func (s *AttrService) ViewByClassIDAndName(ctx context.Context, classID, name string) (model.Attr, error)

func (*AttrService) ViewByDeviceIDAndName 

func (s *AttrService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Attr, error)

func (*AttrService) ViewByID 

func (s *AttrService) ViewByID(ctx context.Context, id string) (model.Attr, error)

func (*AttrService) ViewFromCacheByClassIDAndName 

func (s *AttrService) ViewFromCacheByClassIDAndName(ctx context.Context, classID, name string) (model.Attr, error)

func (*AttrService) ViewFromCacheByDeviceIDAndName 

func (s *AttrService) ViewFromCacheByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Attr, error)

func (*AttrService) ViewFromCacheByID 

func (s *AttrService) ViewFromCacheByID(ctx context.Context, id string) (model.Attr, error)

func (*AttrService) ViewWithDeleted 

func (s *AttrService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Attr, error)

type AuthService 

type AuthService struct {
	cores.UnimplementedAuthServiceServer
	// contains filtered or unexported fields
}

func (*AuthService) ChangePass 

func (s *AuthService) ChangePass(ctx context.Context, in *cores.ChangePassRequest) (*pb.Message, error)

func (*AuthService) ForceChangePass 

func (s *AuthService) ForceChangePass(ctx context.Context, in *cores.ForceChangePassRequest) (*pb.Message, error)

func (*AuthService) Login 

func (s *AuthService) Login(ctx context.Context, in *cores.LoginRequest) (*cores.LoginResponse, error)

type ClassService 

type ClassService struct {
	cores.UnimplementedClassServiceServer
	// contains filtered or unexported fields
}

func (*ClassService) Clone 

func (s *ClassService) Clone(ctx context.Context, in *cores.ClassCloneRequest) (*pb.MyBool, error)

func (*ClassService) Create 

func (s *ClassService) Create(ctx context.Context, in *pb.Class) (*pb.Class, error)

func (*ClassService) Delete 

func (s *ClassService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*ClassService) GC 

func (s *ClassService) GC()

func (*ClassService) List 

func (s *ClassService) List(ctx context.Context, in *cores.ClassListRequest) (*cores.ClassListResponse, error)

func (*ClassService) Name 

func (s *ClassService) Name(ctx context.Context, in *cores.ClassNameRequest) (*pb.Class, error)

func (*ClassService) NameFull 

func (s *ClassService) NameFull(ctx context.Context, in *pb.Name) (*pb.Class, error)

func (*ClassService) Pull 

func (s *ClassService) Pull(ctx context.Context, in *cores.ClassPullRequest) (*cores.ClassPullResponse, error)

func (*ClassService) Sync 

func (s *ClassService) Sync(ctx context.Context, in *pb.Class) (*pb.MyBool, error)

func (*ClassService) Update 

func (s *ClassService) Update(ctx context.Context, in *pb.Class) (*pb.Class, error)

func (*ClassService) View 

func (s *ClassService) View(ctx context.Context, in *pb.Id) (*pb.Class, error)

func (*ClassService) ViewByDeviceIDAndName 

func (s *ClassService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Class, error)

func (*ClassService) ViewByID 

func (s *ClassService) ViewByID(ctx context.Context, id string) (model.Class, error)

func (*ClassService) ViewFromCacheByDeviceIDAndName 

func (s *ClassService) ViewFromCacheByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Class, error)

func (*ClassService) ViewFromCacheByID 

func (s *ClassService) ViewFromCacheByID(ctx context.Context, id string) (model.Class, error)

func (*ClassService) ViewWithDeleted 

func (s *ClassService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Class, error)

type ConstService 

type ConstService struct {
	cores.UnimplementedConstServiceServer
	// contains filtered or unexported fields
}

func (*ConstService) Clone 

func (s *ConstService) Clone(ctx context.Context, in *cores.ConstCloneRequest) (*pb.MyBool, error)

func (*ConstService) Create 

func (s *ConstService) Create(ctx context.Context, in *pb.Const) (*pb.Const, error)

func (*ConstService) Delete 

func (s *ConstService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*ConstService) GC 

func (s *ConstService) GC()

func (*ConstService) GetValue 

func (s *ConstService) GetValue(ctx context.Context, in *pb.Id) (*pb.ConstValue, error)

func (*ConstService) GetValueByName 

func (s *ConstService) GetValueByName(ctx context.Context, in *cores.ConstGetValueByNameRequest) (*cores.ConstNameValue, error)

func (*ConstService) List 

func (s *ConstService) List(ctx context.Context, in *cores.ConstListRequest) (*cores.ConstListResponse, error)

func (*ConstService) Name 

func (s *ConstService) Name(ctx context.Context, in *cores.ConstNameRequest) (*pb.Const, error)

func (*ConstService) NameFull 

func (s *ConstService) NameFull(ctx context.Context, in *pb.Name) (*pb.Const, error)

func (*ConstService) Pull 

func (s *ConstService) Pull(ctx context.Context, in *cores.ConstPullRequest) (*cores.ConstPullResponse, error)

func (*ConstService) SetValue 

func (s *ConstService) SetValue(ctx context.Context, in *pb.ConstValue) (*pb.MyBool, error)

func (*ConstService) SetValueByName 

func (s *ConstService) SetValueByName(ctx context.Context, in *cores.ConstNameValue) (*pb.MyBool, error)

func (*ConstService) SetValueByNameForce 

func (s *ConstService) SetValueByNameForce(ctx context.Context, in *cores.ConstNameValue) (*pb.MyBool, error)

func (*ConstService) SetValueForce 

func (s *ConstService) SetValueForce(ctx context.Context, in *pb.ConstValue) (*pb.MyBool, error)

func (*ConstService) Sync 

func (s *ConstService) Sync(ctx context.Context, in *pb.Const) (*pb.MyBool, error)

func (*ConstService) Update 

func (s *ConstService) Update(ctx context.Context, in *pb.Const) (*pb.Const, error)

func (*ConstService) View 

func (s *ConstService) View(ctx context.Context, in *pb.Id) (*pb.Const, error)

func (*ConstService) ViewByDeviceIDAndName 

func (s *ConstService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Const, error)

func (*ConstService) ViewByID 

func (s *ConstService) ViewByID(ctx context.Context, id string) (model.Const, error)

func (*ConstService) ViewFromCacheByDeviceIDAndName 

func (s *ConstService) ViewFromCacheByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Const, error)

func (*ConstService) ViewFromCacheByID 

func (s *ConstService) ViewFromCacheByID(ctx context.Context, id string) (model.Const, error)

func (*ConstService) ViewWithDeleted 

func (s *ConstService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Const, error)

type ControlService 

type ControlService struct {
	cores.UnimplementedControlServiceServer
	// contains filtered or unexported fields
}

func (*ControlService) AddClient 

func (s *ControlService) AddClient(deviceID string, client cores.ControlServiceClient)

func (*ControlService) GetClient 

func (s *ControlService) GetClient(deviceID string) types.Option[cores.ControlServiceClient]

func (*ControlService) GetTagValue 

func (s *ControlService) GetTagValue(ctx context.Context, in *pb.Id) (*pb.TagValue, error)

func (*ControlService) RemoveClient 

func (s *ControlService) RemoveClient(deviceID string, client cores.ControlServiceClient)

func (*ControlService) SetTagValue 

func (s *ControlService) SetTagValue(ctx context.Context, in *pb.TagValue) (*pb.TagValue, error)

type CoreOption 

type CoreOption interface {
	// contains filtered or unexported methods
}

func WithCache 

func WithCache(enable bool) CoreOption

func WithCacheGCTTL 

func WithCacheGCTTL(d time.Duration) CoreOption

func WithCacheTTL 

func WithCacheTTL(d time.Duration) CoreOption

func WithInfluxDB 

func WithInfluxDB(influxdb *db.InfluxDB) CoreOption

func WithLinkTTL 

func WithLinkTTL(d time.Duration) CoreOption

func WithLogger 

func WithLogger(logger *zap.Logger) CoreOption

func WithSave 

func WithSave(enable bool) CoreOption

func WithSaveInterval 

func WithSaveInterval(d time.Duration) CoreOption

type CoreService 

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

func Core 

func Core(db *bun.DB, opts ...CoreOption) (*CoreService, error)

func CoreContext 

func CoreContext(ctx context.Context, db *bun.DB, opts ...CoreOption) (*CoreService, error)

func (*CoreService) Context 

func (cs *CoreService) Context() context.Context

func (*CoreService) GetAttr 

func (cs *CoreService) GetAttr() *AttrService

func (*CoreService) GetAuth 

func (cs *CoreService) GetAuth() *AuthService

func (*CoreService) GetClass 

func (cs *CoreService) GetClass() *ClassService

func (*CoreService) GetConst 

func (cs *CoreService) GetConst() *ConstService

func (*CoreService) GetControl 

func (cs *CoreService) GetControl() *ControlService

func (*CoreService) GetDB 

func (cs *CoreService) GetDB() *bun.DB

func (*CoreService) GetData 

func (cs *CoreService) GetData() *DataService

func (*CoreService) GetDevice 

func (cs *CoreService) GetDevice() *DeviceService

func (*CoreService) GetFn 

func (cs *CoreService) GetFn() *FnService

func (*CoreService) GetInfluxDB 

func (cs *CoreService) GetInfluxDB() types.Option[*db.InfluxDB]

func (*CoreService) GetLogic 

func (cs *CoreService) GetLogic() *LogicService

func (*CoreService) GetSave 

func (cs *CoreService) GetSave() types.Option[*SaveService]

func (*CoreService) GetSlot 

func (cs *CoreService) GetSlot() *SlotService

func (*CoreService) GetSource 

func (cs *CoreService) GetSource() *SourceService

func (*CoreService) GetStatus 

func (cs *CoreService) GetStatus() *StatusService

func (*CoreService) GetSync 

func (cs *CoreService) GetSync() *SyncService

func (*CoreService) GetSyncGlobal 

func (cs *CoreService) GetSyncGlobal() *SyncGlobalService

func (*CoreService) GetTag 

func (cs *CoreService) GetTag() *TagService

func (*CoreService) GetUser 

func (cs *CoreService) GetUser() *UserService

func (*CoreService) Logger 

func (cs *CoreService) Logger() *zap.Logger

func (*CoreService) Register 

func (cs *CoreService) Register(server *grpc.Server)

func (*CoreService) Start 

func (cs *CoreService) Start()

func (*CoreService) Stop 

func (cs *CoreService) Stop()

type DataService 

type DataService struct {
	cores.UnimplementedDataServiceServer
	// contains filtered or unexported fields
}

func (*DataService) CheckDataTypeJson 

func (s *DataService) CheckDataTypeJson(tag *model.Tag, value any) (nson.Value, error)

func (*DataService) CheckDataTypeNson 

func (s *DataService) CheckDataTypeNson(tag *model.Tag, value nson.Value) error

func (*DataService) Compile 

func (s *DataService) Compile(ctx context.Context, in *cores.DataQueryRequest) (*pb.Message, error)

func (*DataService) GetValue 

func (s *DataService) GetValue(tagID string) types.Option[cache.Value[nson.Value]]

func (*DataService) NewPoint 

func (s *DataService) NewPoint(tag *model.Tag, value float64, timestamp int64) *write.Point

func (*DataService) Query 

func (s *DataService) Query(in *cores.DataQueryRequest, stream cores.DataService_QueryServer) error

func (*DataService) QueryById 

func (s *DataService) QueryById(in *cores.DataQueryByIdRequest, stream cores.DataService_QueryByIdServer) error

func (*DataService) SetValue 

func (s *DataService) SetValue(tagID string, value nson.Value)

func (*DataService) UpdateValue 

func (s *DataService) UpdateValue(tag *model.Tag, value nson.Value)

func (*DataService) Upload 

func (s *DataService) Upload(ctx context.Context, in *cores.DataUploadRequest) (*cores.DataUploadResponse, error)

type DeviceService 

type DeviceService struct {
	cores.UnimplementedDeviceServiceServer
	// contains filtered or unexported fields
}

func (*DeviceService) Clone 

func (s *DeviceService) Clone(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*DeviceService) Create 

func (s *DeviceService) Create(ctx context.Context, in *pb.Device) (*pb.Device, error)

func (*DeviceService) Delete 

func (s *DeviceService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*DeviceService) Destory 

func (s *DeviceService) Destory(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*DeviceService) GC 

func (s *DeviceService) GC()
func (s *DeviceService) Link(ctx context.Context, in *cores.DeviceLinkRequest) (*pb.MyBool, error)

func (*DeviceService) List 

func (s *DeviceService) List(ctx context.Context, in *cores.DeviceListRequest) (*cores.DeviceListResponse, error)

func (*DeviceService) Name 

func (s *DeviceService) Name(ctx context.Context, in *pb.Name) (*pb.Device, error)

func (*DeviceService) Pull 

func (s *DeviceService) Pull(ctx context.Context, in *cores.DevicePullRequest) (*cores.DevicePullResponse, error)

func (*DeviceService) Sync 

func (s *DeviceService) Sync(ctx context.Context, in *pb.Device) (*pb.MyBool, error)

func (*DeviceService) Update 

func (s *DeviceService) Update(ctx context.Context, in *pb.Device) (*pb.Device, error)

func (*DeviceService) View 

func (s *DeviceService) View(ctx context.Context, in *pb.Id) (*pb.Device, error)

func (*DeviceService) ViewByID 

func (s *DeviceService) ViewByID(ctx context.Context, id string) (model.Device, error)

func (*DeviceService) ViewByName 

func (s *DeviceService) ViewByName(ctx context.Context, name string) (model.Device, error)

func (*DeviceService) ViewFromCacheByID 

func (s *DeviceService) ViewFromCacheByID(ctx context.Context, id string) (model.Device, error)

func (*DeviceService) ViewFromCacheByName 

func (s *DeviceService) ViewFromCacheByName(ctx context.Context, name string) (model.Device, error)

func (*DeviceService) ViewWithDeleted 

func (s *DeviceService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Device, error)

type FnService 

type FnService struct {
	cores.UnimplementedFnServiceServer
	// contains filtered or unexported fields
}

func (*FnService) Clone 

func (s *FnService) Clone(ctx context.Context, in *cores.CloneFnRequest) (*pb.MyBool, error)

func (*FnService) Create 

func (s *FnService) Create(ctx context.Context, in *pb.Fn) (*pb.Fn, error)

func (*FnService) Delete 

func (s *FnService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)
func (s *FnService) Link(ctx context.Context, in *cores.FnLinkRequest) (*pb.MyBool, error)

func (*FnService) List 

func (s *FnService) List(ctx context.Context, in *cores.FnListRequest) (*cores.FnListResponse, error)

func (*FnService) Name 

func (s *FnService) Name(ctx context.Context, in *cores.FnNameRequest) (*pb.Fn, error)

func (*FnService) Pull 

func (s *FnService) Pull(ctx context.Context, in *cores.FnPullRequest) (*cores.FnPullResponse, error)

func (*FnService) Sync 

func (s *FnService) Sync(ctx context.Context, in *pb.Fn) (*pb.MyBool, error)

func (*FnService) Update 

func (s *FnService) Update(ctx context.Context, in *pb.Fn) (*pb.Fn, error)

func (*FnService) View 

func (s *FnService) View(ctx context.Context, in *pb.Id) (*pb.Fn, error)

func (*FnService) ViewByID 

func (s *FnService) ViewByID(ctx context.Context, id string) (model.Fn, error)

func (*FnService) ViewWithDeleted 

func (s *FnService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Fn, error)

type GlobalNotify 

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

func (*GlobalNotify) Close 

func (n *GlobalNotify) Close()

func (*GlobalNotify) Id 

func (n *GlobalNotify) Id() string

func (*GlobalNotify) Wait 

func (w *GlobalNotify) Wait() <-chan struct{}

type LogicService 

type LogicService struct {
	cores.UnimplementedLogicServiceServer
	// contains filtered or unexported fields
}

func (*LogicService) Clone 

func (s *LogicService) Clone(ctx context.Context, in *cores.LogicCloneRequest) (*pb.MyBool, error)

func (*LogicService) Create 

func (s *LogicService) Create(ctx context.Context, in *pb.Logic) (*pb.Logic, error)

func (*LogicService) Delete 

func (s *LogicService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*LogicService) List 

func (s *LogicService) List(ctx context.Context, in *cores.LogicListRequest) (*cores.LogicListResponse, error)

func (*LogicService) Name 

func (s *LogicService) Name(ctx context.Context, in *cores.LogicNameRequest) (*pb.Logic, error)

func (*LogicService) Pull 

func (s *LogicService) Pull(ctx context.Context, in *cores.LogicPullRequest) (*cores.LogicPullResponse, error)

func (*LogicService) Sync 

func (s *LogicService) Sync(ctx context.Context, in *pb.Logic) (*pb.MyBool, error)

func (*LogicService) Update 

func (s *LogicService) Update(ctx context.Context, in *pb.Logic) (*pb.Logic, error)

func (*LogicService) View 

func (s *LogicService) View(ctx context.Context, in *pb.Id) (*pb.Logic, error)

func (*LogicService) ViewByID 

func (s *LogicService) ViewByID(ctx context.Context, id string) (model.Logic, error)

func (*LogicService) ViewWithDeleted 

func (s *LogicService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Logic, error)

type Notify 

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

func (*Notify) Close 

func (n *Notify) Close()

func (*Notify) Wait 

func (w *Notify) Wait() <-chan struct{}

type NotifyType 

type NotifyType int
const (
	NOTIFY      NotifyType = 0
	NOTIFY_TVAL NotifyType = 1
)

type SaveService 

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

type SlotService 

type SlotService struct {
	cores.UnimplementedSlotServiceServer
	// contains filtered or unexported fields
}

func (*SlotService) Clone 

func (s *SlotService) Clone(ctx context.Context, in *cores.SlotCloneRequest) (*pb.MyBool, error)

func (*SlotService) Create 

func (s *SlotService) Create(ctx context.Context, in *pb.Slot) (*pb.Slot, error)

func (*SlotService) Delete 

func (s *SlotService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)
func (s *SlotService) Link(ctx context.Context, in *cores.SlotLinkRequest) (*pb.MyBool, error)

func (*SlotService) List 

func (s *SlotService) List(ctx context.Context, in *cores.SlotListRequest) (*cores.SlotListResponse, error)

func (*SlotService) Name 

func (s *SlotService) Name(ctx context.Context, in *cores.SlotNameRequest) (*pb.Slot, error)

func (*SlotService) NameFull 

func (s *SlotService) NameFull(ctx context.Context, in *pb.Name) (*pb.Slot, error)

func (*SlotService) Pull 

func (s *SlotService) Pull(ctx context.Context, in *cores.SlotPullRequest) (*cores.SlotPullResponse, error)

func (*SlotService) Sync 

func (s *SlotService) Sync(ctx context.Context, in *pb.Slot) (*pb.MyBool, error)

func (*SlotService) Update 

func (s *SlotService) Update(ctx context.Context, in *pb.Slot) (*pb.Slot, error)

func (*SlotService) View 

func (s *SlotService) View(ctx context.Context, in *pb.Id) (*pb.Slot, error)

func (*SlotService) ViewByDeviceIDAndName 

func (s *SlotService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Slot, error)

func (*SlotService) ViewByID 

func (s *SlotService) ViewByID(ctx context.Context, id string) (model.Slot, error)

func (*SlotService) ViewWithDeleted 

func (s *SlotService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Slot, error)

type SourceService 

type SourceService struct {
	cores.UnimplementedSourceServiceServer
	// contains filtered or unexported fields
}

func (*SourceService) Clone 

func (s *SourceService) Clone(ctx context.Context, in *cores.SourceCloneRequest) (*pb.MyBool, error)

func (*SourceService) Create 

func (s *SourceService) Create(ctx context.Context, in *pb.Source) (*pb.Source, error)

func (*SourceService) Delete 

func (s *SourceService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*SourceService) GC 

func (s *SourceService) GC()
func (s *SourceService) Link(ctx context.Context, in *cores.SourceLinkRequest) (*pb.MyBool, error)

func (*SourceService) List 

func (s *SourceService) List(ctx context.Context, in *cores.SourceListRequest) (*cores.SourceListResponse, error)

func (*SourceService) Name 

func (s *SourceService) Name(ctx context.Context, in *cores.SourceNameRequest) (*pb.Source, error)

func (*SourceService) NameFull 

func (s *SourceService) NameFull(ctx context.Context, in *pb.Name) (*pb.Source, error)

func (*SourceService) Pull 

func (s *SourceService) Pull(ctx context.Context, in *cores.SourcePullRequest) (*cores.SourcePullResponse, error)

func (*SourceService) Sync 

func (s *SourceService) Sync(ctx context.Context, in *pb.Source) (*pb.MyBool, error)

func (*SourceService) Update 

func (s *SourceService) Update(ctx context.Context, in *pb.Source) (*pb.Source, error)

func (*SourceService) View 

func (s *SourceService) View(ctx context.Context, in *pb.Id) (*pb.Source, error)

func (*SourceService) ViewByDeviceIDAndName 

func (s *SourceService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Source, error)

func (*SourceService) ViewByID 

func (s *SourceService) ViewByID(ctx context.Context, id string) (model.Source, error)

func (*SourceService) ViewFromCacheByDeviceIDAndName 

func (s *SourceService) ViewFromCacheByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Source, error)

func (*SourceService) ViewFromCacheByID 

func (s *SourceService) ViewFromCacheByID(ctx context.Context, id string) (model.Source, error)

func (*SourceService) ViewWithDeleted 

func (s *SourceService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Source, error)

type StatusService 

type StatusService struct {
	// contains filtered or unexported fields
}
func (s *StatusService) GetLink(key string) int32

func (*StatusService) GetLinkValue 

func (s *StatusService) GetLinkValue(key string) types.Option[cache.Value[int32]]
func (s *StatusService) SetLink(key string, status int32)

type SyncGlobalService 

type SyncGlobalService struct {
	cores.UnimplementedSyncGlobalServiceServer
	// contains filtered or unexported fields
}

func (*SyncGlobalService) GetUpdated 

func (s *SyncGlobalService) GetUpdated(ctx context.Context, in *pb.Id) (*cores.SyncUpdated, error)

func (*SyncGlobalService) Notify 

func (s *SyncGlobalService) Notify(id string) *GlobalNotify

func (*SyncGlobalService) SetUpdated 

func (s *SyncGlobalService) SetUpdated(ctx context.Context, in *cores.SyncUpdated) (*pb.MyBool, error)

func (*SyncGlobalService) WaitDeviceUpdated 

func (s *SyncGlobalService) WaitDeviceUpdated(in *pb.Id,
	stream cores.SyncGlobalService_WaitUpdatedServer) error

type SyncService 

type SyncService struct {
	cores.UnimplementedSyncServiceServer
	// contains filtered or unexported fields
}

func (*SyncService) GetDeviceUpdated 

func (s *SyncService) GetDeviceUpdated(ctx context.Context, in *pb.Id) (*cores.SyncUpdated, error)

func (*SyncService) GetTagValueUpdated 

func (s *SyncService) GetTagValueUpdated(ctx context.Context, in *pb.Id) (*cores.SyncUpdated, error)

func (*SyncService) Notify 

func (s *SyncService) Notify(id string, nt NotifyType) *Notify

func (*SyncService) SetDeviceUpdated 

func (s *SyncService) SetDeviceUpdated(ctx context.Context, in *cores.SyncUpdated) (*pb.MyBool, error)

func (*SyncService) SetTagValueUpdated 

func (s *SyncService) SetTagValueUpdated(ctx context.Context, in *cores.SyncUpdated) (*pb.MyBool, error)

func (*SyncService) WaitDeviceUpdated 

func (s *SyncService) WaitDeviceUpdated(in *pb.Id,
	stream cores.SyncService_WaitDeviceUpdatedServer) error

func (*SyncService) WaitTagValueUpdated 

func (s *SyncService) WaitTagValueUpdated(in *pb.Id,
	stream cores.SyncService_WaitTagValueUpdatedServer) error

type TagService 

type TagService struct {
	cores.UnimplementedTagServiceServer
	// contains filtered or unexported fields
}

func (*TagService) Clone 

func (s *TagService) Clone(ctx context.Context, in *cores.TagCloneRequest) (*pb.MyBool, error)

func (*TagService) Create 

func (s *TagService) Create(ctx context.Context, in *pb.Tag) (*pb.Tag, error)

func (*TagService) Delete 

func (s *TagService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*TagService) DeleteValue 

func (s *TagService) DeleteValue(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*TagService) GC 

func (s *TagService) GC()

func (*TagService) GetValue 

func (s *TagService) GetValue(ctx context.Context, in *pb.Id) (*pb.TagValue, error)

func (*TagService) GetValueByName 

func (s *TagService) GetValueByName(ctx context.Context, in *cores.TagGetValueByNameRequest) (*cores.TagNameValue, error)

func (*TagService) List 

func (s *TagService) List(ctx context.Context, in *cores.TagListRequest) (*cores.TagListResponse, error)

func (*TagService) Name 

func (s *TagService) Name(ctx context.Context, in *cores.TagNameRequest) (*pb.Tag, error)

func (*TagService) NameFull 

func (s *TagService) NameFull(ctx context.Context, in *pb.Name) (*pb.Tag, error)

func (*TagService) Pull 

func (s *TagService) Pull(ctx context.Context, in *cores.TagPullRequest) (*cores.TagPullResponse, error)

func (*TagService) PullValue 

func (s *TagService) PullValue(ctx context.Context, in *cores.TagPullValueRequest) (*cores.TagPullValueResponse, error)

func (*TagService) SetValue 

func (s *TagService) SetValue(ctx context.Context, in *pb.TagValue) (*pb.MyBool, error)

func (*TagService) SetValueByName 

func (s *TagService) SetValueByName(ctx context.Context, in *cores.TagNameValue) (*pb.MyBool, error)

func (*TagService) SetValueByNameForce 

func (s *TagService) SetValueByNameForce(ctx context.Context, in *cores.TagNameValue) (*pb.MyBool, error)

func (*TagService) SetValueForce 

func (s *TagService) SetValueForce(ctx context.Context, in *pb.TagValue) (*pb.MyBool, error)

func (*TagService) Sync 

func (s *TagService) Sync(ctx context.Context, in *pb.Tag) (*pb.MyBool, error)

func (*TagService) SyncValue 

func (s *TagService) SyncValue(ctx context.Context, in *pb.TagValue) (*pb.MyBool, error)

func (*TagService) Update 

func (s *TagService) Update(ctx context.Context, in *pb.Tag) (*pb.Tag, error)

func (*TagService) View 

func (s *TagService) View(ctx context.Context, in *pb.Id) (*pb.Tag, error)

func (*TagService) ViewByDeviceIDAndName 

func (s *TagService) ViewByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Tag, error)

func (*TagService) ViewByID 

func (s *TagService) ViewByID(ctx context.Context, id string) (model.Tag, error)

func (*TagService) ViewBySourceIDAndAddress 

func (s *TagService) ViewBySourceIDAndAddress(ctx context.Context, sourceID, address string) (model.Tag, error)

func (*TagService) ViewBySourceIDAndName 

func (s *TagService) ViewBySourceIDAndName(ctx context.Context, sourceID, name string) (model.Tag, error)

func (*TagService) ViewFromCacheByDeviceIDAndName 

func (s *TagService) ViewFromCacheByDeviceIDAndName(ctx context.Context, deviceID, name string) (model.Tag, error)

func (*TagService) ViewFromCacheByID 

func (s *TagService) ViewFromCacheByID(ctx context.Context, id string) (model.Tag, error)

func (*TagService) ViewFromCacheBySourceIDAndAddress 

func (s *TagService) ViewFromCacheBySourceIDAndAddress(ctx context.Context, sourceID, address string) (model.Tag, error)

func (*TagService) ViewFromCacheBySourceIDAndName 

func (s *TagService) ViewFromCacheBySourceIDAndName(ctx context.Context, sourceID, name string) (model.Tag, error)

func (*TagService) ViewValue 

func (s *TagService) ViewValue(ctx context.Context, in *pb.Id) (*pb.TagValueUpdated, error)

func (*TagService) ViewWithDeleted 

func (s *TagService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.Tag, error)

type UserService 

type UserService struct {
	cores.UnimplementedUserServiceServer
	// contains filtered or unexported fields
}

func (*UserService) Create 

func (s *UserService) Create(ctx context.Context, in *pb.User) (*pb.User, error)

func (*UserService) Delete 

func (s *UserService) Delete(ctx context.Context, in *pb.Id) (*pb.MyBool, error)

func (*UserService) GC 

func (s *UserService) GC()

func (*UserService) List 

func (s *UserService) List(ctx context.Context, in *cores.UserListRequest) (*cores.UserListResponse, error)

func (*UserService) Name 

func (s *UserService) Name(ctx context.Context, in *pb.Name) (*pb.User, error)

func (*UserService) Pull 

func (s *UserService) Pull(ctx context.Context, in *cores.UserPullRequest) (*cores.UserPullResponse, error)

func (*UserService) Update 

func (s *UserService) Update(ctx context.Context, in *pb.User) (*pb.User, error)

func (*UserService) View 

func (s *UserService) View(ctx context.Context, in *pb.Id) (*pb.User, error)

func (*UserService) ViewByID 

func (s *UserService) ViewByID(ctx context.Context, id string) (model.User, error)

func (*UserService) ViewByName 

func (s *UserService) ViewByName(ctx context.Context, name string) (model.User, error)

func (*UserService) ViewFromCacheByID 

func (s *UserService) ViewFromCacheByID(ctx context.Context, id string) (model.User, error)

func (*UserService) ViewFromCacheByName 

func (s *UserService) ViewFromCacheByName(ctx context.Context, name string) (model.User, error)

func (*UserService) ViewWithDeleted 

func (s *UserService) ViewWithDeleted(ctx context.Context, in *pb.Id) (*pb.User, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.