Documentation ¶
Index ¶
- type CommandService
- func (cs *CommandService) CreateConnection(ctx context.Context, request *mpi.CreateConnectionRequest) (*mpi.CreateConnectionResponse, error)
- func (cs *CommandService) StartServer(listener net.Listener)
- func (cs *CommandService) Subscribe(in mpi.CommandService_SubscribeServer) error
- func (cs *CommandService) UpdateDataPlaneHealth(_ context.Context, request *mpi.UpdateDataPlaneHealthRequest) (*mpi.UpdateDataPlaneHealthResponse, error)
- func (cs *CommandService) UpdateDataPlaneStatus(_ context.Context, request *mpi.UpdateDataPlaneStatusRequest) (*mpi.UpdateDataPlaneStatusResponse, error)
- type FileService
- func (mgs *FileService) GetFile(_ context.Context, request *v1.GetFileRequest) (*v1.GetFileResponse, error)
- func (mgs *FileService) GetOverview(_ context.Context, request *v1.GetOverviewRequest) (*v1.GetOverviewResponse, error)
- func (mgs *FileService) UpdateFile(_ context.Context, request *v1.UpdateFileRequest) (*v1.UpdateFileResponse, error)
- func (mgs *FileService) UpdateOverview(_ context.Context, request *v1.UpdateOverviewRequest) (*v1.UpdateOverviewResponse, error)
- type MockManagementServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandService ¶
type CommandService struct { mpi.UnimplementedCommandServiceServer // contains filtered or unexported fields }
func NewCommandService ¶
func NewCommandService(requestChan chan *mpi.ManagementPlaneRequest, configDirectory string) *CommandService
func (*CommandService) CreateConnection ¶
func (cs *CommandService) CreateConnection( ctx context.Context, request *mpi.CreateConnectionRequest) ( *mpi.CreateConnectionResponse, error, )
func (*CommandService) StartServer ¶
func (cs *CommandService) StartServer(listener net.Listener)
func (*CommandService) Subscribe ¶
func (cs *CommandService) Subscribe(in mpi.CommandService_SubscribeServer) error
func (*CommandService) UpdateDataPlaneHealth ¶
func (cs *CommandService) UpdateDataPlaneHealth( _ context.Context, request *mpi.UpdateDataPlaneHealthRequest) ( *mpi.UpdateDataPlaneHealthResponse, error, )
func (*CommandService) UpdateDataPlaneStatus ¶
func (cs *CommandService) UpdateDataPlaneStatus( _ context.Context, request *mpi.UpdateDataPlaneStatusRequest) ( *mpi.UpdateDataPlaneStatusResponse, error, )
type FileService ¶
type FileService struct { v1.UnimplementedFileServiceServer // contains filtered or unexported fields }
func NewFileService ¶
func NewFileService(configDirectory string, requestChan chan *v1.ManagementPlaneRequest) *FileService
func (*FileService) GetFile ¶
func (mgs *FileService) GetFile( _ context.Context, request *v1.GetFileRequest, ) (*v1.GetFileResponse, error)
func (*FileService) GetOverview ¶
func (mgs *FileService) GetOverview( _ context.Context, request *v1.GetOverviewRequest, ) (*v1.GetOverviewResponse, error)
func (*FileService) UpdateFile ¶
func (mgs *FileService) UpdateFile( _ context.Context, request *v1.UpdateFileRequest, ) (*v1.UpdateFileResponse, error)
func (*FileService) UpdateOverview ¶
func (mgs *FileService) UpdateOverview( _ context.Context, request *v1.UpdateOverviewRequest, ) (*v1.UpdateOverviewResponse, error)
nolint: unparam
type MockManagementServer ¶
type MockManagementServer struct { CommandService *CommandService FileService *FileService GrpcServer *grpc.Server }
func NewMockManagementServer ¶
func (*MockManagementServer) Stop ¶
func (ms *MockManagementServer) Stop()
Source Files ¶
Click to show internal directories.
Click to hide internal directories.