v1

package
v0.0.0-...-ec0eb22 Latest Latest
Warning

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

 Go to latest Published: Apr 5, 2021 License: MIT Imports: 11 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StatusResponse_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "FAIL",
	}
	StatusResponse_Status_value = map[string]int32{
		"SUCCESS": 0,
		"FAIL":    1,
	}
)

Enum value maps for StatusResponse_Status.

View Source 
var CPU_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.CPU",
	HandlerType: (*CPUServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _CPU_Start_Handler,
		},
		{
			MethodName: "Recover",
			Handler:    _CPU_Recover_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

CPU_ServiceDesc is the grpc.ServiceDesc for CPU service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Docker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Docker",
	HandlerType: (*DockerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Kill",
			Handler:    _Docker_Kill_Handler,
		},
		{
			MethodName: "Recover",
			Handler:    _Docker_Recover_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

Docker_ServiceDesc is the grpc.ServiceDesc for Docker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_manager_proto protoreflect.FileDescriptor
View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}
View Source 
var Health_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Health",
	HandlerType: (*HealthServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Check",
			Handler:    _Health_Check_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _Health_Watch_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "healthcheck.proto",
}

Health_ServiceDesc is the grpc.ServiceDesc for Health service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Network_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Network",
	HandlerType: (*NetworkServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _Network_Start_Handler,
		},
		{
			MethodName: "Recover",
			Handler:    _Network_Recover_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

Network_ServiceDesc is the grpc.ServiceDesc for Network service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Server_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Server",
	HandlerType: (*ServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Kill",
			Handler:    _Server_Kill_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

Server_ServiceDesc is the grpc.ServiceDesc for Server service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Kill",
			Handler:    _Service_Kill_Handler,
		},
		{
			MethodName: "Recover",
			Handler:    _Service_Recover_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "manager.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCPUServer 

func RegisterCPUServer(s grpc.ServiceRegistrar, srv CPUServer)

func RegisterDockerServer 

func RegisterDockerServer(s grpc.ServiceRegistrar, srv DockerServer)

func RegisterHealthServer 

func RegisterHealthServer(s grpc.ServiceRegistrar, srv HealthServer)

func RegisterNetworkServer 

func RegisterNetworkServer(s grpc.ServiceRegistrar, srv NetworkServer)

func RegisterServerServer 

func RegisterServerServer(s grpc.ServiceRegistrar, srv ServerServer)

func RegisterServiceServer 

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type CPUClient 

type CPUClient interface {
	Start(ctx context.Context, in *CPURequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Recover(ctx context.Context, in *CPURequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

CPUClient is the client API for CPU service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCPUClient 

func NewCPUClient(cc grpc.ClientConnInterface) CPUClient

type CPURequest 

type CPURequest struct {
	Percentage int32 `protobuf:"varint,1,opt,name=percentage,proto3" json:"percentage,omitempty"`
	// contains filtered or unexported fields
}

func (*CPURequest) Descriptor deprecated 

func (*CPURequest) Descriptor() ([]byte, []int)

Deprecated: Use CPURequest.ProtoReflect.Descriptor instead.

func (*CPURequest) GetPercentage 

func (x *CPURequest) GetPercentage() int32

func (*CPURequest) ProtoMessage 

func (*CPURequest) ProtoMessage()

func (*CPURequest) ProtoReflect 

func (x *CPURequest) ProtoReflect() protoreflect.Message

func (*CPURequest) Reset 

func (x *CPURequest) Reset()

func (*CPURequest) String 

func (x *CPURequest) String() string

type CPUServer 

type CPUServer interface {
	Start(context.Context, *CPURequest) (*StatusResponse, error)
	Recover(context.Context, *CPURequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

CPUServer is the server API for CPU service. All implementations must embed UnimplementedCPUServer for forward compatibility

type DockerClient 

type DockerClient interface {
	Kill(ctx context.Context, in *DockerRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Recover(ctx context.Context, in *DockerRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

DockerClient is the client API for Docker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDockerClient 

func NewDockerClient(cc grpc.ClientConnInterface) DockerClient

type DockerRequest 

type DockerRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DockerRequest) Descriptor deprecated 

func (*DockerRequest) Descriptor() ([]byte, []int)

Deprecated: Use DockerRequest.ProtoReflect.Descriptor instead.

func (*DockerRequest) GetName 

func (x *DockerRequest) GetName() string

func (*DockerRequest) ProtoMessage 

func (*DockerRequest) ProtoMessage()

func (*DockerRequest) ProtoReflect 

func (x *DockerRequest) ProtoReflect() protoreflect.Message

func (*DockerRequest) Reset 

func (x *DockerRequest) Reset()

func (*DockerRequest) String 

func (x *DockerRequest) String() string

type DockerServer 

type DockerServer interface {
	Kill(context.Context, *DockerRequest) (*StatusResponse, error)
	Recover(context.Context, *DockerRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

DockerServer is the server API for Docker service. All implementations must embed UnimplementedDockerServer for forward compatibility

type HealthCheckRequest 

type HealthCheckRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckRequest) Descriptor 

func (*HealthCheckRequest) Descriptor() ([]byte, []int)

func (*HealthCheckRequest) GetService 

func (m *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckRequest) XXX_Merge 

func (m *HealthCheckRequest) XXX_Merge(src proto.Message)

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status               HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=proto.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

func (*HealthCheckResponse) Descriptor() ([]byte, []int)

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResponse) XXX_Merge 

func (m *HealthCheckResponse) XXX_Merge(src proto.Message)

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int)

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type HealthClient 

type HealthClient interface {
	Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error)
}

HealthClient is the client API for Health service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHealthClient 

func NewHealthClient(cc grpc.ClientConnInterface) HealthClient

type HealthServer 

type HealthServer interface {
	Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	Watch(*HealthCheckRequest, Health_WatchServer) error
	// contains filtered or unexported methods
}

HealthServer is the server API for Health service. All implementations must embed UnimplementedHealthServer for forward compatibility

type Health_WatchClient 

type Health_WatchClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type Health_WatchServer 

type Health_WatchServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

type NetworkClient 

type NetworkClient interface {
	Start(ctx context.Context, in *NetworkRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Recover(ctx context.Context, in *NetworkRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

NetworkClient is the client API for Network service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNetworkClient 

func NewNetworkClient(cc grpc.ClientConnInterface) NetworkClient

type NetworkRequest 

type NetworkRequest struct {
	Device        string  `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Latency       uint32  `protobuf:"varint,2,opt,name=latency,proto3" json:"latency,omitempty"`
	DelayCorr     float32 `protobuf:"fixed32,3,opt,name=delayCorr,proto3" json:"delayCorr,omitempty"`
	Limit         uint32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Loss          float32 `protobuf:"fixed32,5,opt,name=loss,proto3" json:"loss,omitempty"`
	LossCorr      float32 `protobuf:"fixed32,6,opt,name=lossCorr,proto3" json:"lossCorr,omitempty"`
	Gap           uint32  `protobuf:"varint,7,opt,name=gap,proto3" json:"gap,omitempty"`
	Duplicate     float32 `protobuf:"fixed32,8,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	DuplicateCorr float32 `protobuf:"fixed32,9,opt,name=duplicateCorr,proto3" json:"duplicateCorr,omitempty"`
	Jitter        uint32  `protobuf:"varint,10,opt,name=jitter,proto3" json:"jitter,omitempty"`
	ReorderProb   float32 `protobuf:"fixed32,11,opt,name=reorderProb,proto3" json:"reorderProb,omitempty"`
	ReorderCorr   float32 `protobuf:"fixed32,12,opt,name=reorderCorr,proto3" json:"reorderCorr,omitempty"`
	CorruptProb   float32 `protobuf:"fixed32,13,opt,name=corruptProb,proto3" json:"corruptProb,omitempty"`
	CorruptCorr   float32 `protobuf:"fixed32,14,opt,name=corruptCorr,proto3" json:"corruptCorr,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkRequest) Descriptor deprecated 

func (*NetworkRequest) Descriptor() ([]byte, []int)

Deprecated: Use NetworkRequest.ProtoReflect.Descriptor instead.

func (*NetworkRequest) GetCorruptCorr 

func (x *NetworkRequest) GetCorruptCorr() float32

func (*NetworkRequest) GetCorruptProb 

func (x *NetworkRequest) GetCorruptProb() float32

func (*NetworkRequest) GetDelayCorr 

func (x *NetworkRequest) GetDelayCorr() float32

func (*NetworkRequest) GetDevice 

func (x *NetworkRequest) GetDevice() string

func (*NetworkRequest) GetDuplicate 

func (x *NetworkRequest) GetDuplicate() float32

func (*NetworkRequest) GetDuplicateCorr 

func (x *NetworkRequest) GetDuplicateCorr() float32

func (*NetworkRequest) GetGap 

func (x *NetworkRequest) GetGap() uint32

func (*NetworkRequest) GetJitter 

func (x *NetworkRequest) GetJitter() uint32

func (*NetworkRequest) GetLatency 

func (x *NetworkRequest) GetLatency() uint32

func (*NetworkRequest) GetLimit 

func (x *NetworkRequest) GetLimit() uint32

func (*NetworkRequest) GetLoss 

func (x *NetworkRequest) GetLoss() float32

func (*NetworkRequest) GetLossCorr 

func (x *NetworkRequest) GetLossCorr() float32

func (*NetworkRequest) GetReorderCorr 

func (x *NetworkRequest) GetReorderCorr() float32

func (*NetworkRequest) GetReorderProb 

func (x *NetworkRequest) GetReorderProb() float32

func (*NetworkRequest) ProtoMessage 

func (*NetworkRequest) ProtoMessage()

func (*NetworkRequest) ProtoReflect 

func (x *NetworkRequest) ProtoReflect() protoreflect.Message

func (*NetworkRequest) Reset 

func (x *NetworkRequest) Reset()

func (*NetworkRequest) String 

func (x *NetworkRequest) String() string

type NetworkServer 

type NetworkServer interface {
	Start(context.Context, *NetworkRequest) (*StatusResponse, error)
	Recover(context.Context, *NetworkRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

NetworkServer is the server API for Network service. All implementations must embed UnimplementedNetworkServer for forward compatibility

type ServerClient 

type ServerClient interface {
	Kill(ctx context.Context, in *ServerRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

ServerClient is the client API for Server service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewServerClient 

func NewServerClient(cc grpc.ClientConnInterface) ServerClient

type ServerRequest 

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

func (*ServerRequest) Descriptor deprecated 

func (*ServerRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServerRequest.ProtoReflect.Descriptor instead.

func (*ServerRequest) ProtoMessage 

func (*ServerRequest) ProtoMessage()

func (*ServerRequest) ProtoReflect 

func (x *ServerRequest) ProtoReflect() protoreflect.Message

func (*ServerRequest) Reset 

func (x *ServerRequest) Reset()

func (*ServerRequest) String 

func (x *ServerRequest) String() string

type ServerServer 

type ServerServer interface {
	Kill(context.Context, *ServerRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

ServerServer is the server API for Server service. All implementations must embed UnimplementedServerServer for forward compatibility

type ServiceClient 

type ServiceClient interface {
	Kill(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Recover(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*StatusResponse, error)
}

ServiceClient is the client API for Service service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewServiceClient 

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceRequest 

type ServiceRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceRequest) Descriptor deprecated 

func (*ServiceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ServiceRequest.ProtoReflect.Descriptor instead.

func (*ServiceRequest) GetName 

func (x *ServiceRequest) GetName() string

func (*ServiceRequest) ProtoMessage 

func (*ServiceRequest) ProtoMessage()

func (*ServiceRequest) ProtoReflect 

func (x *ServiceRequest) ProtoReflect() protoreflect.Message

func (*ServiceRequest) Reset 

func (x *ServiceRequest) Reset()

func (*ServiceRequest) String 

func (x *ServiceRequest) String() string

type ServiceServer 

type ServiceServer interface {
	Kill(context.Context, *ServiceRequest) (*StatusResponse, error)
	Recover(context.Context, *ServiceRequest) (*StatusResponse, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type StatusResponse 

type StatusResponse struct {
	Status  StatusResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=v1.StatusResponse_Status" json:"status,omitempty"`
	Message string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

func (*StatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMessage 

func (x *StatusResponse) GetMessage() string

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() StatusResponse_Status

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

func (x *StatusResponse) ProtoReflect() protoreflect.Message

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_Status 

type StatusResponse_Status int32
const (
	StatusResponse_SUCCESS StatusResponse_Status = 0
	StatusResponse_FAIL    StatusResponse_Status = 1
)

func (StatusResponse_Status) Descriptor 

func (StatusResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (StatusResponse_Status) Enum 

func (x StatusResponse_Status) Enum() *StatusResponse_Status

func (StatusResponse_Status) EnumDescriptor deprecated 

func (StatusResponse_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use StatusResponse_Status.Descriptor instead.

func (StatusResponse_Status) Number 

func (x StatusResponse_Status) Number() protoreflect.EnumNumber

func (StatusResponse_Status) String 

func (x StatusResponse_Status) String() string

func (StatusResponse_Status) Type 

func (StatusResponse_Status) Type() protoreflect.EnumType

type UnimplementedCPUServer 

type UnimplementedCPUServer struct {
}

UnimplementedCPUServer must be embedded to have forward compatible implementations.

func (UnimplementedCPUServer) Recover 

func (UnimplementedCPUServer) Recover(context.Context, *CPURequest) (*StatusResponse, error)

func (UnimplementedCPUServer) Start 

func (UnimplementedCPUServer) Start(context.Context, *CPURequest) (*StatusResponse, error)

type UnimplementedDockerServer 

type UnimplementedDockerServer struct {
}

UnimplementedDockerServer must be embedded to have forward compatible implementations.

func (UnimplementedDockerServer) Kill 

func (UnimplementedDockerServer) Kill(context.Context, *DockerRequest) (*StatusResponse, error)

func (UnimplementedDockerServer) Recover 

func (UnimplementedDockerServer) Recover(context.Context, *DockerRequest) (*StatusResponse, error)

type UnimplementedHealthServer 

type UnimplementedHealthServer struct {
}

UnimplementedHealthServer must be embedded to have forward compatible implementations.

func (UnimplementedHealthServer) Check 

func (UnimplementedHealthServer) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)

func (UnimplementedHealthServer) Watch 

func (UnimplementedHealthServer) Watch(*HealthCheckRequest, Health_WatchServer) error

type UnimplementedNetworkServer 

type UnimplementedNetworkServer struct {
}

UnimplementedNetworkServer must be embedded to have forward compatible implementations.

func (UnimplementedNetworkServer) Recover 

func (UnimplementedNetworkServer) Recover(context.Context, *NetworkRequest) (*StatusResponse, error)

func (UnimplementedNetworkServer) Start 

func (UnimplementedNetworkServer) Start(context.Context, *NetworkRequest) (*StatusResponse, error)

type UnimplementedServerServer 

type UnimplementedServerServer struct {
}

UnimplementedServerServer must be embedded to have forward compatible implementations.

func (UnimplementedServerServer) Kill 

func (UnimplementedServerServer) Kill(context.Context, *ServerRequest) (*StatusResponse, error)

type UnimplementedServiceServer 

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) Kill 

func (UnimplementedServiceServer) Kill(context.Context, *ServiceRequest) (*StatusResponse, error)

func (UnimplementedServiceServer) Recover 

func (UnimplementedServiceServer) Recover(context.Context, *ServiceRequest) (*StatusResponse, error)

type UnsafeCPUServer 

type UnsafeCPUServer interface {
	// contains filtered or unexported methods
}

UnsafeCPUServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CPUServer will result in compilation errors.

type UnsafeDockerServer 

type UnsafeDockerServer interface {
	// contains filtered or unexported methods
}

UnsafeDockerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DockerServer will result in compilation errors.

type UnsafeHealthServer 

type UnsafeHealthServer interface {
	// contains filtered or unexported methods
}

UnsafeHealthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServer will result in compilation errors.

type UnsafeNetworkServer 

type UnsafeNetworkServer interface {
	// contains filtered or unexported methods
}

UnsafeNetworkServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NetworkServer will result in compilation errors.

type UnsafeServerServer 

type UnsafeServerServer interface {
	// contains filtered or unexported methods
}

UnsafeServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServerServer will result in compilation errors.

type UnsafeServiceServer 

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.

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.