instance

package
v1.6.1 Latest Latest
Warning

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

 Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 17 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
}

type Server 

type Server struct {
	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) 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) InstanceWatch 

func (s *Server) InstanceWatch(req *emptypb.Empty, srv rpc.InstanceService_InstanceWatchServer) 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) 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)

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) 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)

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.