internal

Jan 23, 2026

Changes in this version

+ var MAX_PROCESSORS = 20

+ type OrcaCoreServer struct

+ func NewServer(ctx context.Context, platform dlyr.Platform, connStr string) (*OrcaCoreServer, error)

+ func (o *OrcaCoreServer) EmitWindow(ctx context.Context, window *pb.Window) (*pb.WindowEmitStatus, error)

+ func (o *OrcaCoreServer) Expose(ctx context.Context, settings *pb.ExposeSettings) (*pb.InternalState, error)

+ func (o *OrcaCoreServer) RegisterProcessor(ctx context.Context, proc *pb.ProcessorRegistration) (*pb.Status, error)