frontendv1pb

package
v0.0.0-...-80e4d6b Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

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)
	// The client notifies the query-frontend that it started a graceful shutdown.
	NotifyClientShutdown(ctx context.Context, in *NotifyClientShutdownRequest, opts ...grpc.CallOption) (*NotifyClientShutdownResponse, 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
	// The client notifies the query-frontend that it started a graceful shutdown.
	NotifyClientShutdown(context.Context, *NotifyClientShutdownRequest) (*NotifyClientShutdownResponse, 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"`
	// How much time did query spend in the queue.
	QueueTimeNanos int64 `protobuf:"varint,4,opt,name=queueTimeNanos,proto3" json:"queueTimeNanos,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) GetQueueTimeNanos 

func (m *FrontendToClient) GetQueueTimeNanos() int64

func (*FrontendToClient) GetStatsEnabled 

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 NotifyClientShutdownRequest 

type NotifyClientShutdownRequest struct {
	ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
}

func (*NotifyClientShutdownRequest) Descriptor 

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

func (*NotifyClientShutdownRequest) Equal 

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

func (*NotifyClientShutdownRequest) GetClientID 

func (m *NotifyClientShutdownRequest) GetClientID() string

func (*NotifyClientShutdownRequest) GoString 

func (this *NotifyClientShutdownRequest) GoString() string

func (*NotifyClientShutdownRequest) Marshal 

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

func (*NotifyClientShutdownRequest) MarshalTo 

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

func (*NotifyClientShutdownRequest) MarshalToSizedBuffer 

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

func (*NotifyClientShutdownRequest) ProtoMessage 

func (*NotifyClientShutdownRequest) ProtoMessage()

func (*NotifyClientShutdownRequest) Reset 

func (m *NotifyClientShutdownRequest) Reset()

func (*NotifyClientShutdownRequest) Size 

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

func (*NotifyClientShutdownRequest) String 

func (this *NotifyClientShutdownRequest) String() string

func (*NotifyClientShutdownRequest) Unmarshal 

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

func (*NotifyClientShutdownRequest) XXX_DiscardUnknown 

func (m *NotifyClientShutdownRequest) XXX_DiscardUnknown()

func (*NotifyClientShutdownRequest) XXX_Marshal 

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

func (*NotifyClientShutdownRequest) XXX_Merge 

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

func (*NotifyClientShutdownRequest) XXX_Size 

func (m *NotifyClientShutdownRequest) XXX_Size() int

func (*NotifyClientShutdownRequest) XXX_Unmarshal 

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

type NotifyClientShutdownResponse 

type NotifyClientShutdownResponse struct {
}

func (*NotifyClientShutdownResponse) Descriptor 

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

func (*NotifyClientShutdownResponse) Equal 

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

func (*NotifyClientShutdownResponse) GoString 

func (this *NotifyClientShutdownResponse) GoString() string

func (*NotifyClientShutdownResponse) Marshal 

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

func (*NotifyClientShutdownResponse) MarshalTo 

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

func (*NotifyClientShutdownResponse) MarshalToSizedBuffer 

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

func (*NotifyClientShutdownResponse) ProtoMessage 

func (*NotifyClientShutdownResponse) ProtoMessage()

func (*NotifyClientShutdownResponse) Reset 

func (m *NotifyClientShutdownResponse) Reset()

func (*NotifyClientShutdownResponse) Size 

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

func (*NotifyClientShutdownResponse) String 

func (this *NotifyClientShutdownResponse) String() string

func (*NotifyClientShutdownResponse) Unmarshal 

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

func (*NotifyClientShutdownResponse) XXX_DiscardUnknown 

func (m *NotifyClientShutdownResponse) XXX_DiscardUnknown()

func (*NotifyClientShutdownResponse) XXX_Marshal 

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

func (*NotifyClientShutdownResponse) XXX_Merge 

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

func (*NotifyClientShutdownResponse) XXX_Size 

func (m *NotifyClientShutdownResponse) XXX_Size() int

func (*NotifyClientShutdownResponse) XXX_Unmarshal 

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

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) NotifyClientShutdown 

func (*UnimplementedFrontendServer) NotifyClientShutdown(ctx context.Context, req *NotifyClientShutdownRequest) (*NotifyClientShutdownResponse, error)

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.