dcspb

package
v0.0.0-...-1542595 Latest Latest
Warning

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

Go to latest
Published: Mar 13, 2024 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Error_ErrorType_name = map[int32]string{
		0: "CANCELLED",
		1: "BACKEND_UNAVAILABLE",
		2: "FAILED",
		3: "INVALID_QUERY",
	}
	Error_ErrorType_value = map[string]int32{
		"CANCELLED":           0,
		"BACKEND_UNAVAILABLE": 1,
		"FAILED":              2,
		"INVALID_QUERY":       3,
	}
)

Enum value maps for Error_ErrorType.

View Source
var (
	Event_Type_name = map[int32]string{
		0: "ERROR",
		1: "PROGRESS",
		2: "MATCH",
		3: "PAGINATION",
		4: "DONE",
	}
	Event_Type_value = map[string]int32{
		"ERROR":      0,
		"PROGRESS":   1,
		"MATCH":      2,
		"PAGINATION": 3,
		"DONE":       4,
	}
)

Enum value maps for Event_Type.

View Source
var DCS_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dcspb.DCS",
	HandlerType: (*DCSServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _DCS_Search_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Results",
			Handler:       _DCS_Results_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "dcs.proto",
}

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

Functions

func RegisterDCSServer

func RegisterDCSServer(s grpc.ServiceRegistrar, srv DCSServer)

Types

type DCSClient

type DCSClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (DCS_SearchClient, error)
	Results(ctx context.Context, in *ResultsRequest, opts ...grpc.CallOption) (DCS_ResultsClient, error)
}

DCSClient is the client API for DCS 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 NewDCSClient

func NewDCSClient(cc grpc.ClientConnInterface) DCSClient

type DCSServer

type DCSServer interface {
	Search(*SearchRequest, DCS_SearchServer) error
	Results(*ResultsRequest, DCS_ResultsServer) error
	// contains filtered or unexported methods
}

DCSServer is the server API for DCS service. All implementations must embed UnimplementedDCSServer for forward compatibility

type DCS_ResultsClient

type DCS_ResultsClient interface {
	Recv() (*sourcebackendpb.Match, error)
	grpc.ClientStream
}

type DCS_ResultsServer

type DCS_ResultsServer interface {
	Send(*sourcebackendpb.Match) error
	grpc.ServerStream
}

type DCS_SearchClient

type DCS_SearchClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type DCS_SearchServer

type DCS_SearchServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Error

type Error struct {
	Type    Error_ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=dcspb.Error_ErrorType" json:"type,omitempty"`
	Message string          `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage

func (x *Error) GetMessage() string

func (*Error) GetType

func (x *Error) GetType() Error_ErrorType

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

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

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

type Error_ErrorType

type Error_ErrorType int32
const (
	Error_CANCELLED           Error_ErrorType = 0
	Error_BACKEND_UNAVAILABLE Error_ErrorType = 1
	Error_FAILED              Error_ErrorType = 2 // TODO: is this reasonable?
	Error_INVALID_QUERY       Error_ErrorType = 3
)

func (Error_ErrorType) Descriptor

func (Error_ErrorType) Enum

func (x Error_ErrorType) Enum() *Error_ErrorType

func (Error_ErrorType) EnumDescriptor deprecated

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

Deprecated: Use Error_ErrorType.Descriptor instead.

func (Error_ErrorType) Number

func (Error_ErrorType) String

func (x Error_ErrorType) String() string

func (Error_ErrorType) Type

type Event

type Event struct {

	// Types that are assignable to Data:
	//	*Event_Error
	//	*Event_Progress
	//	*Event_Match
	//	*Event_Pagination
	Data isEvent_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetData

func (m *Event) GetData() isEvent_Data

func (*Event) GetError

func (x *Event) GetError() *Error

func (*Event) GetMatch

func (x *Event) GetMatch() *sourcebackendpb.Match

func (*Event) GetPagination

func (x *Event) GetPagination() *Pagination

func (*Event) GetProgress

func (x *Event) GetProgress() *Progress

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Event_Error

type Event_Error struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3,oneof"`
}

type Event_Match

type Event_Match struct {
	Match *sourcebackendpb.Match `protobuf:"bytes,3,opt,name=match,proto3,oneof"`
}

type Event_Pagination

type Event_Pagination struct {
	Pagination *Pagination `protobuf:"bytes,4,opt,name=pagination,proto3,oneof"`
}

type Event_Progress

type Event_Progress struct {
	Progress *Progress `protobuf:"bytes,2,opt,name=progress,proto3,oneof"`
}

type Event_Type

type Event_Type int32
const (
	Event_ERROR      Event_Type = 0
	Event_PROGRESS   Event_Type = 1
	Event_MATCH      Event_Type = 2
	Event_PAGINATION Event_Type = 3
	Event_DONE       Event_Type = 4
)

func (Event_Type) Descriptor

func (Event_Type) Descriptor() protoreflect.EnumDescriptor

func (Event_Type) Enum

func (x Event_Type) Enum() *Event_Type

func (Event_Type) EnumDescriptor deprecated

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

Deprecated: Use Event_Type.Descriptor instead.

func (Event_Type) Number

func (x Event_Type) Number() protoreflect.EnumNumber

func (Event_Type) String

func (x Event_Type) String() string

func (Event_Type) Type

type Pagination

type Pagination struct {
	QueryId     string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	ResultPages int64  `protobuf:"varint,2,opt,name=result_pages,json=resultPages,proto3" json:"result_pages,omitempty"`
	// contains filtered or unexported fields
}

func (*Pagination) Descriptor deprecated

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

Deprecated: Use Pagination.ProtoReflect.Descriptor instead.

func (*Pagination) GetQueryId

func (x *Pagination) GetQueryId() string

func (*Pagination) GetResultPages

func (x *Pagination) GetResultPages() int64

func (*Pagination) ProtoMessage

func (*Pagination) ProtoMessage()

func (*Pagination) ProtoReflect

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

func (*Pagination) Reset

func (x *Pagination) Reset()

func (*Pagination) String

func (x *Pagination) String() string

type Progress

type Progress struct {
	QueryId        string `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	FilesProcessed int64  `protobuf:"varint,2,opt,name=files_processed,json=filesProcessed,proto3" json:"files_processed,omitempty"`
	FilesTotal     int64  `protobuf:"varint,3,opt,name=files_total,json=filesTotal,proto3" json:"files_total,omitempty"`
	Results        int64  `protobuf:"varint,4,opt,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*Progress) Descriptor deprecated

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

Deprecated: Use Progress.ProtoReflect.Descriptor instead.

func (*Progress) GetFilesProcessed

func (x *Progress) GetFilesProcessed() int64

func (*Progress) GetFilesTotal

func (x *Progress) GetFilesTotal() int64

func (*Progress) GetQueryId

func (x *Progress) GetQueryId() string

func (*Progress) GetResults

func (x *Progress) GetResults() int64

func (*Progress) ProtoMessage

func (*Progress) ProtoMessage()

func (*Progress) ProtoReflect

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

func (*Progress) Reset

func (x *Progress) Reset()

func (*Progress) String

func (x *Progress) String() string

type ResultsRequest

type ResultsRequest struct {

	// See https://codesearch.debian.net/apikeys/
	Apikey  string `protobuf:"bytes,1,opt,name=apikey,proto3" json:"apikey,omitempty"`
	QueryId string `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultsRequest) Descriptor deprecated

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

Deprecated: Use ResultsRequest.ProtoReflect.Descriptor instead.

func (*ResultsRequest) GetApikey

func (x *ResultsRequest) GetApikey() string

func (*ResultsRequest) GetQueryId

func (x *ResultsRequest) GetQueryId() string

func (*ResultsRequest) ProtoMessage

func (*ResultsRequest) ProtoMessage()

func (*ResultsRequest) ProtoReflect

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

func (*ResultsRequest) Reset

func (x *ResultsRequest) Reset()

func (*ResultsRequest) String

func (x *ResultsRequest) String() string

type SearchRequest

type SearchRequest struct {
	Query   string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Literal bool   `protobuf:"varint,2,opt,name=literal,proto3" json:"literal,omitempty"`
	// See https://codesearch.debian.net/apikeys/
	Apikey string `protobuf:"bytes,3,opt,name=apikey,proto3" json:"apikey,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetApikey

func (x *SearchRequest) GetApikey() string

func (*SearchRequest) GetLiteral

func (x *SearchRequest) GetLiteral() bool

func (*SearchRequest) GetQuery

func (x *SearchRequest) GetQuery() string

func (*SearchRequest) ProtoMessage

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect

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

func (*SearchRequest) Reset

func (x *SearchRequest) Reset()

func (*SearchRequest) String

func (x *SearchRequest) String() string

type UnimplementedDCSServer

type UnimplementedDCSServer struct {
}

UnimplementedDCSServer must be embedded to have forward compatible implementations.

func (UnimplementedDCSServer) Results

func (UnimplementedDCSServer) Search

type UnsafeDCSServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL