plugisservice

type Endpoint struct {
	Name       string   `json:"name"`
	Subject    string   `json:"subject"`
	QueueGroup string   `json:"queue_group"`
	Metadata   Metadata `json:"metadata,omitempty"`
}

type Event[T any] struct {
	Type string `json:"type,omitempty"`
	Data T      `json:"data,omitempty"`
}

type Metadata map[string]string

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

type PlugisIntf interface {
	SetLogger(*slog.Logger)
	Logger() *slog.Logger
	SetNats(*nats.Conn)
	Nats() *nats.Conn
	SetPrefix(prefix string)
	Prefix() string
	Publish(topic string, payload []byte) error
	Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)
	RequestMany(ctx context.Context, subject string, data []byte, opts ...natsext.RequestManyOpt) (iter.Seq2[*nats.Msg, error], error)
	GetServices(ctx context.Context) ([]ServiceInfo, error)
	StartService(svc PlugisServiceIntf) (*nats_service.NatsService, error)
	VariableSet(name string, value any, varType string) error
	VariableUnset(name string) error
}

type PlugisServiceIntf interface {
	Run(ctx context.Context) error
	Name() string
	Description() string
	Version() string
	Metadata() Metadata
	PlugisIntf
}

type ServiceInfo struct {
	Name        string     `json:"name"`
	Id          string     `json:"id"`
	Description string     `json:"description"`
	Version     string     `json:"version"`
	Type        string     `json:"type"`
	Metadata    Metadata   `json:"metadata"` // contains at least ServiceMetadata fields
	Endpoints   []Endpoint `json:"endpoints"`
}

type ServiceMetadata struct {
	Hostname  string `json:"hostname"`
	MAC       string `json:"mac"`
	Platform  string `json:"platform"`
	Prefix    string `json:"prefix"`
	StartedAt string `json:"started_at"`
}

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