proto

package
v0.11.3 Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2021 License: Apache-2.0 Imports: 8 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	Default_ServerConf_Port               = int32(3142)
	Default_ServerConf_EnableReflection   = bool(false)
	Default_ServerConf_UseDedicatedServer = bool(true)
)

Default values for ServerConf fields.

Variables

View Source 
var File_github_com_google_cloudprober_servers_grpc_proto_config_proto protoreflect.FileDescriptor
View Source 
var File_github_com_google_cloudprober_servers_grpc_proto_grpcservice_proto protoreflect.FileDescriptor

Functions

func RegisterProberServer 

func RegisterProberServer(s *grpc.Server, srv ProberServer)

Types

type BlobReadRequest added in v0.10.2 

type BlobReadRequest struct {
	Size *int32 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobReadRequest) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use BlobReadRequest.ProtoReflect.Descriptor instead.

func (*BlobReadRequest) GetSize added in v0.10.2 

func (x *BlobReadRequest) GetSize() int32

func (*BlobReadRequest) ProtoMessage added in v0.10.2 

func (*BlobReadRequest) ProtoMessage()

func (*BlobReadRequest) ProtoReflect added in v0.10.8 

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

func (*BlobReadRequest) Reset added in v0.10.2 

func (x *BlobReadRequest) Reset()

func (*BlobReadRequest) String added in v0.10.2 

func (x *BlobReadRequest) String() string

type BlobReadResponse added in v0.10.2 

type BlobReadResponse struct {
	Blob []byte `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobReadResponse) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use BlobReadResponse.ProtoReflect.Descriptor instead.

func (*BlobReadResponse) GetBlob added in v0.10.2 

func (x *BlobReadResponse) GetBlob() []byte

func (*BlobReadResponse) ProtoMessage added in v0.10.2 

func (*BlobReadResponse) ProtoMessage()

func (*BlobReadResponse) ProtoReflect added in v0.10.8 

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

func (*BlobReadResponse) Reset added in v0.10.2 

func (x *BlobReadResponse) Reset()

func (*BlobReadResponse) String added in v0.10.2 

func (x *BlobReadResponse) String() string

type BlobWriteRequest added in v0.10.2 

type BlobWriteRequest struct {
	Blob []byte `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobWriteRequest) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use BlobWriteRequest.ProtoReflect.Descriptor instead.

func (*BlobWriteRequest) GetBlob added in v0.10.2 

func (x *BlobWriteRequest) GetBlob() []byte

func (*BlobWriteRequest) ProtoMessage added in v0.10.2 

func (*BlobWriteRequest) ProtoMessage()

func (*BlobWriteRequest) ProtoReflect added in v0.10.8 

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

func (*BlobWriteRequest) Reset added in v0.10.2 

func (x *BlobWriteRequest) Reset()

func (*BlobWriteRequest) String added in v0.10.2 

func (x *BlobWriteRequest) String() string

type BlobWriteResponse added in v0.10.2 

type BlobWriteResponse struct {
	Size *int32 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobWriteResponse) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use BlobWriteResponse.ProtoReflect.Descriptor instead.

func (*BlobWriteResponse) GetSize added in v0.10.2 

func (x *BlobWriteResponse) GetSize() int32

func (*BlobWriteResponse) ProtoMessage added in v0.10.2 

func (*BlobWriteResponse) ProtoMessage()

func (*BlobWriteResponse) ProtoReflect added in v0.10.8 

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

func (*BlobWriteResponse) Reset added in v0.10.2 

func (x *BlobWriteResponse) Reset()

func (*BlobWriteResponse) String added in v0.10.2 

func (x *BlobWriteResponse) String() string

type EchoMessage 

type EchoMessage struct {
	Blob []byte `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*EchoMessage) Descriptor deprecated 

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

Deprecated: Use EchoMessage.ProtoReflect.Descriptor instead.

func (*EchoMessage) GetBlob 

func (x *EchoMessage) GetBlob() []byte

func (*EchoMessage) ProtoMessage 

func (*EchoMessage) ProtoMessage()

func (*EchoMessage) ProtoReflect added in v0.10.8 

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

func (*EchoMessage) Reset 

func (x *EchoMessage) Reset()

func (*EchoMessage) String 

func (x *EchoMessage) String() string

type ProberClient 

type ProberClient interface {
	// Echo echoes back incoming messages.
	Echo(ctx context.Context, in *EchoMessage, opts ...grpc.CallOption) (*EchoMessage, error)
	// BlobRead returns a blob of bytes to the prober.
	BlobRead(ctx context.Context, in *BlobReadRequest, opts ...grpc.CallOption) (*BlobReadResponse, error)
	// ServerStatus returns the current server status.
	ServerStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// BlobWrite allows client to write a blob to the server.
	BlobWrite(ctx context.Context, in *BlobWriteRequest, opts ...grpc.CallOption) (*BlobWriteResponse, error)
}

ProberClient is the client API for Prober service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProberClient 

func NewProberClient(cc grpc.ClientConnInterface) ProberClient

type ProberServer 

type ProberServer interface {
	// Echo echoes back incoming messages.
	Echo(context.Context, *EchoMessage) (*EchoMessage, error)
	// BlobRead returns a blob of bytes to the prober.
	BlobRead(context.Context, *BlobReadRequest) (*BlobReadResponse, error)
	// ServerStatus returns the current server status.
	ServerStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	// BlobWrite allows client to write a blob to the server.
	BlobWrite(context.Context, *BlobWriteRequest) (*BlobWriteResponse, error)
}

ProberServer is the server API for Prober service.

type ServerConf 

type ServerConf struct {
	Port *int32 `protobuf:"varint,1,opt,name=port,def=3142" json:"port,omitempty"`
	// Enables gRPC reflection for publicly visible services, allowing grpc_cli to
	// work. See https://grpc.io/grpc/core/md_doc_server_reflection_tutorial.html.
	EnableReflection *bool `protobuf:"varint,2,opt,name=enable_reflection,json=enableReflection,def=0" json:"enable_reflection,omitempty"`
	// If use_dedicated_server is set to true, then create a new gRPC server
	// to handle probes. Otherwise, attempt to reuse gRPC server from runconfig
	// if that was set.
	UseDedicatedServer *bool `protobuf:"varint,3,opt,name=use_dedicated_server,json=useDedicatedServer,def=1" json:"use_dedicated_server,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerConf) Descriptor deprecated 

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

Deprecated: Use ServerConf.ProtoReflect.Descriptor instead.

func (*ServerConf) GetEnableReflection 

func (x *ServerConf) GetEnableReflection() bool

func (*ServerConf) GetPort 

func (x *ServerConf) GetPort() int32

func (*ServerConf) GetUseDedicatedServer 

func (x *ServerConf) GetUseDedicatedServer() bool

func (*ServerConf) ProtoMessage 

func (*ServerConf) ProtoMessage()

func (*ServerConf) ProtoReflect added in v0.10.8 

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

func (*ServerConf) Reset 

func (x *ServerConf) Reset()

func (*ServerConf) String 

func (x *ServerConf) String() string

type StatusRequest 

type StatusRequest struct {
	ClientName *string `protobuf:"bytes,1,opt,name=client_name,json=clientName" json:"client_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetClientName 

func (x *StatusRequest) GetClientName() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect added in v0.10.8 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	UptimeUs *int64 `protobuf:"varint,1,opt,name=uptime_us,json=uptimeUs" json:"uptime_us,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetUptimeUs 

func (x *StatusResponse) GetUptimeUs() int64

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect added in v0.10.8 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type UnimplementedProberServer added in v0.10.4 

type UnimplementedProberServer struct {
}

UnimplementedProberServer can be embedded to have forward compatible implementations.

func (*UnimplementedProberServer) BlobRead added in v0.10.4 

func (*UnimplementedProberServer) BlobRead(context.Context, *BlobReadRequest) (*BlobReadResponse, error)

func (*UnimplementedProberServer) BlobWrite added in v0.10.4 

func (*UnimplementedProberServer) BlobWrite(context.Context, *BlobWriteRequest) (*BlobWriteResponse, error)

func (*UnimplementedProberServer) Echo added in v0.10.4 

func (*UnimplementedProberServer) Echo(context.Context, *EchoMessage) (*EchoMessage, error)

func (*UnimplementedProberServer) ServerStatus added in v0.10.4 

func (*UnimplementedProberServer) ServerStatus(context.Context, *StatusRequest) (*StatusResponse, 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.