api

package
v0.0.0-...-c923896 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

func (*EndpointResult) Descriptor 

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

func (*EndpointResult) GetCached 

func (m *EndpointResult) GetCached() bool

func (*EndpointResult) GetHttpStatusCode 

func (m *EndpointResult) GetHttpStatusCode() int32

func (*EndpointResult) GetHttpStatusMessage 

func (m *EndpointResult) GetHttpStatusMessage() string

func (*EndpointResult) GetTtfb 

func (m *EndpointResult) GetTtfb() int32

func (*EndpointResult) GetUrl 

func (m *EndpointResult) GetUrl() string

func (*EndpointResult) ProtoMessage 

func (*EndpointResult) ProtoMessage()

func (*EndpointResult) Reset 

func (m *EndpointResult) Reset()

func (*EndpointResult) String 

func (m *EndpointResult) String() string

func (*EndpointResult) Validate 

func (this *EndpointResult) Validate() error

func (*EndpointResult) XXX_DiscardUnknown 

func (m *EndpointResult) XXX_DiscardUnknown()

func (*EndpointResult) XXX_Marshal 

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

func (*EndpointResult) XXX_Merge 

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

func (*EndpointResult) XXX_Size 

func (m *EndpointResult) XXX_Size() int

func (*EndpointResult) XXX_Unmarshal 

func (m *EndpointResult) XXX_Unmarshal(b []byte) 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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*RunRequest) Descriptor 

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

func (*RunRequest) GetAmount 

func (m *RunRequest) GetAmount() uint32

func (*RunRequest) GetEndpoints 

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

func (*RunRequest) GetMaxWaitTime 

func (m *RunRequest) GetMaxWaitTime() uint32

func (*RunRequest) GetMinWaitTime 

func (m *RunRequest) GetMinWaitTime() uint32

func (*RunRequest) GetType 

func (m *RunRequest) GetType() RunRequest_BrowserType

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) Reset 

func (m *RunRequest) Reset()

func (*RunRequest) String 

func (m *RunRequest) String() string

func (*RunRequest) Validate 

func (this *RunRequest) Validate() error

func (*RunRequest) XXX_DiscardUnknown 

func (m *RunRequest) XXX_DiscardUnknown()

func (*RunRequest) XXX_Marshal 

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

func (*RunRequest) XXX_Merge 

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

func (*RunRequest) XXX_Size 

func (m *RunRequest) XXX_Size() int

func (*RunRequest) XXX_Unmarshal 

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

type RunRequest_BrowserType 

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

func (RunRequest_BrowserType) EnumDescriptor 

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

func (RunRequest_BrowserType) String 

func (x RunRequest_BrowserType) String() string

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

func (*RunRequest_Endpoint) Descriptor 

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

func (*RunRequest_Endpoint) GetUrl 

func (m *RunRequest_Endpoint) GetUrl() string

func (*RunRequest_Endpoint) GetWeight 

func (m *RunRequest_Endpoint) GetWeight() uint32

func (*RunRequest_Endpoint) ProtoMessage 

func (*RunRequest_Endpoint) ProtoMessage()

func (*RunRequest_Endpoint) Reset 

func (m *RunRequest_Endpoint) Reset()

func (*RunRequest_Endpoint) String 

func (m *RunRequest_Endpoint) String() string

func (*RunRequest_Endpoint) Validate 

func (this *RunRequest_Endpoint) Validate() error

func (*RunRequest_Endpoint) XXX_DiscardUnknown 

func (m *RunRequest_Endpoint) XXX_DiscardUnknown()

func (*RunRequest_Endpoint) XXX_Marshal 

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

func (*RunRequest_Endpoint) XXX_Merge 

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

func (*RunRequest_Endpoint) XXX_Size 

func (m *RunRequest_Endpoint) XXX_Size() int

func (*RunRequest_Endpoint) XXX_Unmarshal 

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

type UnimplementedWorkerServer 

type UnimplementedWorkerServer struct {
}

UnimplementedWorkerServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkerServer) Run 

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

type WorkerClient 

type WorkerClient interface {
	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 {
	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.