grpc

package
v3.0.0-...-483f4b8 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CommandService 

type CommandService struct {
	v1.UnimplementedCommandServiceServer
	// contains filtered or unexported fields
}

func NewCommandService 

func NewCommandService() *CommandService

func (*CommandService) CreateConnection 

func (cs *CommandService) CreateConnection(
	ctx context.Context,
	request *v1.CreateConnectionRequest) (
	*v1.CreateConnectionResponse,
	error,
)

func (*CommandService) StartServer 

func (cs *CommandService) StartServer(listener net.Listener)

func (*CommandService) Subscribe 

func (cs *CommandService) Subscribe(in v1.CommandService_SubscribeServer) error

func (*CommandService) UpdateDataPlaneHealth 

func (cs *CommandService) UpdateDataPlaneHealth(
	_ context.Context,
	request *v1.UpdateDataPlaneHealthRequest) (
	*v1.UpdateDataPlaneHealthResponse,
	error,
)

func (*CommandService) UpdateDataPlaneStatus 

func (cs *CommandService) UpdateDataPlaneStatus(
	_ context.Context,
	request *v1.UpdateDataPlaneStatusRequest) (
	*v1.UpdateDataPlaneStatusResponse,
	error,
)

type FileService 

type FileService struct {
	v1.UnimplementedFileServiceServer
	// contains filtered or unexported fields
}

func NewFileService 

func NewFileService(configDirectory string) (*FileService, error)

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 NewMockManagementServer(
	apiAddress string,
	agentConfig *config.Config,
	configDirectory *string,
) (*MockManagementServer, error)

func (*MockManagementServer) Stop 

func (ms *MockManagementServer) Stop()

Source Files

View all Source files

Directories

Path Synopsis

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.