Documentation
¶
Index ¶
- Variables
- type OrcaCoreServer
- 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)
Constants ¶
This section is empty.
Variables ¶
View Source
var (
MAX_PROCESSORS = 20
)
Functions ¶
This section is empty.
Types ¶
type OrcaCoreServer ¶
type OrcaCoreServer struct {
pb.UnimplementedOrcaCoreServer
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer( ctx context.Context, platform dlyr.Platform, connStr string, ) (*OrcaCoreServer, error)
NewServer produces a new ORCA gRPC server
func (*OrcaCoreServer) EmitWindow ¶
func (o *OrcaCoreServer) EmitWindow( ctx context.Context, window *pb.Window, ) (*pb.WindowEmitStatus, error)
func (*OrcaCoreServer) Expose ¶
func (o *OrcaCoreServer) Expose( ctx context.Context, settings *pb.ExposeSettings, ) (*pb.InternalState, error)
func (*OrcaCoreServer) RegisterProcessor ¶
func (o *OrcaCoreServer) RegisterProcessor( ctx context.Context, proc *pb.ProcessorRegistration, ) (*pb.Status, error)
--------------------------- gRPC Services --------------------------- -------------------------- Core Operations -------------------------- Register a processor with orca-core. Called when a processor startsup.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package datalayers provides a factory function for generating a datalayer client.
|
Package datalayers provides a factory function for generating a datalayer client. |
Click to show internal directories.
Click to hide internal directories.