Documentation ¶
Index ¶
- type Server
- func (s *Server) QueryEndpoints(ctx context.Context, _ *emptypb.Empty) (*master_pb.QueryResponse, error)
- func (s *Server) RegisterVolume(ctx context.Context, in *master_pb.RegisterVolumeRequest) (*master_pb.RegisterVolumeResponse, error)
- func (s *Server) Run(port int) error
- func (s *Server) SendHeartbeat(ctx context.Context, in *master_pb.HeartbeatRequest) (*emptypb.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct { master_pb.UnimplementedMasterServiceServer // contains filtered or unexported fields }
func (*Server) QueryEndpoints ¶
func (*Server) RegisterVolume ¶
func (s *Server) RegisterVolume(ctx context.Context, in *master_pb.RegisterVolumeRequest) (*master_pb.RegisterVolumeResponse, error)
func (*Server) SendHeartbeat ¶
Click to show internal directories.
Click to hide internal directories.