Documentation ¶
Index ¶
- type Authenticator
- type NoAuthenticator
- type Server
- func (s *Server) PushFinishedSamples(streamingSvc __.StreamingService_PushFinishedSamplesServer) error
- func (s *Server) PushNodeInfo(ctx context.Context, nodeInfo *__.NodeInfo) (*__.PushInfoResponse, error)
- func (s *Server) RequestAlloc(ctx context.Context, alloc *__.Alloc) (*__.AllocStatus, error)
- func (s *Server) ScheduleClientAllocs(streamingSvc __.StreamingService_ScheduleClientAllocsServer) error
- func (s *Server) Serve(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Authenticator ¶
type Authenticator interface { AuthUnary(context.Context, interface{}, *grpc.UnaryServerInfo, grpc.UnaryHandler) (interface{}, error) AuthStreaming(interface{}, grpc.ServerStream, *grpc.StreamServerInfo, grpc.StreamHandler) error }
type NoAuthenticator ¶
type NoAuthenticator struct{}
func (NoAuthenticator) AuthStreaming ¶
func (na NoAuthenticator) AuthStreaming( srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler, ) error
func (NoAuthenticator) AuthUnary ¶
func (na NoAuthenticator) AuthUnary( ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (interface{}, error)
type Server ¶
type Server struct { Authenticator Log *logrus.Logger __.UnimplementedStreamingServiceServer }
func (*Server) PushFinishedSamples ¶
func (s *Server) PushFinishedSamples(streamingSvc __.StreamingService_PushFinishedSamplesServer) error
func (*Server) PushNodeInfo ¶
func (*Server) RequestAlloc ¶
func (*Server) ScheduleClientAllocs ¶
func (s *Server) ScheduleClientAllocs( streamingSvc __.StreamingService_ScheduleClientAllocsServer, ) error
Click to show internal directories.
Click to hide internal directories.