frontendv1pb

package
v1.8.0 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2021 License: Apache-2.0 Imports: 15 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthFrontend = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFrontend   = fmt.Errorf("proto: integer overflow")
)
View Source 
var Type_name = map[int32]string{
	0: "HTTP_REQUEST",
	1: "GET_ID",
}
View Source 
var Type_value = map[string]int32{
	"HTTP_REQUEST": 0,
	"GET_ID":       1,
}

Functions

func RegisterFrontendServer 

func RegisterFrontendServer(s *grpc.Server, srv FrontendServer)

Types

type ClientToFrontend 

type ClientToFrontend struct {
	HttpResponse *httpgrpc.HTTPResponse `protobuf:"bytes,1,opt,name=httpResponse,proto3" json:"httpResponse,omitempty"`
	ClientID     string                 `protobuf:"bytes,2,opt,name=clientID,proto3" json:"clientID,omitempty"`
	Stats        *stats.Stats           `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
}

func (*ClientToFrontend) Descriptor 

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

func (*ClientToFrontend) Equal 

func (this *ClientToFrontend) Equal(that interface{}) bool

func (*ClientToFrontend) GetClientID 

func (m *ClientToFrontend) GetClientID() string

func (*ClientToFrontend) GetHttpResponse 

func (m *ClientToFrontend) GetHttpResponse() *httpgrpc.HTTPResponse

func (*ClientToFrontend) GetStats 

func (m *ClientToFrontend) GetStats() *stats.Stats

func (*ClientToFrontend) GoString 

func (this *ClientToFrontend) GoString() string

func (*ClientToFrontend) Marshal 

func (m *ClientToFrontend) Marshal() (dAtA []byte, err error)

func (*ClientToFrontend) MarshalTo 

func (m *ClientToFrontend) MarshalTo(dAtA []byte) (int, error)

func (*ClientToFrontend) MarshalToSizedBuffer 

func (m *ClientToFrontend) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientToFrontend) ProtoMessage 

func (*ClientToFrontend) ProtoMessage()

func (*ClientToFrontend) Reset 

func (m *ClientToFrontend) Reset()

func (*ClientToFrontend) Size 

func (m *ClientToFrontend) Size() (n int)

func (*ClientToFrontend) String 

func (this *ClientToFrontend) String() string

func (*ClientToFrontend) Unmarshal 

func (m *ClientToFrontend) Unmarshal(dAtA []byte) error

func (*ClientToFrontend) XXX_DiscardUnknown 

func (m *ClientToFrontend) XXX_DiscardUnknown()

func (*ClientToFrontend) XXX_Marshal 

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

func (*ClientToFrontend) XXX_Merge 

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

func (*ClientToFrontend) XXX_Size 

func (m *ClientToFrontend) XXX_Size() int

func (*ClientToFrontend) XXX_Unmarshal 

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

type FrontendClient 

type FrontendClient interface {
	// After calling this method, client enters a loop, in which it waits for
	// a "FrontendToClient" message and replies with single "ClientToFrontend" message.
	Process(ctx context.Context, opts ...grpc.CallOption) (Frontend_ProcessClient, error)
}

FrontendClient is the client API for Frontend service.

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

func NewFrontendClient 

func NewFrontendClient(cc *grpc.ClientConn) FrontendClient

type FrontendServer 

type FrontendServer interface {
	// After calling this method, client enters a loop, in which it waits for
	// a "FrontendToClient" message and replies with single "ClientToFrontend" message.
	Process(Frontend_ProcessServer) error
}

FrontendServer is the server API for Frontend service.

type FrontendToClient 

type FrontendToClient struct {
	HttpRequest *httpgrpc.HTTPRequest `protobuf:"bytes,1,opt,name=httpRequest,proto3" json:"httpRequest,omitempty"`
	Type        Type                  `protobuf:"varint,2,opt,name=type,proto3,enum=frontend.Type" json:"type,omitempty"`
	// Whether query statistics tracking should be enabled. The response will include
	// statistics only when this option is enabled.
	StatsEnabled bool `protobuf:"varint,3,opt,name=statsEnabled,proto3" json:"statsEnabled,omitempty"`
}

func (*FrontendToClient) Descriptor 

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

func (*FrontendToClient) Equal 

func (this *FrontendToClient) Equal(that interface{}) bool

func (*FrontendToClient) GetHttpRequest 

func (m *FrontendToClient) GetHttpRequest() *httpgrpc.HTTPRequest

func (*FrontendToClient) GetStatsEnabled added in v1.7.0 

func (m *FrontendToClient) GetStatsEnabled() bool

func (*FrontendToClient) GetType 

func (m *FrontendToClient) GetType() Type

func (*FrontendToClient) GoString 

func (this *FrontendToClient) GoString() string

func (*FrontendToClient) Marshal 

func (m *FrontendToClient) Marshal() (dAtA []byte, err error)

func (*FrontendToClient) MarshalTo 

func (m *FrontendToClient) MarshalTo(dAtA []byte) (int, error)

func (*FrontendToClient) MarshalToSizedBuffer 

func (m *FrontendToClient) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FrontendToClient) ProtoMessage 

func (*FrontendToClient) ProtoMessage()

func (*FrontendToClient) Reset 

func (m *FrontendToClient) Reset()

func (*FrontendToClient) Size 

func (m *FrontendToClient) Size() (n int)

func (*FrontendToClient) String 

func (this *FrontendToClient) String() string

func (*FrontendToClient) Unmarshal 

func (m *FrontendToClient) Unmarshal(dAtA []byte) error

func (*FrontendToClient) XXX_DiscardUnknown 

func (m *FrontendToClient) XXX_DiscardUnknown()

func (*FrontendToClient) XXX_Marshal 

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

func (*FrontendToClient) XXX_Merge 

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

func (*FrontendToClient) XXX_Size 

func (m *FrontendToClient) XXX_Size() int

func (*FrontendToClient) XXX_Unmarshal 

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

type Frontend_ProcessClient 

type Frontend_ProcessClient interface {
	Send(*ClientToFrontend) error
	Recv() (*FrontendToClient, error)
	grpc.ClientStream
}

type Frontend_ProcessServer 

type Frontend_ProcessServer interface {
	Send(*FrontendToClient) error
	Recv() (*ClientToFrontend, error)
	grpc.ServerStream
}

type Type 

type Type int32
const (
	HTTP_REQUEST Type = 0
	GET_ID       Type = 1
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type UnimplementedFrontendServer 

type UnimplementedFrontendServer struct {
}

UnimplementedFrontendServer can be embedded to have forward compatible implementations.

func (*UnimplementedFrontendServer) Process 

func (*UnimplementedFrontendServer) Process(srv Frontend_ProcessServer) 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.