eventstream

package

v1.10.0-rc3 Latest Latest Go to latest Published: May 9, 2026 License: AGPL-3.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/TeoSlayer/pilotprotocol

Links

Open Source Insights

Documentation ¶

Index ¶

func WriteEvent(w io.Writer, e *Event) error
type Client
type Event
- func ReadEvent(r io.Reader) (*Event, error)
type Server
type Service
- func NewService() *Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func WriteEvent ¶

func WriteEvent(w io.Writer, e *Event) error

Wire helpers.

Types ¶

type Client ¶

type Client = internales.Client

Type aliases.

type Event ¶

type Event = internales.Event

Type aliases.

func ReadEvent ¶

func ReadEvent(r io.Reader) (*Event, error)

type Server ¶

type Server = internales.Server

Type aliases.

type Service ¶

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

Service is the L11 plugin adapter. cmd/daemon/main.go (L12) and cmd/pilotctl _daemon-run construct it via NewService and register via daemon.RegisterPlugin.

func NewService ¶

func NewService() *Service

NewService returns a Service ready for daemon.RegisterPlugin.

func (*Service) Name ¶

func (s *Service) Name() string

func (*Service) Order ¶

func (s *Service) Order() int

Order: 120 — after the trust subsystem (50) and other application services that may want to publish before the broker is up.

func (*Service) Start ¶

func (s *Service) Start(ctx context.Context, deps coreapi.Deps) error

func (*Service) Stop ¶

func (s *Service) Stop(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL