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",
}
View Source
var Error_ErrorType_value = map[string]int32{
	"CANCELLED":           0,
	"BACKEND_UNAVAILABLE": 1,
	"FAILED":              2,
	"INVALID_QUERY":       3,
}
View Source
var Event_Type_name = map[int32]string{
	0: "ERROR",
	1: "PROGRESS",
	2: "MATCH",
	3: "PAGINATION",
	4: "DONE",
}
View Source
var Event_Type_value = map[string]int32{
	"ERROR":      0,
	"PROGRESS":   1,
	"MATCH":      2,
	"PAGINATION": 3,
	"DONE":       4,
}

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

    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.ClientConn) DCSClient

    type DCSServer

    type DCSServer interface {
    	Search(*SearchRequest, DCS_SearchServer) error
    }

      DCSServer is the server API for DCS service.

      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"`
      	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
      	XXX_unrecognized     []byte          `json:"-"`
      	XXX_sizecache        int32           `json:"-"`
      }

      func (*Error) Descriptor

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

      func (*Error) GetMessage

      func (m *Error) GetMessage() string

      func (*Error) GetType

      func (m *Error) GetType() Error_ErrorType

      func (*Error) ProtoMessage

      func (*Error) ProtoMessage()

      func (*Error) Reset

      func (m *Error) Reset()

      func (*Error) String

      func (m *Error) String() string

      func (*Error) XXX_DiscardUnknown

      func (m *Error) XXX_DiscardUnknown()

      func (*Error) XXX_Marshal

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

      func (*Error) XXX_Merge

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

      func (*Error) XXX_Size

      func (m *Error) XXX_Size() int

      func (*Error) XXX_Unmarshal

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

      type Error_ErrorType

      type Error_ErrorType int32
      const (
      	Error_CANCELLED           Error_ErrorType = 0
      	Error_BACKEND_UNAVAILABLE Error_ErrorType = 1
      	Error_FAILED              Error_ErrorType = 2
      	Error_INVALID_QUERY       Error_ErrorType = 3
      )

      func (Error_ErrorType) EnumDescriptor

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

      func (Error_ErrorType) String

      func (x Error_ErrorType) String() string

      type Event

      type Event struct {
      	// Types that are valid to be assigned to Data:
      	//	*Event_Error
      	//	*Event_Progress
      	//	*Event_Match
      	//	*Event_Pagination
      	Data                 isEvent_Data `protobuf_oneof:"data"`
      	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
      	XXX_unrecognized     []byte       `json:"-"`
      	XXX_sizecache        int32        `json:"-"`
      }

      func (*Event) Descriptor

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

      func (*Event) GetData

      func (m *Event) GetData() isEvent_Data

      func (*Event) GetError

      func (m *Event) GetError() *Error

      func (*Event) GetMatch

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

      func (*Event) GetPagination

      func (m *Event) GetPagination() *Pagination

      func (*Event) GetProgress

      func (m *Event) GetProgress() *Progress

      func (*Event) ProtoMessage

      func (*Event) ProtoMessage()

      func (*Event) Reset

      func (m *Event) Reset()

      func (*Event) String

      func (m *Event) String() string

      func (*Event) XXX_DiscardUnknown

      func (m *Event) XXX_DiscardUnknown()

      func (*Event) XXX_Marshal

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

      func (*Event) XXX_Merge

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

      func (*Event) XXX_OneofFuncs

      func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

        XXX_OneofFuncs is for the internal use of the proto package.

        func (*Event) XXX_Size

        func (m *Event) XXX_Size() int

        func (*Event) XXX_Unmarshal

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

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

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

        func (Event_Type) String

        func (x Event_Type) String() string

        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"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

        func (*Pagination) Descriptor

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

        func (*Pagination) GetQueryId

        func (m *Pagination) GetQueryId() string

        func (*Pagination) GetResultPages

        func (m *Pagination) GetResultPages() int64

        func (*Pagination) ProtoMessage

        func (*Pagination) ProtoMessage()

        func (*Pagination) Reset

        func (m *Pagination) Reset()

        func (*Pagination) String

        func (m *Pagination) String() string

        func (*Pagination) XXX_DiscardUnknown

        func (m *Pagination) XXX_DiscardUnknown()

        func (*Pagination) XXX_Marshal

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

        func (*Pagination) XXX_Merge

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

        func (*Pagination) XXX_Size

        func (m *Pagination) XXX_Size() int

        func (*Pagination) XXX_Unmarshal

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

        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"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

        func (*Progress) Descriptor

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

        func (*Progress) GetFilesProcessed

        func (m *Progress) GetFilesProcessed() int64

        func (*Progress) GetFilesTotal

        func (m *Progress) GetFilesTotal() int64

        func (*Progress) GetQueryId

        func (m *Progress) GetQueryId() string

        func (*Progress) GetResults

        func (m *Progress) GetResults() int64

        func (*Progress) ProtoMessage

        func (*Progress) ProtoMessage()

        func (*Progress) Reset

        func (m *Progress) Reset()

        func (*Progress) String

        func (m *Progress) String() string

        func (*Progress) XXX_DiscardUnknown

        func (m *Progress) XXX_DiscardUnknown()

        func (*Progress) XXX_Marshal

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

        func (*Progress) XXX_Merge

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

        func (*Progress) XXX_Size

        func (m *Progress) XXX_Size() int

        func (*Progress) XXX_Unmarshal

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

        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"`
        	XXX_NoUnkeyedLiteral struct{} `json:"-"`
        	XXX_unrecognized     []byte   `json:"-"`
        	XXX_sizecache        int32    `json:"-"`
        }

        func (*SearchRequest) Descriptor

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

        func (*SearchRequest) GetLiteral

        func (m *SearchRequest) GetLiteral() bool

        func (*SearchRequest) GetQuery

        func (m *SearchRequest) GetQuery() string

        func (*SearchRequest) ProtoMessage

        func (*SearchRequest) ProtoMessage()

        func (*SearchRequest) Reset

        func (m *SearchRequest) Reset()

        func (*SearchRequest) String

        func (m *SearchRequest) String() string

        func (*SearchRequest) XXX_DiscardUnknown

        func (m *SearchRequest) XXX_DiscardUnknown()

        func (*SearchRequest) XXX_Marshal

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

        func (*SearchRequest) XXX_Merge

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

        func (*SearchRequest) XXX_Size

        func (m *SearchRequest) XXX_Size() int

        func (*SearchRequest) XXX_Unmarshal

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