instance

package
v1.6.3-dev-20240825 Latest Latest
Warning

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

Go to latest
Published: Jul 25, 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 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 (*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 (V1DataEngineInstanceOps) InstanceDelete added in v1.6.0

func (V1DataEngineInstanceOps) InstanceGet added in v1.6.0

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 (V1DataEngineInstanceOps) InstanceReplace added in v1.6.0

type V2DataEngineInstanceOps added in v1.6.0

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

func (V2DataEngineInstanceOps) InstanceCreate added in v1.6.0

func (V2DataEngineInstanceOps) InstanceDelete added in v1.6.0

func (V2DataEngineInstanceOps) InstanceGet added in v1.6.0

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 (V2DataEngineInstanceOps) InstanceReplace added in v1.6.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL