edge

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: 41 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 {
	edges.UnimplementedAttrServiceServer
	// contains filtered or unexported fields
}

func (*AttrService) Clone 

func (s *AttrService) Clone(ctx context.Context, in *edges.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 *pb.Name) (*pb.AttrNameValue, error)

func (*AttrService) List 

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

func (*AttrService) Name 

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

func (*AttrService) Pull 

func (s *AttrService) Pull(ctx context.Context, in *edges.AttrPullRequest) (*edges.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 *pb.AttrNameValue) (*pb.MyBool, error)

func (*AttrService) SetValueByNameForce 

func (s *AttrService) SetValueByNameForce(ctx context.Context, in *pb.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) 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) ViewByID 

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

func (*AttrService) ViewByName 

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

func (*AttrService) ViewFromCacheByClassIDAndName 

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

func (*AttrService) ViewFromCacheByID 

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

func (*AttrService) ViewFromCacheByName 

func (s *AttrService) ViewFromCacheByName(ctx context.Context, name 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 {
	edges.UnimplementedAuthServiceServer
	// contains filtered or unexported fields
}

func (*AuthService) ChangePass 

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

func (*AuthService) ForceChangePass 

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

func (*AuthService) Login 

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

type BadgerGCOptions 

type BadgerGCOptions struct {
	GC             time.Duration
	GCDiscardRatio float64
}

type BadgerService 

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

func (*BadgerService) GetDB 

func (s *BadgerService) GetDB() *badger.DB

type ClassService 

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

func (*ClassService) Clone 

func (s *ClassService) Clone(ctx context.Context, in *edges.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 *edges.ClassListRequest) (*edges.ClassListResponse, error)

func (*ClassService) Name 

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

func (*ClassService) Pull 

func (s *ClassService) Pull(ctx context.Context, in *edges.ClassPullRequest) (*edges.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) ViewByID 

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

func (*ClassService) ViewByName 

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

func (*ClassService) ViewFromCacheByID 

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

func (*ClassService) ViewFromCacheByName 

func (s *ClassService) ViewFromCacheByName(ctx context.Context, name 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 {
	edges.UnimplementedConstServiceServer
	// contains filtered or unexported fields
}

func (*ConstService) Clone 

func (s *ConstService) Clone(ctx context.Context, in *edges.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 *pb.Name) (*pb.ConstNameValue, error)

func (*ConstService) List 

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

func (*ConstService) Name 

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

func (*ConstService) Pull 

func (s *ConstService) Pull(ctx context.Context, in *edges.ConstPullRequest) (*edges.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 *pb.ConstNameValue) (*pb.MyBool, error)

func (*ConstService) SetValueByNameForce 

func (s *ConstService) SetValueByNameForce(ctx context.Context, in *pb.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) ViewByID 

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

func (*ConstService) ViewByName 

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

func (*ConstService) ViewFromByName 

func (s *ConstService) ViewFromByName(ctx context.Context, 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 {
	edges.UnimplementedControlServiceServer
	// contains filtered or unexported fields
}

func (*ControlService) AddSlotClient 

func (s *ControlService) AddSlotClient(slotID string, client slots.ControlServiceClient)

func (*ControlService) AddSourceServer 

func (s *ControlService) AddSourceServer(sourceID string, server slots.ControlServiceServer)

func (*ControlService) DeleteSlotClient 

func (s *ControlService) DeleteSlotClient(slotID string, client slots.ControlServiceClient)

func (*ControlService) GetSlotClient 

func (s *ControlService) GetSlotClient(slotID string) types.Option[slots.ControlServiceClient]

func (*ControlService) GetSourceServer 

func (s *ControlService) GetSourceServer(sourceID string) types.Option[slots.ControlServiceServer]

func (*ControlService) GetTagValue 

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

func (*ControlService) RemoveSourceServer 

func (s *ControlService) RemoveSourceServer(sourceID string, server slots.ControlServiceServer)

func (*ControlService) SetTagValue 

func (s *ControlService) SetTagValue(ctx context.Context, in *pb.TagValue) (*pb.TagValue, error)
func (s *ControlService) SourceLink(slotID string, sourceID string, status int32)

type DataService 

type DataService struct {
	edges.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 *edges.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 *edges.DataQueryRequest, stream edges.DataService_QueryServer) error

func (*DataService) QueryById 

func (s *DataService) QueryById(in *edges.DataQueryByIdRequest, stream edges.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 *edges.DataUploadRequest) (*edges.DataUploadResponse, error)

type DeviceService 

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

func (*DeviceService) Destory 

func (s *DeviceService) Destory(ctx context.Context, in *pb.MyEmpty) (*pb.MyBool, 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.MyEmpty) (*pb.Device, error)

func (*DeviceService) ViewByID 

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

func (*DeviceService) ViewFromCacheByID 

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

func (*DeviceService) ViewWithDeleted 

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

type EdgeOption 

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

func WithBadger 

func WithBadger(options badger.Options) EdgeOption

func WithBadgerGC 

func WithBadgerGC(options *BadgerGCOptions) EdgeOption

func WithCache 

func WithCache(enable bool) EdgeOption

func WithCacheGCTTL 

func WithCacheGCTTL(d time.Duration) EdgeOption

func WithCacheTTL 

func WithCacheTTL(d time.Duration) EdgeOption

func WithDeviceID 

func WithDeviceID(id, secret string) EdgeOption

func WithInfluxDB 

func WithInfluxDB(influxdb *db.InfluxDB) EdgeOption

func WithLinkTTL 

func WithLinkTTL(d time.Duration) EdgeOption

func WithLogger 

func WithLogger(logger *zap.Logger) EdgeOption

func WithNode 

func WithNode(options NodeOptions) EdgeOption

func WithSave 

func WithSave(enable bool) EdgeOption

func WithSaveInterval 

func WithSaveInterval(d time.Duration) EdgeOption

func WithSync 

func WithSync(options SyncOptions) EdgeOption

type EdgeService 

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

func Edge 

func Edge(db *bun.DB, opts ...EdgeOption) (*EdgeService, error)

func EdgeContext 

func EdgeContext(ctx context.Context, db *bun.DB, opts ...EdgeOption) (*EdgeService, error)

func (*EdgeService) Context 

func (es *EdgeService) Context() context.Context

func (*EdgeService) GetAttr 

func (es *EdgeService) GetAttr() *AttrService

func (*EdgeService) GetAuth 

func (es *EdgeService) GetAuth() *AuthService

func (*EdgeService) GetBadgerDB 

func (es *EdgeService) GetBadgerDB() *badger.DB

func (*EdgeService) GetClass 

func (es *EdgeService) GetClass() *ClassService

func (*EdgeService) GetConst 

func (es *EdgeService) GetConst() *ConstService

func (*EdgeService) GetControl 

func (es *EdgeService) GetControl() *ControlService

func (*EdgeService) GetDB 

func (es *EdgeService) GetDB() *bun.DB

func (*EdgeService) GetData 

func (es *EdgeService) GetData() *DataService

func (*EdgeService) GetDevice 

func (es *EdgeService) GetDevice() *DeviceService

func (*EdgeService) GetFn 

func (es *EdgeService) GetFn() *FnService

func (*EdgeService) GetInfluxDB 

func (es *EdgeService) GetInfluxDB() types.Option[*db.InfluxDB]

func (*EdgeService) GetLogic 

func (es *EdgeService) GetLogic() *LogicService

func (*EdgeService) GetNode 

func (es *EdgeService) GetNode() types.Option[*NodeService]

func (*EdgeService) GetSave 

func (es *EdgeService) GetSave() types.Option[*SaveService]

func (*EdgeService) GetSlot 

func (es *EdgeService) GetSlot() *SlotService

func (*EdgeService) GetSource 

func (es *EdgeService) GetSource() *SourceService

func (*EdgeService) GetStatus 

func (es *EdgeService) GetStatus() *StatusService

func (*EdgeService) GetSync 

func (es *EdgeService) GetSync() *SyncService

func (*EdgeService) GetTag 

func (es *EdgeService) GetTag() *TagService

func (*EdgeService) GetUser 

func (es *EdgeService) GetUser() *UserService

func (*EdgeService) Logger 

func (es *EdgeService) Logger() *zap.Logger

func (*EdgeService) Register 

func (es *EdgeService) Register(server *grpc.Server)

func (*EdgeService) Start 

func (es *EdgeService) Start()

func (*EdgeService) Stop 

func (es *EdgeService) Stop()

type FnService 

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

func (*FnService) Clone 

func (s *FnService) Clone(ctx context.Context, in *edges.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 *edges.FnLinkRequest) (*pb.MyBool, error)

func (*FnService) List 

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

func (*FnService) Name 

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

func (*FnService) Pull 

func (s *FnService) Pull(ctx context.Context, in *edges.FnPullRequest) (*edges.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) ViewByName 

func (s *FnService) ViewByName(ctx context.Context, name string) (model.Fn, error)

func (*FnService) ViewWithDeleted 

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

type LogicService 

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

func (*LogicService) Clone 

func (s *LogicService) Clone(ctx context.Context, in *edges.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 *edges.LogicListRequest) (*edges.LogicListResponse, error)

func (*LogicService) Name 

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

func (*LogicService) Pull 

func (s *LogicService) Pull(ctx context.Context, in *edges.LogicPullRequest) (*edges.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) ViewByName 

func (s *LogicService) ViewByName(ctx context.Context, name string) (model.Logic, error)

func (*LogicService) ViewWithDeleted 

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

type NodeOptions 

type NodeOptions struct {
	Enable      bool
	Addr        string
	GRPCOptions []grpc.DialOption
}

type NodeService 

type NodeService struct {
	NodeConn *grpc.ClientConn
	// contains filtered or unexported fields
}

func (*NodeService) AttrServiceClient 

func (s *NodeService) AttrServiceClient() nodes.AttrServiceClient

func (*NodeService) ClassServiceClient 

func (s *NodeService) ClassServiceClient() nodes.ClassServiceClient

func (*NodeService) ConstServiceClient 

func (s *NodeService) ConstServiceClient() nodes.ConstServiceClient

func (*NodeService) DataServiceClient 

func (s *NodeService) DataServiceClient() nodes.DataServiceClient
func (s *NodeService) DeviceLink(ctx context.Context) error

func (*NodeService) DeviceServiceClient 

func (s *NodeService) DeviceServiceClient() nodes.DeviceServiceClient

func (*NodeService) FnServiceClient 

func (s *NodeService) FnServiceClient() nodes.FnServiceClient

func (*NodeService) GetToken 

func (s *NodeService) GetToken() string

func (*NodeService) LogicServiceClient 

func (s *NodeService) LogicServiceClient() nodes.LogicServiceClient

func (*NodeService) RrpcServiceClient 

func (s *NodeService) RrpcServiceClient() rgrpc.RgrpcServiceClient

func (*NodeService) SetToken 

func (s *NodeService) SetToken(ctx context.Context) context.Context

func (*NodeService) SlotServiceClient 

func (s *NodeService) SlotServiceClient() nodes.SlotServiceClient

func (*NodeService) SourceServiceClient 

func (s *NodeService) SourceServiceClient() nodes.SourceServiceClient

func (*NodeService) SyncServiceClient 

func (s *NodeService) SyncServiceClient() nodes.SyncServiceClient

func (*NodeService) TagServiceClient 

func (s *NodeService) TagServiceClient() nodes.TagServiceClient

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 {
	edges.UnimplementedSlotServiceServer
	// contains filtered or unexported fields
}

func (*SlotService) Clone 

func (s *SlotService) Clone(ctx context.Context, in *edges.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 *edges.SlotLinkRequest) (*pb.MyBool, error)

func (*SlotService) List 

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

func (*SlotService) Name 

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

func (*SlotService) Pull 

func (s *SlotService) Pull(ctx context.Context, in *edges.SlotPullRequest) (*edges.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) ViewByID 

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

func (*SlotService) ViewByName 

func (s *SlotService) ViewByName(ctx context.Context, name 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 {
	edges.UnimplementedSourceServiceServer
	// contains filtered or unexported fields
}

func (*SourceService) Clone 

func (s *SourceService) Clone(ctx context.Context, in *edges.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 *edges.SourceLinkRequest) (*pb.MyBool, error)

func (*SourceService) List 

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

func (*SourceService) Name 

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

func (*SourceService) Pull 

func (s *SourceService) Pull(ctx context.Context, in *edges.SourcePullRequest) (*edges.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) ViewByID 

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

func (*SourceService) ViewByName 

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

func (*SourceService) ViewFromCacheByID 

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

func (*SourceService) ViewFromCacheByName 

func (s *SourceService) ViewFromCacheByName(ctx context.Context, name 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) GetDeviceLink() int32

func (*StatusService) GetDeviceLinkValue 

func (s *StatusService) GetDeviceLinkValue() types.Option[cache.Value[int32]]
func (s *StatusService) GetLink(key string) int32

func (*StatusService) GetLinkValue 

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

type SyncOptions 

type SyncOptions struct {
	TokenRefresh time.Duration
	Link         time.Duration
	Interval     time.Duration
	Realtime     bool
}

type SyncService 

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

func (*SyncService) GetAttrUpdated 

func (s *SyncService) GetAttrUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetClassUpdated 

func (s *SyncService) GetClassUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetConstUpdated 

func (s *SyncService) GetConstUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetDeviceUpdated 

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

func (*SyncService) GetFnUpdated 

func (s *SyncService) GetFnUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetLogicUpdated 

func (s *SyncService) GetLogicUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetOptionUpdated 

func (s *SyncService) GetOptionUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetSlotUpdated 

func (s *SyncService) GetSlotUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetSourceUpdated 

func (s *SyncService) GetSourceUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetTagUpdated 

func (s *SyncService) GetTagUpdated(ctx context.Context, in *pb.MyEmpty) (*edges.SyncUpdated, error)

func (*SyncService) GetTagValueUpdated 

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

func (*SyncService) Notify 

func (s *SyncService) Notify(nt NotifyType) *Notify

func (*SyncService) SetAttrUpdated 

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

func (*SyncService) SetClassUpdated 

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

func (*SyncService) SetConstUpdated 

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

func (*SyncService) SetDeviceUpdated 

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

func (*SyncService) SetFnUpdated 

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

func (*SyncService) SetLogicUpdated 

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

func (*SyncService) SetOptionUpdated 

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

func (*SyncService) SetSlotUpdated 

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

func (*SyncService) SetSourceUpdated 

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

func (*SyncService) SetTagUpdated 

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

func (*SyncService) SetTagValueUpdated 

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

func (*SyncService) WaitDeviceUpdated 

func (s *SyncService) WaitDeviceUpdated(in *pb.MyEmpty,
	stream edges.SyncService_WaitDeviceUpdatedServer) error

func (*SyncService) WaitTagValueUpdated 

func (s *SyncService) WaitTagValueUpdated(in *pb.MyEmpty,
	stream edges.SyncService_WaitTagValueUpdatedServer) error

type TagService 

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

func (*TagService) Clone 

func (s *TagService) Clone(ctx context.Context, in *edges.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 *pb.Name) (*pb.TagNameValue, error)

func (*TagService) List 

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

func (*TagService) Name 

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

func (*TagService) Pull 

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

func (*TagService) PullValue 

func (s *TagService) PullValue(ctx context.Context, in *edges.TagPullValueRequest) (*edges.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 *pb.TagNameValue) (*pb.MyBool, error)

func (*TagService) SetValueByNameForce 

func (s *TagService) SetValueByNameForce(ctx context.Context, in *pb.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) ViewByID 

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

func (*TagService) ViewByName 

func (s *TagService) ViewByName(ctx context.Context, name 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) ViewFromCacheByID 

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

func (*TagService) ViewFromCacheByName 

func (s *TagService) ViewFromCacheByName(ctx context.Context, name 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 {
	edges.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 *edges.UserListRequest) (*edges.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 *edges.UserPullRequest) (*edges.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.