api

package
v0.0.0-...-ba7165a Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RunRequest_BrowserType_name = map[int32]string{
		0: "FAKE",
		1: "CHROME",
	}
	RunRequest_BrowserType_value = map[string]int32{
		"FAKE":   0,
		"CHROME": 1,
	}
)

Enum value maps for RunRequest_BrowserType.

View Source 
var File_worker_proto protoreflect.FileDescriptor

Functions

func RegisterWorkerServer 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types

type EndpointResult 

type EndpointResult struct {
	Url               string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	HttpStatusCode    int32  `protobuf:"varint,2,opt,name=httpStatusCode,proto3" json:"httpStatusCode,omitempty"`
	HttpStatusMessage string `protobuf:"bytes,3,opt,name=httpStatusMessage,proto3" json:"httpStatusMessage,omitempty"`
	Ttfb              int32  `protobuf:"varint,4,opt,name=ttfb,proto3" json:"ttfb,omitempty"`
	Cached            bool   `protobuf:"varint,5,opt,name=cached,proto3" json:"cached,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointResult) Descriptor deprecated 

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

Deprecated: Use EndpointResult.ProtoReflect.Descriptor instead.

func (*EndpointResult) GetCached 

func (x *EndpointResult) GetCached() bool

func (*EndpointResult) GetHttpStatusCode 

func (x *EndpointResult) GetHttpStatusCode() int32

func (*EndpointResult) GetHttpStatusMessage 

func (x *EndpointResult) GetHttpStatusMessage() string

func (*EndpointResult) GetTtfb 

func (x *EndpointResult) GetTtfb() int32

func (*EndpointResult) GetUrl 

func (x *EndpointResult) GetUrl() string

func (*EndpointResult) ProtoMessage 

func (*EndpointResult) ProtoMessage()

func (*EndpointResult) ProtoReflect 

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

func (*EndpointResult) Reset 

func (x *EndpointResult) Reset()

func (*EndpointResult) String 

func (x *EndpointResult) String() string

func (*EndpointResult) Validate 

func (this *EndpointResult) Validate() error

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

func (*PingRequest) Validate 

func (this *PingRequest) Validate() error

type PingResponse 

type PingResponse struct {
	SrcIP   string `protobuf:"bytes,1,opt,name=srcIP,proto3" json:"srcIP,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetMessage 

func (x *PingResponse) GetMessage() string

func (*PingResponse) GetSrcIP 

func (x *PingResponse) GetSrcIP() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

func (*PingResponse) Validate 

func (this *PingResponse) Validate() error

type RunRequest 

type RunRequest struct {
	Endpoints   []*RunRequest_Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Amount      uint32                 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	Type        RunRequest_BrowserType `protobuf:"varint,3,opt,name=type,proto3,enum=v1.RunRequest_BrowserType" json:"type,omitempty"`
	MinWaitTime uint32                 `protobuf:"varint,4,opt,name=minWaitTime,proto3" json:"minWaitTime,omitempty"`
	MaxWaitTime uint32                 `protobuf:"varint,5,opt,name=maxWaitTime,proto3" json:"maxWaitTime,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetAmount 

func (x *RunRequest) GetAmount() uint32

func (*RunRequest) GetEndpoints 

func (x *RunRequest) GetEndpoints() []*RunRequest_Endpoint

func (*RunRequest) GetMaxWaitTime 

func (x *RunRequest) GetMaxWaitTime() uint32

func (*RunRequest) GetMinWaitTime 

func (x *RunRequest) GetMinWaitTime() uint32

func (*RunRequest) GetType 

func (x *RunRequest) GetType() RunRequest_BrowserType

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

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

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

func (*RunRequest) Validate 

func (this *RunRequest) Validate() error

type RunRequest_BrowserType 

type RunRequest_BrowserType int32
const (
	RunRequest_FAKE   RunRequest_BrowserType = 0
	RunRequest_CHROME RunRequest_BrowserType = 1
)

func (RunRequest_BrowserType) Descriptor 

func (RunRequest_BrowserType) Descriptor() protoreflect.EnumDescriptor

func (RunRequest_BrowserType) Enum 

func (x RunRequest_BrowserType) Enum() *RunRequest_BrowserType

func (RunRequest_BrowserType) EnumDescriptor deprecated 

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

Deprecated: Use RunRequest_BrowserType.Descriptor instead.

func (RunRequest_BrowserType) Number 

func (x RunRequest_BrowserType) Number() protoreflect.EnumNumber

func (RunRequest_BrowserType) String 

func (x RunRequest_BrowserType) String() string

func (RunRequest_BrowserType) Type 

func (RunRequest_BrowserType) Type() protoreflect.EnumType

type RunRequest_Endpoint 

type RunRequest_Endpoint struct {
	Url    string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Weight uint32 `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest_Endpoint) Descriptor deprecated 

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

Deprecated: Use RunRequest_Endpoint.ProtoReflect.Descriptor instead.

func (*RunRequest_Endpoint) GetUrl 

func (x *RunRequest_Endpoint) GetUrl() string

func (*RunRequest_Endpoint) GetWeight 

func (x *RunRequest_Endpoint) GetWeight() uint32

func (*RunRequest_Endpoint) ProtoMessage 

func (*RunRequest_Endpoint) ProtoMessage()

func (*RunRequest_Endpoint) ProtoReflect 

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

func (*RunRequest_Endpoint) Reset 

func (x *RunRequest_Endpoint) Reset()

func (*RunRequest_Endpoint) String 

func (x *RunRequest_Endpoint) String() string

func (*RunRequest_Endpoint) Validate 

func (this *RunRequest_Endpoint) Validate() error

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) Ping 

func (*UnimplementedWorkerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (*UnimplementedWorkerServer) Run 

func (*UnimplementedWorkerServer) Run(*RunRequest, Worker_RunServer) error

type WorkerClient 

type WorkerClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (Worker_RunClient, error)
}

WorkerClient is the client API for Worker service.

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

func NewWorkerClient 

func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient

type WorkerServer 

type WorkerServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Run(*RunRequest, Worker_RunServer) error
}

WorkerServer is the server API for Worker service.

type Worker_RunClient 

type Worker_RunClient interface {
	Recv() (*EndpointResult, error)
	grpc.ClientStream
}

type Worker_RunServer 

type Worker_RunServer interface {
	Send(*EndpointResult) error
	grpc.ServerStream
}

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.