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

        Source Files

        View all