dcspb

package
Version: v0.0.0-...-c88c75b Latest Latest
Warning

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

Go to latest
Published: Mar 24, 2022 License: BSD-3-Clause Imports: 10 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.

Functions

func RegisterDCSServer

func RegisterDCSServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#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
}

DCSServer is the server API for DCS service.

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 can be embedded to have forward compatible implementations.

func (*UnimplementedDCSServer) Results

func (*UnimplementedDCSServer) Search

Jump to

Keyboard shortcuts

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