Versions in this module Expand all Collapse all v0 v0.10.0 Nov 4, 2022 Changes in this version + func DeserializeContext(context string) map[string]string + func DeserializeIPs(ips string) []string + func DeserializeStatus(status int32) nspAPI.Target_Status + func DeserializeType(t int32) nspAPI.Target_Type + func GetTargetID(target *nspAPI.Target) string + func New(datastore string) (types.TargetRegistry, error) + func SQLTConduitToNSPConduit(conduit *Conduit) *nspAPI.Conduit + func SQLTStreamToNSPStream(stream *Stream) *nspAPI.Stream + func SQLTTrenchToNSPTrench(trench *Trench) *nspAPI.Trench + func SQLTargetToNSPTarget(target *Target) *nspAPI.Target + func SerializeContext(context map[string]string) string + func SerializeIPs(ips []string) string + func SerializeStatus(status nspAPI.Target_Status) int32 + func SerializeType(t nspAPI.Target_Type) int32 + type Conduit struct + Name string + Trench Trench + TrenchName string + func NSPTConduitToSQLConduit(conduit *nspAPI.Conduit) Conduit + type Stream struct + Conduit Conduit + ConduitName string + Name string + func NSPTStreamToSQLStream(stream *nspAPI.Stream) Stream + type Target struct + Context string + ID string + Ips string + Status int32 + Stream Stream + StreamName string + Type int32 + func NSPTargetToSQLTarget(target *nspAPI.Target) *Target + type TargetRegistrySQLite struct + DB *gorm.DB + func (trsql *TargetRegistrySQLite) Get(ctx context.Context, target *nspAPI.Target) ([]*nspAPI.Target, error) + func (trsql *TargetRegistrySQLite) Remove(ctx context.Context, target *nspAPI.Target) error + func (trsql *TargetRegistrySQLite) Set(ctx context.Context, target *nspAPI.Target) error + func (trsql *TargetRegistrySQLite) Watch(ctx context.Context, target *nspAPI.Target) (types.TargetWatcher, error) + type Trench struct + Name string + func NSPTTrenchToSQLTrench(trench *nspAPI.Trench) Trench