servers

README

This directory is for helper servers available for use with Cloudprober. Cloudprober itself is a prober daemon with primary purpose to run probes but since it runs on all of our probing VMs, it provides a perfect platform to run servers that can act as the backend for probes that need to access something on cloud.

Documentation

Overview

Package servers is a generated protocol buffer package.

It is generated from these files:

github.com/google/cloudprober/servers/config.proto

It has these top-level messages:

Server

servers package provides an interface to initialize cloudprober servers using servers config.

Index

• Variables
• func Start(ctx context.Context, serverProtobufs []*Server, ...)
• type Server
  • func (*Server) Descriptor() ([]byte, []int)
  • func (m *Server) GetHttpServer() *cloudprober_servers_http.ServerConf
  • func (m *Server) GetServer() isServer_Server
  • func (m *Server) GetType() Server_Type
  • func (m *Server) GetUdpServer() *cloudprober_servers_udp.ServerConf
  • func (*Server) ProtoMessage()
  • func (m *Server) Reset()
  • func (m *Server) String() string
  • func (*Server) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Server_HttpServer
• type Server_Type
  • func (x Server_Type) Enum() *Server_Type
  • func (Server_Type) EnumDescriptor() ([]byte, []int)
  • func (x Server_Type) String() string
  • func (x *Server_Type) UnmarshalJSON(data []byte) error
• type Server_UdpServer

Variables

var Server_Type_name = map[int32]string{
	0: "HTTP",
	1: "UDP",
}

var Server_Type_value = map[string]int32{
	"HTTP": 0,
	"UDP":  1,
}

Functions

func Start

func Start(ctx context.Context, serverProtobufs []*Server, dataChan chan<- *metrics.EventMetrics)

Start initializes and starts cloudprober servers, based on the provided config.

Types

type Server

type Server struct {
	Type *Server_Type `protobuf:"varint,1,req,name=type,enum=cloudprober.servers.Server_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Server:
	//	*Server_HttpServer
	//	*Server_UdpServer
	Server           isServer_Server `protobuf_oneof:"server"`
	XXX_unrecognized []byte          `json:"-"`
}

func (*Server) Descriptor

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

func (*Server) GetHttpServer

func (m *Server) GetHttpServer() *cloudprober_servers_http.ServerConf

func (*Server) GetServer

func (m *Server) GetServer() isServer_Server

func (*Server) GetType

func (m *Server) GetType() Server_Type

func (*Server) GetUdpServer

func (m *Server) GetUdpServer() *cloudprober_servers_udp.ServerConf

func (*Server) ProtoMessage

func (*Server) ProtoMessage()

func (*Server) Reset

func (m *Server) Reset()

func (*Server) String

func (m *Server) String() string

func (*Server) XXX_OneofFuncs

func (*Server) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Server_HttpServer

type Server_HttpServer struct {
	HttpServer *cloudprober_servers_http.ServerConf `protobuf:"bytes,2,opt,name=http_server,json=httpServer,oneof"`
}

type Server_Type

type Server_Type int32

const (
	Server_HTTP Server_Type = 0
	Server_UDP  Server_Type = 1
)

func (Server_Type) Enum

func (x Server_Type) Enum() *Server_Type

func (Server_Type) EnumDescriptor

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

func (Server_Type) String

func (x Server_Type) String() string

func (*Server_Type) UnmarshalJSON

func (x *Server_Type) UnmarshalJSON(data []byte) error

type Server_UdpServer

type Server_UdpServer struct {
	UdpServer *cloudprober_servers_udp.ServerConf `protobuf:"bytes,3,opt,name=udp_server,json=udpServer,oneof"`
}