frontendv1pb

package
v0.0.0-...-39c03fc Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Type_name = map[int32]string{
		0: "HTTP_REQUEST",
		1: "GET_ID",
	}
	Type_value = map[string]int32{
		"HTTP_REQUEST": 0,
		"GET_ID":       1,
	}
)

Enum value maps for Type.

View Source 
var File_frontend_v1_frontendv1pb_frontend_proto protoreflect.FileDescriptor
View Source 
var Frontend_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "frontend.Frontend",
	HandlerType: (*FrontendServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NotifyClientShutdown",
			Handler:    _Frontend_NotifyClientShutdown_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Process",
			Handler:       _Frontend_Process_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ProcessTracepoint",
			Handler:       _Frontend_ProcessTracepoint_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "frontend/v1/frontendv1pb/frontend.proto",
}

Frontend_ServiceDesc is the grpc.ServiceDesc for Frontend service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFrontendServer 

func RegisterFrontendServer(s grpc.ServiceRegistrar, srv FrontendServer)

Types

type ClientToFrontend 

type ClientToFrontend struct {
	HttpResponse *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"`
	// contains filtered or unexported fields
}

func (*ClientToFrontend) Descriptor deprecated 

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

Deprecated: Use ClientToFrontend.ProtoReflect.Descriptor instead.

func (*ClientToFrontend) GetClientID 

func (x *ClientToFrontend) GetClientID() string

func (*ClientToFrontend) GetHttpResponse 

func (x *ClientToFrontend) GetHttpResponse() *HTTPResponse

func (*ClientToFrontend) GetStats 

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

func (*ClientToFrontend) ProtoMessage 

func (*ClientToFrontend) ProtoMessage()

func (*ClientToFrontend) ProtoReflect 

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

func (*ClientToFrontend) Reset 

func (x *ClientToFrontend) Reset()

func (*ClientToFrontend) String 

func (x *ClientToFrontend) String() string

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)
	// After calling this method, client enters a loop, in which it waits for
	// a "FrontendToClient" message and replies with single "ClientToFrontend" message.
	// This version differs from the above as this is called from the tracepoint service
	ProcessTracepoint(ctx context.Context, opts ...grpc.CallOption) (Frontend_ProcessTracepointClient, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFrontendClient 

func NewFrontendClient(cc grpc.ClientConnInterface) 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
	// After calling this method, client enters a loop, in which it waits for
	// a "FrontendToClient" message and replies with single "ClientToFrontend" message.
	// This version differs from the above as this is called from the tracepoint service
	ProcessTracepoint(Frontend_ProcessTracepointServer) error
	// The client notifies the query-frontend that it started a graceful shutdown.
	NotifyClientShutdown(context.Context, *NotifyClientShutdownRequest) (*NotifyClientShutdownResponse, error)
	// contains filtered or unexported methods
}

FrontendServer is the server API for Frontend service. All implementations must embed UnimplementedFrontendServer for forward compatibility

type FrontendToClient 

type FrontendToClient struct {
	HttpRequest *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"`
	// contains filtered or unexported fields
}

func (*FrontendToClient) Descriptor deprecated 

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

Deprecated: Use FrontendToClient.ProtoReflect.Descriptor instead.

func (*FrontendToClient) GetHttpRequest 

func (x *FrontendToClient) GetHttpRequest() *HTTPRequest

func (*FrontendToClient) GetStatsEnabled 

func (x *FrontendToClient) GetStatsEnabled() bool

func (*FrontendToClient) GetType 

func (x *FrontendToClient) GetType() Type

func (*FrontendToClient) ProtoMessage 

func (*FrontendToClient) ProtoMessage()

func (*FrontendToClient) ProtoReflect 

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

func (*FrontendToClient) Reset 

func (x *FrontendToClient) Reset()

func (*FrontendToClient) String 

func (x *FrontendToClient) String() string

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 Frontend_ProcessTracepointClient 

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

type Frontend_ProcessTracepointServer 

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

type HTTPRequest 

type HTTPRequest struct {
	Method  string    `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url     string    `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Headers []*Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Body    []byte    `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPRequest) Descriptor deprecated 

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

Deprecated: Use HTTPRequest.ProtoReflect.Descriptor instead.

func (*HTTPRequest) GetBody 

func (x *HTTPRequest) GetBody() []byte

func (*HTTPRequest) GetHeaders 

func (x *HTTPRequest) GetHeaders() []*Header

func (*HTTPRequest) GetMethod 

func (x *HTTPRequest) GetMethod() string

func (*HTTPRequest) GetUrl 

func (x *HTTPRequest) GetUrl() string

func (*HTTPRequest) ProtoMessage 

func (*HTTPRequest) ProtoMessage()

func (*HTTPRequest) ProtoReflect 

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

func (*HTTPRequest) Reset 

func (x *HTTPRequest) Reset()

func (*HTTPRequest) String 

func (x *HTTPRequest) String() string

type HTTPResponse 

type HTTPResponse struct {
	Code    int32     `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Headers []*Header `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	Body    []byte    `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPResponse) Descriptor deprecated 

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

Deprecated: Use HTTPResponse.ProtoReflect.Descriptor instead.

func (*HTTPResponse) GetBody 

func (x *HTTPResponse) GetBody() []byte

func (*HTTPResponse) GetCode 

func (x *HTTPResponse) GetCode() int32

func (*HTTPResponse) GetHeaders 

func (x *HTTPResponse) GetHeaders() []*Header

func (*HTTPResponse) ProtoMessage 

func (*HTTPResponse) ProtoMessage()

func (*HTTPResponse) ProtoReflect 

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

func (*HTTPResponse) Reset 

func (x *HTTPResponse) Reset()

func (*HTTPResponse) String 

func (x *HTTPResponse) String() string
type Header struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetValues 

func (x *Header) GetValues() []string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type NotifyClientShutdownRequest 

type NotifyClientShutdownRequest struct {
	ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyClientShutdownRequest) Descriptor deprecated 

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

Deprecated: Use NotifyClientShutdownRequest.ProtoReflect.Descriptor instead.

func (*NotifyClientShutdownRequest) GetClientID 

func (x *NotifyClientShutdownRequest) GetClientID() string

func (*NotifyClientShutdownRequest) ProtoMessage 

func (*NotifyClientShutdownRequest) ProtoMessage()

func (*NotifyClientShutdownRequest) ProtoReflect 

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

func (*NotifyClientShutdownRequest) Reset 

func (x *NotifyClientShutdownRequest) Reset()

func (*NotifyClientShutdownRequest) String 

func (x *NotifyClientShutdownRequest) String() string

type NotifyClientShutdownResponse 

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

func (*NotifyClientShutdownResponse) Descriptor deprecated 

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

Deprecated: Use NotifyClientShutdownResponse.ProtoReflect.Descriptor instead.

func (*NotifyClientShutdownResponse) ProtoMessage 

func (*NotifyClientShutdownResponse) ProtoMessage()

func (*NotifyClientShutdownResponse) ProtoReflect 

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

func (*NotifyClientShutdownResponse) Reset 

func (x *NotifyClientShutdownResponse) Reset()

func (*NotifyClientShutdownResponse) String 

func (x *NotifyClientShutdownResponse) String() string

type Type 

type Type int32
const (
	Type_HTTP_REQUEST Type = 0
	Type_GET_ID       Type = 1
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor deprecated 

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

Deprecated: Use Type.Descriptor instead.

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

type UnimplementedFrontendServer 

type UnimplementedFrontendServer struct {
}

UnimplementedFrontendServer must be embedded to have forward compatible implementations.

func (UnimplementedFrontendServer) NotifyClientShutdown 

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

func (UnimplementedFrontendServer) Process 

func (UnimplementedFrontendServer) Process(Frontend_ProcessServer) error

func (UnimplementedFrontendServer) ProcessTracepoint 

func (UnimplementedFrontendServer) ProcessTracepoint(Frontend_ProcessTracepointServer) error

type UnsafeFrontendServer 

type UnsafeFrontendServer interface {
	// contains filtered or unexported methods
}

UnsafeFrontendServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FrontendServer will result in compilation errors.

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.