proto

package
v0.10.3 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2019 License: Apache-2.0 Imports: 5 Imported by: 4

Documentation

Index

Constants

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

Variables

This section is empty.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlobReadRequest) Descriptor added in v0.10.2 

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

func (*BlobReadRequest) GetSize added in v0.10.2 

func (m *BlobReadRequest) GetSize() int32

func (*BlobReadRequest) ProtoMessage added in v0.10.2 

func (*BlobReadRequest) ProtoMessage()

func (*BlobReadRequest) Reset added in v0.10.2 

func (m *BlobReadRequest) Reset()

func (*BlobReadRequest) String added in v0.10.2 

func (m *BlobReadRequest) String() string

func (*BlobReadRequest) XXX_DiscardUnknown added in v0.10.2 

func (m *BlobReadRequest) XXX_DiscardUnknown()

func (*BlobReadRequest) XXX_Marshal added in v0.10.2 

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

func (*BlobReadRequest) XXX_Merge added in v0.10.2 

func (dst *BlobReadRequest) XXX_Merge(src proto.Message)

func (*BlobReadRequest) XXX_Size added in v0.10.2 

func (m *BlobReadRequest) XXX_Size() int

func (*BlobReadRequest) XXX_Unmarshal added in v0.10.2 

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

type BlobReadResponse added in v0.10.2 

type BlobReadResponse struct {
	Blob                 []byte   `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlobReadResponse) Descriptor added in v0.10.2 

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

func (*BlobReadResponse) GetBlob added in v0.10.2 

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

func (*BlobReadResponse) ProtoMessage added in v0.10.2 

func (*BlobReadResponse) ProtoMessage()

func (*BlobReadResponse) Reset added in v0.10.2 

func (m *BlobReadResponse) Reset()

func (*BlobReadResponse) String added in v0.10.2 

func (m *BlobReadResponse) String() string

func (*BlobReadResponse) XXX_DiscardUnknown added in v0.10.2 

func (m *BlobReadResponse) XXX_DiscardUnknown()

func (*BlobReadResponse) XXX_Marshal added in v0.10.2 

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

func (*BlobReadResponse) XXX_Merge added in v0.10.2 

func (dst *BlobReadResponse) XXX_Merge(src proto.Message)

func (*BlobReadResponse) XXX_Size added in v0.10.2 

func (m *BlobReadResponse) XXX_Size() int

func (*BlobReadResponse) XXX_Unmarshal added in v0.10.2 

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

type BlobWriteRequest added in v0.10.2 

type BlobWriteRequest struct {
	Blob                 []byte   `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlobWriteRequest) Descriptor added in v0.10.2 

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

func (*BlobWriteRequest) GetBlob added in v0.10.2 

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

func (*BlobWriteRequest) ProtoMessage added in v0.10.2 

func (*BlobWriteRequest) ProtoMessage()

func (*BlobWriteRequest) Reset added in v0.10.2 

func (m *BlobWriteRequest) Reset()

func (*BlobWriteRequest) String added in v0.10.2 

func (m *BlobWriteRequest) String() string

func (*BlobWriteRequest) XXX_DiscardUnknown added in v0.10.2 

func (m *BlobWriteRequest) XXX_DiscardUnknown()

func (*BlobWriteRequest) XXX_Marshal added in v0.10.2 

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

func (*BlobWriteRequest) XXX_Merge added in v0.10.2 

func (dst *BlobWriteRequest) XXX_Merge(src proto.Message)

func (*BlobWriteRequest) XXX_Size added in v0.10.2 

func (m *BlobWriteRequest) XXX_Size() int

func (*BlobWriteRequest) XXX_Unmarshal added in v0.10.2 

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

type BlobWriteResponse added in v0.10.2 

type BlobWriteResponse struct {
	Size                 *int32   `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlobWriteResponse) Descriptor added in v0.10.2 

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

func (*BlobWriteResponse) GetSize added in v0.10.2 

func (m *BlobWriteResponse) GetSize() int32

func (*BlobWriteResponse) ProtoMessage added in v0.10.2 

func (*BlobWriteResponse) ProtoMessage()

func (*BlobWriteResponse) Reset added in v0.10.2 

func (m *BlobWriteResponse) Reset()

func (*BlobWriteResponse) String added in v0.10.2 

func (m *BlobWriteResponse) String() string

func (*BlobWriteResponse) XXX_DiscardUnknown added in v0.10.2 

func (m *BlobWriteResponse) XXX_DiscardUnknown()

func (*BlobWriteResponse) XXX_Marshal added in v0.10.2 

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

func (*BlobWriteResponse) XXX_Merge added in v0.10.2 

func (dst *BlobWriteResponse) XXX_Merge(src proto.Message)

func (*BlobWriteResponse) XXX_Size added in v0.10.2 

func (m *BlobWriteResponse) XXX_Size() int

func (*BlobWriteResponse) XXX_Unmarshal added in v0.10.2 

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

type EchoMessage 

type EchoMessage struct {
	Blob                 []byte   `protobuf:"bytes,1,opt,name=blob" json:"blob,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EchoMessage) Descriptor 

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

func (*EchoMessage) GetBlob 

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

func (*EchoMessage) ProtoMessage 

func (*EchoMessage) ProtoMessage()

func (*EchoMessage) Reset 

func (m *EchoMessage) Reset()

func (*EchoMessage) String 

func (m *EchoMessage) String() string

func (*EchoMessage) XXX_DiscardUnknown 

func (m *EchoMessage) XXX_DiscardUnknown()

func (*EchoMessage) XXX_Marshal 

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

func (*EchoMessage) XXX_Merge 

func (dst *EchoMessage) XXX_Merge(src proto.Message)

func (*EchoMessage) XXX_Size 

func (m *EchoMessage) XXX_Size() int

func (*EchoMessage) XXX_Unmarshal 

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

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.ClientConn) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerConf) Descriptor 

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

func (*ServerConf) GetEnableReflection 

func (m *ServerConf) GetEnableReflection() bool

func (*ServerConf) GetPort 

func (m *ServerConf) GetPort() int32

func (*ServerConf) GetUseDedicatedServer 

func (m *ServerConf) GetUseDedicatedServer() bool

func (*ServerConf) ProtoMessage 

func (*ServerConf) ProtoMessage()

func (*ServerConf) Reset 

func (m *ServerConf) Reset()

func (*ServerConf) String 

func (m *ServerConf) String() string

func (*ServerConf) XXX_DiscardUnknown 

func (m *ServerConf) XXX_DiscardUnknown()

func (*ServerConf) XXX_Marshal 

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

func (*ServerConf) XXX_Merge 

func (dst *ServerConf) XXX_Merge(src proto.Message)

func (*ServerConf) XXX_Size 

func (m *ServerConf) XXX_Size() int

func (*ServerConf) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	ClientName           *string  `protobuf:"bytes,1,opt,name=client_name,json=clientName" json:"client_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetClientName 

func (m *StatusRequest) GetClientName() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

func (dst *StatusRequest) XXX_Merge(src proto.Message)

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	UptimeUs             *int64   `protobuf:"varint,1,opt,name=uptime_us,json=uptimeUs" json:"uptime_us,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetUptimeUs 

func (m *StatusResponse) GetUptimeUs() int64

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

func (dst *StatusResponse) XXX_Merge(src proto.Message)

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

func (m *StatusResponse) XXX_Unmarshal(b []byte) 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.