instance

package
v1.7.3-dev-20241006 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 18, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCHealthChecker 

type GRPCHealthChecker struct{}

func (*GRPCHealthChecker) IsRunning 

func (c *GRPCHealthChecker) IsRunning(address string) bool

func (*GRPCHealthChecker) WaitForRunning 

func (c *GRPCHealthChecker) WaitForRunning(address, name string, stopCh chan struct{}) bool

type HealthChecker 

type HealthChecker interface {
	IsRunning(address string) bool
	WaitForRunning(address, name string, stopCh chan struct{}) bool
}

type InstanceOps added in v1.6.0 

type InstanceOps interface {
	InstanceCreate(*rpc.InstanceCreateRequest) (*rpc.InstanceResponse, error)
	InstanceDelete(*rpc.InstanceDeleteRequest) (*rpc.InstanceResponse, error)
	InstanceGet(*rpc.InstanceGetRequest) (*rpc.InstanceResponse, error)
	InstanceList(map[string]*rpc.InstanceResponse) error
	InstanceReplace(*rpc.InstanceReplaceRequest) (*rpc.InstanceResponse, error)
	InstanceLog(*rpc.InstanceLogRequest, rpc.InstanceService_InstanceLogServer) error
	InstanceSuspend(*rpc.InstanceSuspendRequest) (*emptypb.Empty, error)
	InstanceResume(*rpc.InstanceResumeRequest) (*emptypb.Empty, error)
	InstanceSwitchOverTarget(*rpc.InstanceSwitchOverTargetRequest) (*emptypb.Empty, error)
	InstanceDeleteTarget(*rpc.InstanceDeleteTargetRequest) (*emptypb.Empty, error)

	LogSetLevel(context.Context, *rpc.LogSetLevelRequest) (*emptypb.Empty, error)
	LogSetFlags(context.Context, *rpc.LogSetFlagsRequest) (*emptypb.Empty, error)
	LogGetLevel(context.Context, *rpc.LogGetLevelRequest) (*rpc.LogGetLevelResponse, error)
	LogGetFlags(context.Context, *rpc.LogGetFlagsRequest) (*rpc.LogGetFlagsResponse, error)
}

type Server 

type Server struct {
	rpc.UnimplementedInstanceServiceServer

	HealthChecker HealthChecker
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(ctx context.Context, logsDir, processManagerServiceAddress, spdkServiceAddress string, v2DataEngineEnabled bool) (*Server, error)

func (*Server) InstanceCreate 

func (s *Server) InstanceCreate(ctx context.Context, req *rpc.InstanceCreateRequest) (*rpc.InstanceResponse, error)

func (*Server) InstanceDelete 

func (s *Server) InstanceDelete(ctx context.Context, req *rpc.InstanceDeleteRequest) (*rpc.InstanceResponse, error)

func (*Server) InstanceDeleteTarget added in v1.7.0 

func (s *Server) InstanceDeleteTarget(ctx context.Context, req *rpc.InstanceDeleteTargetRequest) (*emptypb.Empty, error)

func (*Server) InstanceGet 

func (s *Server) InstanceGet(ctx context.Context, req *rpc.InstanceGetRequest) (*rpc.InstanceResponse, error)

func (*Server) InstanceList 

func (s *Server) InstanceList(ctx context.Context, req *emptypb.Empty) (*rpc.InstanceListResponse, error)

func (*Server) InstanceLog 

func (s *Server) InstanceLog(req *rpc.InstanceLogRequest, srv rpc.InstanceService_InstanceLogServer) error

func (*Server) InstanceReplace 

func (s *Server) InstanceReplace(ctx context.Context, req *rpc.InstanceReplaceRequest) (*rpc.InstanceResponse, error)

func (*Server) InstanceResume added in v1.7.0 

func (s *Server) InstanceResume(ctx context.Context, req *rpc.InstanceResumeRequest) (*emptypb.Empty, error)

func (*Server) InstanceSuspend added in v1.7.0 

func (s *Server) InstanceSuspend(ctx context.Context, req *rpc.InstanceSuspendRequest) (*emptypb.Empty, error)

func (*Server) InstanceSwitchOverTarget added in v1.7.0 

func (s *Server) InstanceSwitchOverTarget(ctx context.Context, req *rpc.InstanceSwitchOverTargetRequest) (*emptypb.Empty, error)

func (*Server) InstanceWatch 

func (s *Server) InstanceWatch(req *emptypb.Empty, srv rpc.InstanceService_InstanceWatchServer) error

func (*Server) LogGetFlags added in v1.7.0 

func (s *Server) LogGetFlags(ctx context.Context, req *rpc.LogGetFlagsRequest) (resp *rpc.LogGetFlagsResponse, err error)

func (*Server) LogGetLevel added in v1.7.0 

func (s *Server) LogGetLevel(ctx context.Context, req *rpc.LogGetLevelRequest) (resp *rpc.LogGetLevelResponse, err error)

func (*Server) LogSetFlags added in v1.7.0 

func (s *Server) LogSetFlags(ctx context.Context, req *rpc.LogSetFlagsRequest) (resp *emptypb.Empty, err error)

func (*Server) LogSetLevel added in v1.7.0 

func (s *Server) LogSetLevel(ctx context.Context, req *rpc.LogSetLevelRequest) (resp *emptypb.Empty, err error)

func (*Server) VersionGet 

func (s *Server) VersionGet(ctx context.Context, req *emptypb.Empty) (*rpc.VersionResponse, error)

type V1DataEngineInstanceOps added in v1.6.0 

type V1DataEngineInstanceOps struct {
	// contains filtered or unexported fields
}

func (V1DataEngineInstanceOps) InstanceCreate added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceCreate(req *rpc.InstanceCreateRequest) (*rpc.InstanceResponse, error)

func (V1DataEngineInstanceOps) InstanceDelete added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceDelete(req *rpc.InstanceDeleteRequest) (*rpc.InstanceResponse, error)

func (V1DataEngineInstanceOps) InstanceDeleteTarget added in v1.7.0 

func (ops V1DataEngineInstanceOps) InstanceDeleteTarget(req *rpc.InstanceDeleteTargetRequest) (*emptypb.Empty, error)

func (V1DataEngineInstanceOps) InstanceGet added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceGet(req *rpc.InstanceGetRequest) (*rpc.InstanceResponse, error)

func (V1DataEngineInstanceOps) InstanceList added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceList(instances map[string]*rpc.InstanceResponse) error

func (V1DataEngineInstanceOps) InstanceLog added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceLog(req *rpc.InstanceLogRequest, srv rpc.InstanceService_InstanceLogServer) error

func (V1DataEngineInstanceOps) InstanceReplace added in v1.6.0 

func (ops V1DataEngineInstanceOps) InstanceReplace(req *rpc.InstanceReplaceRequest) (*rpc.InstanceResponse, error)

func (V1DataEngineInstanceOps) InstanceResume added in v1.7.0 

func (ops V1DataEngineInstanceOps) InstanceResume(req *rpc.InstanceResumeRequest) (*emptypb.Empty, error)

func (V1DataEngineInstanceOps) InstanceSuspend added in v1.7.0 

func (ops V1DataEngineInstanceOps) InstanceSuspend(req *rpc.InstanceSuspendRequest) (*emptypb.Empty, error)

func (V1DataEngineInstanceOps) InstanceSwitchOverTarget added in v1.7.0 

func (ops V1DataEngineInstanceOps) InstanceSwitchOverTarget(req *rpc.InstanceSwitchOverTargetRequest) (*emptypb.Empty, error)

func (V1DataEngineInstanceOps) LogGetFlags added in v1.7.0 

func (ops V1DataEngineInstanceOps) LogGetFlags(ctx context.Context, req *rpc.LogGetFlagsRequest) (resp *rpc.LogGetFlagsResponse, err error)

func (V1DataEngineInstanceOps) LogGetLevel added in v1.7.0 

func (ops V1DataEngineInstanceOps) LogGetLevel(ctx context.Context, req *rpc.LogGetLevelRequest) (resp *rpc.LogGetLevelResponse, err error)

func (V1DataEngineInstanceOps) LogSetFlags added in v1.7.0 

func (ops V1DataEngineInstanceOps) LogSetFlags(ctx context.Context, req *rpc.LogSetFlagsRequest) (resp *emptypb.Empty, err error)

func (V1DataEngineInstanceOps) LogSetLevel added in v1.7.0 

func (ops V1DataEngineInstanceOps) LogSetLevel(ctx context.Context, req *rpc.LogSetLevelRequest) (resp *emptypb.Empty, err error)

type V2DataEngineInstanceOps added in v1.6.0 

type V2DataEngineInstanceOps struct {
	// contains filtered or unexported fields
}

func (V2DataEngineInstanceOps) InstanceCreate added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceCreate(req *rpc.InstanceCreateRequest) (*rpc.InstanceResponse, error)

func (V2DataEngineInstanceOps) InstanceDelete added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceDelete(req *rpc.InstanceDeleteRequest) (*rpc.InstanceResponse, error)

func (V2DataEngineInstanceOps) InstanceDeleteTarget added in v1.7.0 

func (ops V2DataEngineInstanceOps) InstanceDeleteTarget(req *rpc.InstanceDeleteTargetRequest) (*emptypb.Empty, error)

func (V2DataEngineInstanceOps) InstanceGet added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceGet(req *rpc.InstanceGetRequest) (*rpc.InstanceResponse, error)

func (V2DataEngineInstanceOps) InstanceList added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceList(instances map[string]*rpc.InstanceResponse) error

func (V2DataEngineInstanceOps) InstanceLog added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceLog(req *rpc.InstanceLogRequest, srv rpc.InstanceService_InstanceLogServer) error

func (V2DataEngineInstanceOps) InstanceReplace added in v1.6.0 

func (ops V2DataEngineInstanceOps) InstanceReplace(req *rpc.InstanceReplaceRequest) (*rpc.InstanceResponse, error)

func (V2DataEngineInstanceOps) InstanceResume added in v1.7.0 

func (ops V2DataEngineInstanceOps) InstanceResume(req *rpc.InstanceResumeRequest) (*emptypb.Empty, error)

func (V2DataEngineInstanceOps) InstanceSuspend added in v1.7.0 

func (ops V2DataEngineInstanceOps) InstanceSuspend(req *rpc.InstanceSuspendRequest) (*emptypb.Empty, error)

func (V2DataEngineInstanceOps) InstanceSwitchOverTarget added in v1.7.0 

func (ops V2DataEngineInstanceOps) InstanceSwitchOverTarget(req *rpc.InstanceSwitchOverTargetRequest) (*emptypb.Empty, error)

func (V2DataEngineInstanceOps) LogGetFlags added in v1.7.0 

func (ops V2DataEngineInstanceOps) LogGetFlags(ctx context.Context, req *rpc.LogGetFlagsRequest) (resp *rpc.LogGetFlagsResponse, err error)

func (V2DataEngineInstanceOps) LogGetLevel added in v1.7.0 

func (ops V2DataEngineInstanceOps) LogGetLevel(ctx context.Context, req *rpc.LogGetLevelRequest) (resp *rpc.LogGetLevelResponse, err error)

func (V2DataEngineInstanceOps) LogSetFlags added in v1.7.0 

func (ops V2DataEngineInstanceOps) LogSetFlags(ctx context.Context, req *rpc.LogSetFlagsRequest) (resp *emptypb.Empty, err error)

func (V2DataEngineInstanceOps) LogSetLevel added in v1.7.0 

func (ops V2DataEngineInstanceOps) LogSetLevel(ctx context.Context, req *rpc.LogSetLevelRequest) (resp *emptypb.Empty, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.