Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + var ErrIntOverflowFrontend = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthFrontend = fmt.Errorf("proto: negative length found during unmarshaling") + var Type_name = map[int32]string + var Type_value = map[string]int32 + func RegisterFrontendServer(s *grpc.Server, srv FrontendServer) + type ClientToFrontend struct + ClientID string + HttpResponse *httpgrpc.HTTPResponse + Stats *stats.Stats + func (*ClientToFrontend) Descriptor() ([]byte, []int) + func (*ClientToFrontend) ProtoMessage() + func (m *ClientToFrontend) GetClientID() string + func (m *ClientToFrontend) GetHttpResponse() *httpgrpc.HTTPResponse + func (m *ClientToFrontend) GetStats() *stats.Stats + func (m *ClientToFrontend) Marshal() (dAtA []byte, err error) + func (m *ClientToFrontend) MarshalTo(dAtA []byte) (int, error) + func (m *ClientToFrontend) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClientToFrontend) Reset() + func (m *ClientToFrontend) Size() (n int) + func (m *ClientToFrontend) Unmarshal(dAtA []byte) error + func (m *ClientToFrontend) XXX_DiscardUnknown() + func (m *ClientToFrontend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClientToFrontend) XXX_Merge(src proto.Message) + func (m *ClientToFrontend) XXX_Size() int + func (m *ClientToFrontend) XXX_Unmarshal(b []byte) error + func (this *ClientToFrontend) Equal(that interface{}) bool + func (this *ClientToFrontend) GoString() string + func (this *ClientToFrontend) String() string + type FrontendClient interface + NotifyClientShutdown func(ctx context.Context, in *NotifyClientShutdownRequest, opts ...grpc.CallOption) (*NotifyClientShutdownResponse, error) + Process func(ctx context.Context, opts ...grpc.CallOption) (Frontend_ProcessClient, error) + func NewFrontendClient(cc *grpc.ClientConn) FrontendClient + type FrontendServer interface + NotifyClientShutdown func(context.Context, *NotifyClientShutdownRequest) (*NotifyClientShutdownResponse, error) + Process func(Frontend_ProcessServer) error + type FrontendToClient struct + HttpRequest *httpgrpc.HTTPRequest + StatsEnabled bool + Type Type + func (*FrontendToClient) Descriptor() ([]byte, []int) + func (*FrontendToClient) ProtoMessage() + func (m *FrontendToClient) GetHttpRequest() *httpgrpc.HTTPRequest + func (m *FrontendToClient) GetStatsEnabled() bool + func (m *FrontendToClient) GetType() Type + func (m *FrontendToClient) Marshal() (dAtA []byte, err error) + func (m *FrontendToClient) MarshalTo(dAtA []byte) (int, error) + func (m *FrontendToClient) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FrontendToClient) Reset() + func (m *FrontendToClient) Size() (n int) + func (m *FrontendToClient) Unmarshal(dAtA []byte) error + func (m *FrontendToClient) XXX_DiscardUnknown() + func (m *FrontendToClient) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FrontendToClient) XXX_Merge(src proto.Message) + func (m *FrontendToClient) XXX_Size() int + func (m *FrontendToClient) XXX_Unmarshal(b []byte) error + func (this *FrontendToClient) Equal(that interface{}) bool + func (this *FrontendToClient) GoString() string + func (this *FrontendToClient) String() string + type Frontend_ProcessClient interface + Recv func() (*FrontendToClient, error) + Send func(*ClientToFrontend) error + type Frontend_ProcessServer interface + Recv func() (*ClientToFrontend, error) + Send func(*FrontendToClient) error + type NotifyClientShutdownRequest struct + ClientID string + func (*NotifyClientShutdownRequest) Descriptor() ([]byte, []int) + func (*NotifyClientShutdownRequest) ProtoMessage() + func (m *NotifyClientShutdownRequest) GetClientID() string + func (m *NotifyClientShutdownRequest) Marshal() (dAtA []byte, err error) + func (m *NotifyClientShutdownRequest) MarshalTo(dAtA []byte) (int, error) + func (m *NotifyClientShutdownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotifyClientShutdownRequest) Reset() + func (m *NotifyClientShutdownRequest) Size() (n int) + func (m *NotifyClientShutdownRequest) Unmarshal(dAtA []byte) error + func (m *NotifyClientShutdownRequest) XXX_DiscardUnknown() + func (m *NotifyClientShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyClientShutdownRequest) XXX_Merge(src proto.Message) + func (m *NotifyClientShutdownRequest) XXX_Size() int + func (m *NotifyClientShutdownRequest) XXX_Unmarshal(b []byte) error + func (this *NotifyClientShutdownRequest) Equal(that interface{}) bool + func (this *NotifyClientShutdownRequest) GoString() string + func (this *NotifyClientShutdownRequest) String() string + type NotifyClientShutdownResponse struct + func (*NotifyClientShutdownResponse) Descriptor() ([]byte, []int) + func (*NotifyClientShutdownResponse) ProtoMessage() + func (m *NotifyClientShutdownResponse) Marshal() (dAtA []byte, err error) + func (m *NotifyClientShutdownResponse) MarshalTo(dAtA []byte) (int, error) + func (m *NotifyClientShutdownResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NotifyClientShutdownResponse) Reset() + func (m *NotifyClientShutdownResponse) Size() (n int) + func (m *NotifyClientShutdownResponse) Unmarshal(dAtA []byte) error + func (m *NotifyClientShutdownResponse) XXX_DiscardUnknown() + func (m *NotifyClientShutdownResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyClientShutdownResponse) XXX_Merge(src proto.Message) + func (m *NotifyClientShutdownResponse) XXX_Size() int + func (m *NotifyClientShutdownResponse) XXX_Unmarshal(b []byte) error + func (this *NotifyClientShutdownResponse) Equal(that interface{}) bool + func (this *NotifyClientShutdownResponse) GoString() string + func (this *NotifyClientShutdownResponse) String() string + type Type int32 + const GET_ID + const HTTP_REQUEST + func (Type) EnumDescriptor() ([]byte, []int) + func (x Type) String() string + type UnimplementedFrontendServer struct + func (*UnimplementedFrontendServer) NotifyClientShutdown(ctx context.Context, req *NotifyClientShutdownRequest) (*NotifyClientShutdownResponse, error) + func (*UnimplementedFrontendServer) Process(srv Frontend_ProcessServer) error