blackrock_io

package
v0.0.0-...-be96ec6 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2021 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package blackrock_io is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSpec = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpec   = fmt.Errorf("proto: integer overflow")
)

Functions

func Decorate 

func Decorate(g *geoip2.Reader, r *http.Request, e *Envelope) error

func RegisterEnqueueHandler 

func RegisterEnqueueHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterEnqueueHandler registers the http handlers for service Enqueue to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterEnqueueHandlerClient 

func RegisterEnqueueHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EnqueueClient) error

RegisterEnqueueHandlerClient registers the http handlers for service Enqueue to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EnqueueClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EnqueueClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EnqueueClient" to call the correct interceptors.

func RegisterEnqueueHandlerFromEndpoint 

func RegisterEnqueueHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterEnqueueHandlerFromEndpoint is same as RegisterEnqueueHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterEnqueueHandlerServer 

func RegisterEnqueueHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EnqueueServer) error

RegisterEnqueueHandlerServer registers the http handlers for service Enqueue to "mux". UnaryRPC :call EnqueueServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEnqueueServer 

func RegisterEnqueueServer(s *grpc.Server, srv EnqueueServer)

func RegisterSearchHandler 

func RegisterSearchHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterSearchHandler registers the http handlers for service Search to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterSearchHandlerClient 

func RegisterSearchHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SearchClient) error

RegisterSearchHandlerClient registers the http handlers for service Search to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "SearchClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "SearchClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "SearchClient" to call the correct interceptors.

func RegisterSearchHandlerFromEndpoint 

func RegisterSearchHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterSearchHandlerFromEndpoint is same as RegisterSearchHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterSearchHandlerServer 

func RegisterSearchHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SearchServer) error

RegisterSearchHandlerServer registers the http handlers for service Search to "mux". UnaryRPC :call SearchServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterSearchServer 

func RegisterSearchServer(s *grpc.Server, srv SearchServer)

func ToString 

func ToString(v interface{}) string

func ValidateEnvelope 

func ValidateEnvelope(envelope *Envelope) error

Types

type Aggregate 

type Aggregate struct {
	Search    map[string]*CountPerKV `` /* 153-byte string literal not displayed */
	Count     map[string]*CountPerKV `` /* 151-byte string literal not displayed */
	ForeignId map[string]*CountPerKV `` /* 176-byte string literal not displayed */
	EventType map[string]*CountPerKV `` /* 176-byte string literal not displayed */
	Possible  map[string]uint32      `` /* 158-byte string literal not displayed */
	Total     uint32                 `protobuf:"varint,6,opt,name=total,proto3" json:"total,omitempty"`
	Sample    []*Hit                 `protobuf:"bytes,7,rep,name=sample,proto3" json:"sample,omitempty"`
	Chart     *Chart                 `protobuf:"bytes,8,opt,name=chart,proto3" json:"chart,omitempty"`
}

func (*Aggregate) Descriptor 

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

func (*Aggregate) GetChart 

func (m *Aggregate) GetChart() *Chart

func (*Aggregate) GetCount 

func (m *Aggregate) GetCount() map[string]*CountPerKV

func (*Aggregate) GetEventType 

func (m *Aggregate) GetEventType() map[string]*CountPerKV

func (*Aggregate) GetForeignId 

func (m *Aggregate) GetForeignId() map[string]*CountPerKV

func (*Aggregate) GetPossible 

func (m *Aggregate) GetPossible() map[string]uint32

func (*Aggregate) GetSample 

func (m *Aggregate) GetSample() []*Hit

func (*Aggregate) GetSearch 

func (m *Aggregate) GetSearch() map[string]*CountPerKV

func (*Aggregate) GetTotal 

func (m *Aggregate) GetTotal() uint32

func (*Aggregate) Marshal 

func (m *Aggregate) Marshal() (dAtA []byte, err error)

func (*Aggregate) MarshalTo 

func (m *Aggregate) MarshalTo(dAtA []byte) (int, error)

func (*Aggregate) MarshalToSizedBuffer 

func (m *Aggregate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Aggregate) ProtoMessage 

func (*Aggregate) ProtoMessage()

func (*Aggregate) Reset 

func (m *Aggregate) Reset()

func (*Aggregate) Size 

func (m *Aggregate) Size() (n int)

func (*Aggregate) String 

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal 

func (m *Aggregate) Unmarshal(dAtA []byte) error

func (*Aggregate) XXX_DiscardUnknown 

func (m *Aggregate) XXX_DiscardUnknown()

func (*Aggregate) XXX_Marshal 

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

func (*Aggregate) XXX_Merge 

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

func (*Aggregate) XXX_Size 

func (m *Aggregate) XXX_Size() int

func (*Aggregate) XXX_Unmarshal 

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

type AggregateRequest 

type AggregateRequest struct {
	Query         *SearchQueryRequest `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Fields        map[string]bool     `` /* 154-byte string literal not displayed */
	SampleLimit   int32               `protobuf:"varint,3,opt,name=sample_limit,json=sampleLimit,proto3" json:"sample_limit,omitempty"`
	TimeBucketSec uint32              `protobuf:"varint,4,opt,name=time_bucket_sec,json=timeBucketSec,proto3" json:"time_bucket_sec,omitempty"`
}

func (*AggregateRequest) Descriptor 

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

func (*AggregateRequest) GetFields 

func (m *AggregateRequest) GetFields() map[string]bool

func (*AggregateRequest) GetQuery 

func (m *AggregateRequest) GetQuery() *SearchQueryRequest

func (*AggregateRequest) GetSampleLimit 

func (m *AggregateRequest) GetSampleLimit() int32

func (*AggregateRequest) GetTimeBucketSec 

func (m *AggregateRequest) GetTimeBucketSec() uint32

func (*AggregateRequest) Marshal 

func (m *AggregateRequest) Marshal() (dAtA []byte, err error)

func (*AggregateRequest) MarshalTo 

func (m *AggregateRequest) MarshalTo(dAtA []byte) (int, error)

func (*AggregateRequest) MarshalToSizedBuffer 

func (m *AggregateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateRequest) ProtoMessage 

func (*AggregateRequest) ProtoMessage()

func (*AggregateRequest) Reset 

func (m *AggregateRequest) Reset()

func (*AggregateRequest) Size 

func (m *AggregateRequest) Size() (n int)

func (*AggregateRequest) String 

func (m *AggregateRequest) String() string

func (*AggregateRequest) Unmarshal 

func (m *AggregateRequest) Unmarshal(dAtA []byte) error

func (*AggregateRequest) XXX_DiscardUnknown 

func (m *AggregateRequest) XXX_DiscardUnknown()

func (*AggregateRequest) XXX_Marshal 

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

func (*AggregateRequest) XXX_Merge 

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

func (*AggregateRequest) XXX_Size 

func (m *AggregateRequest) XXX_Size() int

func (*AggregateRequest) XXX_Unmarshal 

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

type BasicMetadata 

type BasicMetadata struct {
	CreatedAtNs int64  `protobuf:"varint,5,opt,name=created_at_ns,json=createdAtNs,proto3" json:"created_at_ns,omitempty"`
	EventType   string `protobuf:"bytes,7,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	ForeignId   string `protobuf:"bytes,9,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"`
	ForeignType string `protobuf:"bytes,10,opt,name=foreign_type,json=foreignType,proto3" json:"foreign_type,omitempty"`
}

func (*BasicMetadata) Descriptor 

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

func (*BasicMetadata) GetCreatedAtNs 

func (m *BasicMetadata) GetCreatedAtNs() int64

func (*BasicMetadata) GetEventType 

func (m *BasicMetadata) GetEventType() string

func (*BasicMetadata) GetForeignId 

func (m *BasicMetadata) GetForeignId() string

func (*BasicMetadata) GetForeignType 

func (m *BasicMetadata) GetForeignType() string

func (*BasicMetadata) Marshal 

func (m *BasicMetadata) Marshal() (dAtA []byte, err error)

func (*BasicMetadata) MarshalTo 

func (m *BasicMetadata) MarshalTo(dAtA []byte) (int, error)

func (*BasicMetadata) MarshalToSizedBuffer 

func (m *BasicMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BasicMetadata) ProtoMessage 

func (*BasicMetadata) ProtoMessage()

func (*BasicMetadata) Reset 

func (m *BasicMetadata) Reset()

func (*BasicMetadata) Size 

func (m *BasicMetadata) Size() (n int)

func (*BasicMetadata) String 

func (m *BasicMetadata) String() string

func (*BasicMetadata) Unmarshal 

func (m *BasicMetadata) Unmarshal(dAtA []byte) error

func (*BasicMetadata) XXX_DiscardUnknown 

func (m *BasicMetadata) XXX_DiscardUnknown()

func (*BasicMetadata) XXX_Marshal 

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

func (*BasicMetadata) XXX_Merge 

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

func (*BasicMetadata) XXX_Size 

func (m *BasicMetadata) XXX_Size() int

func (*BasicMetadata) XXX_Unmarshal 

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

type Chart 

type Chart struct {
	Buckets       map[uint32]*ChartBucketPerTime `` /* 156-byte string literal not displayed */
	TimeStart     uint32                         `protobuf:"varint,2,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty"`
	TimeEnd       uint32                         `protobuf:"varint,3,opt,name=time_end,json=timeEnd,proto3" json:"time_end,omitempty"`
	TimeBucketSec uint32                         `protobuf:"varint,4,opt,name=time_bucket_sec,json=timeBucketSec,proto3" json:"time_bucket_sec,omitempty"`
}

func (*Chart) Descriptor 

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

func (*Chart) GetBuckets 

func (m *Chart) GetBuckets() map[uint32]*ChartBucketPerTime

func (*Chart) GetTimeBucketSec 

func (m *Chart) GetTimeBucketSec() uint32

func (*Chart) GetTimeEnd 

func (m *Chart) GetTimeEnd() uint32

func (*Chart) GetTimeStart 

func (m *Chart) GetTimeStart() uint32

func (*Chart) Marshal 

func (m *Chart) Marshal() (dAtA []byte, err error)

func (*Chart) MarshalTo 

func (m *Chart) MarshalTo(dAtA []byte) (int, error)

func (*Chart) MarshalToSizedBuffer 

func (m *Chart) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Chart) ProtoMessage 

func (*Chart) ProtoMessage()

func (*Chart) Reset 

func (m *Chart) Reset()

func (*Chart) Size 

func (m *Chart) Size() (n int)

func (*Chart) String 

func (m *Chart) String() string

func (*Chart) Unmarshal 

func (m *Chart) Unmarshal(dAtA []byte) error

func (*Chart) XXX_DiscardUnknown 

func (m *Chart) XXX_DiscardUnknown()

func (*Chart) XXX_Marshal 

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

func (*Chart) XXX_Merge 

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

func (*Chart) XXX_Size 

func (m *Chart) XXX_Size() int

func (*Chart) XXX_Unmarshal 

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

type ChartBucketPerTime 

type ChartBucketPerTime struct {
	PerType map[string]*PointPerEventType `` /* 170-byte string literal not displayed */
}

func (*ChartBucketPerTime) Descriptor 

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

func (*ChartBucketPerTime) GetPerType 

func (m *ChartBucketPerTime) GetPerType() map[string]*PointPerEventType

func (*ChartBucketPerTime) Marshal 

func (m *ChartBucketPerTime) Marshal() (dAtA []byte, err error)

func (*ChartBucketPerTime) MarshalTo 

func (m *ChartBucketPerTime) MarshalTo(dAtA []byte) (int, error)

func (*ChartBucketPerTime) MarshalToSizedBuffer 

func (m *ChartBucketPerTime) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChartBucketPerTime) ProtoMessage 

func (*ChartBucketPerTime) ProtoMessage()

func (*ChartBucketPerTime) Reset 

func (m *ChartBucketPerTime) Reset()

func (*ChartBucketPerTime) Size 

func (m *ChartBucketPerTime) Size() (n int)

func (*ChartBucketPerTime) String 

func (m *ChartBucketPerTime) String() string

func (*ChartBucketPerTime) Unmarshal 

func (m *ChartBucketPerTime) Unmarshal(dAtA []byte) error

func (*ChartBucketPerTime) XXX_DiscardUnknown 

func (m *ChartBucketPerTime) XXX_DiscardUnknown()

func (*ChartBucketPerTime) XXX_Marshal 

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

func (*ChartBucketPerTime) XXX_Merge 

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

func (*ChartBucketPerTime) XXX_Size 

func (m *ChartBucketPerTime) XXX_Size() int

func (*ChartBucketPerTime) XXX_Unmarshal 

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

type CountPerKV 

type CountPerKV struct {
	Count map[string]uint32 `` /* 152-byte string literal not displayed */
	Total uint32            `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Key   string            `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
}

func (*CountPerKV) Descriptor 

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

func (*CountPerKV) GetCount 

func (m *CountPerKV) GetCount() map[string]uint32

func (*CountPerKV) GetKey 

func (m *CountPerKV) GetKey() string

func (*CountPerKV) GetTotal 

func (m *CountPerKV) GetTotal() uint32

func (*CountPerKV) Marshal 

func (m *CountPerKV) Marshal() (dAtA []byte, err error)

func (*CountPerKV) MarshalTo 

func (m *CountPerKV) MarshalTo(dAtA []byte) (int, error)

func (*CountPerKV) MarshalToSizedBuffer 

func (m *CountPerKV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CountPerKV) ProtoMessage 

func (*CountPerKV) ProtoMessage()

func (*CountPerKV) Reset 

func (m *CountPerKV) Reset()

func (*CountPerKV) Size 

func (m *CountPerKV) Size() (n int)

func (*CountPerKV) String 

func (m *CountPerKV) String() string

func (*CountPerKV) Unmarshal 

func (m *CountPerKV) Unmarshal(dAtA []byte) error

func (*CountPerKV) XXX_DiscardUnknown 

func (m *CountPerKV) XXX_DiscardUnknown()

func (*CountPerKV) XXX_Marshal 

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

func (*CountPerKV) XXX_Merge 

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

func (*CountPerKV) XXX_Size 

func (m *CountPerKV) XXX_Size() int

func (*CountPerKV) XXX_Unmarshal 

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

type CountableMetadata 

type CountableMetadata struct {
	Search      []KV   `protobuf:"bytes,1,rep,name=search,proto3" json:"search"`
	Count       []KV   `protobuf:"bytes,2,rep,name=count,proto3" json:"count"`
	CreatedAtNs int64  `protobuf:"varint,5,opt,name=created_at_ns,json=createdAtNs,proto3" json:"created_at_ns,omitempty"`
	EventType   string `protobuf:"bytes,7,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	ForeignId   string `protobuf:"bytes,9,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"`
	ForeignType string `protobuf:"bytes,10,opt,name=foreign_type,json=foreignType,proto3" json:"foreign_type,omitempty"`
}

func (*CountableMetadata) Descriptor 

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

func (*CountableMetadata) GetCount 

func (m *CountableMetadata) GetCount() []KV

func (*CountableMetadata) GetCreatedAtNs 

func (m *CountableMetadata) GetCreatedAtNs() int64

func (*CountableMetadata) GetEventType 

func (m *CountableMetadata) GetEventType() string

func (*CountableMetadata) GetForeignId 

func (m *CountableMetadata) GetForeignId() string

func (*CountableMetadata) GetForeignType 

func (m *CountableMetadata) GetForeignType() string

func (*CountableMetadata) GetSearch 

func (m *CountableMetadata) GetSearch() []KV

func (*CountableMetadata) Marshal 

func (m *CountableMetadata) Marshal() (dAtA []byte, err error)

func (*CountableMetadata) MarshalTo 

func (m *CountableMetadata) MarshalTo(dAtA []byte) (int, error)

func (*CountableMetadata) MarshalToSizedBuffer 

func (m *CountableMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CountableMetadata) ProtoMessage 

func (*CountableMetadata) ProtoMessage()

func (*CountableMetadata) Reset 

func (m *CountableMetadata) Reset()

func (*CountableMetadata) Size 

func (m *CountableMetadata) Size() (n int)

func (*CountableMetadata) String 

func (m *CountableMetadata) String() string

func (*CountableMetadata) Unmarshal 

func (m *CountableMetadata) Unmarshal(dAtA []byte) error

func (*CountableMetadata) XXX_DiscardUnknown 

func (m *CountableMetadata) XXX_DiscardUnknown()

func (*CountableMetadata) XXX_Marshal 

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

func (*CountableMetadata) XXX_Merge 

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

func (*CountableMetadata) XXX_Size 

func (m *CountableMetadata) XXX_Size() int

func (*CountableMetadata) XXX_Unmarshal 

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

type EnqueueClient 

type EnqueueClient interface {
	SayPush(ctx context.Context, opts ...grpc.CallOption) (Enqueue_SayPushClient, error)
	SayHealth(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*Success, error)
}

EnqueueClient is the client API for Enqueue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEnqueueClient 

func NewEnqueueClient(cc *grpc.ClientConn) EnqueueClient

type EnqueueServer 

type EnqueueServer interface {
	SayPush(Enqueue_SayPushServer) error
	SayHealth(context.Context, *HealthRequest) (*Success, error)
}

EnqueueServer is the server API for Enqueue service.

type Enqueue_SayPushClient 

type Enqueue_SayPushClient interface {
	Send(*Envelope) error
	CloseAndRecv() (*Success, error)
	grpc.ClientStream
}

type Enqueue_SayPushServer 

type Enqueue_SayPushServer interface {
	SendAndClose(*Success) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

type Envelope 

type Envelope struct {
	Metadata *Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Payload  []byte    `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

func DecodeAndFlatten 

func DecodeAndFlatten(body io.Reader) (*Envelope, error)

func (*Envelope) Descriptor 

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

func (*Envelope) GetMetadata 

func (m *Envelope) GetMetadata() *Metadata

func (*Envelope) GetPayload 

func (m *Envelope) GetPayload() []byte

func (*Envelope) Marshal 

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo 

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) MarshalToSizedBuffer 

func (m *Envelope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Envelope) ProtoMessage 

func (*Envelope) ProtoMessage()

func (*Envelope) Reset 

func (m *Envelope) Reset()

func (*Envelope) Size 

func (m *Envelope) Size() (n int)

func (*Envelope) String 

func (m *Envelope) String() string

func (*Envelope) Unmarshal 

func (m *Envelope) Unmarshal(dAtA []byte) error

func (*Envelope) XXX_DiscardUnknown 

func (m *Envelope) XXX_DiscardUnknown()

func (*Envelope) XXX_Marshal 

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

func (*Envelope) XXX_Merge 

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

func (*Envelope) XXX_Size 

func (m *Envelope) XXX_Size() int

func (*Envelope) XXX_Unmarshal 

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

type HealthRequest 

type HealthRequest struct {
}

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) Marshal 

func (m *HealthRequest) Marshal() (dAtA []byte, err error)

func (*HealthRequest) MarshalTo 

func (m *HealthRequest) MarshalTo(dAtA []byte) (int, error)

func (*HealthRequest) MarshalToSizedBuffer 

func (m *HealthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) Size 

func (m *HealthRequest) Size() (n int)

func (*HealthRequest) String 

func (m *HealthRequest) String() string

func (*HealthRequest) Unmarshal 

func (m *HealthRequest) Unmarshal(dAtA []byte) error

func (*HealthRequest) XXX_DiscardUnknown 

func (m *HealthRequest) XXX_DiscardUnknown()

func (*HealthRequest) XXX_Marshal 

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

func (*HealthRequest) XXX_Merge 

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

func (*HealthRequest) XXX_Size 

func (m *HealthRequest) XXX_Size() int

func (*HealthRequest) XXX_Unmarshal 

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

type Hit 

type Hit struct {
	Id       uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Score    float32   `protobuf:"fixed32,2,opt,name=score,proto3" json:"score,omitempty"`
	Metadata *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*Hit) Descriptor 

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

func (*Hit) GetId 

func (m *Hit) GetId() uint64

func (*Hit) GetMetadata 

func (m *Hit) GetMetadata() *Metadata

func (*Hit) GetScore 

func (m *Hit) GetScore() float32

func (*Hit) Marshal 

func (m *Hit) Marshal() (dAtA []byte, err error)

func (*Hit) MarshalTo 

func (m *Hit) MarshalTo(dAtA []byte) (int, error)

func (*Hit) MarshalToSizedBuffer 

func (m *Hit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Hit) ProtoMessage 

func (*Hit) ProtoMessage()

func (*Hit) Reset 

func (m *Hit) Reset()

func (*Hit) Size 

func (m *Hit) Size() (n int)

func (*Hit) String 

func (m *Hit) String() string

func (*Hit) Unmarshal 

func (m *Hit) Unmarshal(dAtA []byte) error

func (*Hit) XXX_DiscardUnknown 

func (m *Hit) XXX_DiscardUnknown()

func (*Hit) XXX_Marshal 

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

func (*Hit) XXX_Merge 

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

func (*Hit) XXX_Size 

func (m *Hit) XXX_Size() int

func (*Hit) XXX_Unmarshal 

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

type JsonFrame 

type JsonFrame struct {
	Search      map[string]interface{} `json:"search"`
	Count       map[string]interface{} `json:"count"`
	Properties  map[string]interface{} `json:"properties"`
	CreatedAtNs int64                  `json:"created_at_ns"`
	ForeignId   string                 `json:"foreign_id"`
	ForeignType string                 `json:"foreign_type"`
	EventType   string                 `json:"event_type"`
	Payload     interface{}            `json:"payload"`
}

type KF 

type KF struct {
	Key   string  `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*KF) Descriptor 

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

func (*KF) GetKey 

func (m *KF) GetKey() string

func (*KF) GetValue 

func (m *KF) GetValue() float64

func (*KF) Marshal 

func (m *KF) Marshal() (dAtA []byte, err error)

func (*KF) MarshalTo 

func (m *KF) MarshalTo(dAtA []byte) (int, error)

func (*KF) MarshalToSizedBuffer 

func (m *KF) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KF) ProtoMessage 

func (*KF) ProtoMessage()

func (*KF) Reset 

func (m *KF) Reset()

func (*KF) Size 

func (m *KF) Size() (n int)

func (*KF) String 

func (m *KF) String() string

func (*KF) Unmarshal 

func (m *KF) Unmarshal(dAtA []byte) error

func (*KF) XXX_DiscardUnknown 

func (m *KF) XXX_DiscardUnknown()

func (*KF) XXX_Marshal 

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

func (*KF) XXX_Merge 

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

func (*KF) XXX_Size 

func (m *KF) XXX_Size() int

func (*KF) XXX_Unmarshal 

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

type KV 

type KV struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func ToKV 

func ToKV(key string, v interface{}) KV

func Transform 

func Transform(m map[string]interface{}, expand bool) ([]KV, error)

func (*KV) Descriptor 

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

func (*KV) GetKey 

func (m *KV) GetKey() string

func (*KV) GetValue 

func (m *KV) GetValue() string

func (*KV) Marshal 

func (m *KV) Marshal() (dAtA []byte, err error)

func (*KV) MarshalTo 

func (m *KV) MarshalTo(dAtA []byte) (int, error)

func (*KV) MarshalToSizedBuffer 

func (m *KV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) Reset 

func (m *KV) Reset()

func (*KV) Size 

func (m *KV) Size() (n int)

func (*KV) String 

func (m *KV) String() string

func (*KV) Unmarshal 

func (m *KV) Unmarshal(dAtA []byte) error

func (*KV) XXX_DiscardUnknown 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal 

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

func (*KV) XXX_Merge 

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

func (*KV) XXX_Size 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal 

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

type Metadata 

type Metadata struct {
	Search      []KV              `protobuf:"bytes,1,rep,name=search,proto3" json:"search"`
	Count       []KV              `protobuf:"bytes,2,rep,name=count,proto3" json:"count"`
	Properties  []KV              `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties"`
	CreatedAtNs int64             `protobuf:"varint,5,opt,name=created_at_ns,json=createdAtNs,proto3" json:"created_at_ns,omitempty"`
	EventType   string            `protobuf:"bytes,7,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	ForeignId   string            `protobuf:"bytes,9,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"`
	ForeignType string            `protobuf:"bytes,10,opt,name=foreign_type,json=foreignType,proto3" json:"foreign_type,omitempty"`
	Track       map[string]uint32 `` /* 153-byte string literal not displayed */
	Id          uint64            `protobuf:"fixed64,12,opt,name=id,proto3" json:"id,omitempty"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetCount 

func (m *Metadata) GetCount() []KV

func (*Metadata) GetCreatedAtNs 

func (m *Metadata) GetCreatedAtNs() int64

func (*Metadata) GetEventType 

func (m *Metadata) GetEventType() string

func (*Metadata) GetForeignId 

func (m *Metadata) GetForeignId() string

func (*Metadata) GetForeignType 

func (m *Metadata) GetForeignType() string

func (*Metadata) GetId 

func (m *Metadata) GetId() uint64

func (*Metadata) GetProperties 

func (m *Metadata) GetProperties() []KV

func (*Metadata) GetSearch 

func (m *Metadata) GetSearch() []KV

func (*Metadata) GetTrack 

func (m *Metadata) GetTrack() map[string]uint32

func (*Metadata) Marshal 

func (m *Metadata) Marshal() (dAtA []byte, err error)

func (*Metadata) MarshalTo 

func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

func (*Metadata) MarshalToSizedBuffer 

func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

func (m *Metadata) Size() (n int)

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

func (m *Metadata) Unmarshal(dAtA []byte) error

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type PointPerEventType 

type PointPerEventType struct {
	Count       uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	CountUnique uint32 `protobuf:"varint,2,opt,name=count_unique,json=countUnique,proto3" json:"count_unique,omitempty"`
	Bucket      uint32 `protobuf:"varint,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	EventType   string `protobuf:"bytes,4,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
}

func (*PointPerEventType) Descriptor 

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

func (*PointPerEventType) GetBucket 

func (m *PointPerEventType) GetBucket() uint32

func (*PointPerEventType) GetCount 

func (m *PointPerEventType) GetCount() uint32

func (*PointPerEventType) GetCountUnique 

func (m *PointPerEventType) GetCountUnique() uint32

func (*PointPerEventType) GetEventType 

func (m *PointPerEventType) GetEventType() string

func (*PointPerEventType) Marshal 

func (m *PointPerEventType) Marshal() (dAtA []byte, err error)

func (*PointPerEventType) MarshalTo 

func (m *PointPerEventType) MarshalTo(dAtA []byte) (int, error)

func (*PointPerEventType) MarshalToSizedBuffer 

func (m *PointPerEventType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PointPerEventType) ProtoMessage 

func (*PointPerEventType) ProtoMessage()

func (*PointPerEventType) Reset 

func (m *PointPerEventType) Reset()

func (*PointPerEventType) Size 

func (m *PointPerEventType) Size() (n int)

func (*PointPerEventType) String 

func (m *PointPerEventType) String() string

func (*PointPerEventType) Unmarshal 

func (m *PointPerEventType) Unmarshal(dAtA []byte) error

func (*PointPerEventType) XXX_DiscardUnknown 

func (m *PointPerEventType) XXX_DiscardUnknown()

func (*PointPerEventType) XXX_Marshal 

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

func (*PointPerEventType) XXX_Merge 

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

func (*PointPerEventType) XXX_Size 

func (m *PointPerEventType) XXX_Size() int

func (*PointPerEventType) XXX_Unmarshal 

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

type SearchClient 

type SearchClient interface {
	SayPush(ctx context.Context, opts ...grpc.CallOption) (Search_SayPushClient, error)
	SaySearch(ctx context.Context, in *SearchQueryRequest, opts ...grpc.CallOption) (*SearchQueryResponse, error)
	SayFetch(ctx context.Context, in *SearchQueryRequest, opts ...grpc.CallOption) (Search_SayFetchClient, error)
	SayAggregate(ctx context.Context, in *AggregateRequest, opts ...grpc.CallOption) (*Aggregate, error)
	SayHealth(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*Success, error)
}

SearchClient is the client API for Search service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSearchClient 

func NewSearchClient(cc *grpc.ClientConn) SearchClient

type SearchQueryRequest 

type SearchQueryRequest struct {
	FromSecond uint32                    `protobuf:"varint,1,opt,name=from_second,json=fromSecond,proto3" json:"from_second,omitempty"`
	ToSecond   uint32                    `protobuf:"varint,2,opt,name=to_second,json=toSecond,proto3" json:"to_second,omitempty"`
	Query      *go_query_index_dsl.Query `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	Limit      int32                     `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*SearchQueryRequest) Descriptor 

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

func (*SearchQueryRequest) GetFromSecond 

func (m *SearchQueryRequest) GetFromSecond() uint32

func (*SearchQueryRequest) GetLimit 

func (m *SearchQueryRequest) GetLimit() int32

func (*SearchQueryRequest) GetQuery 

func (m *SearchQueryRequest) GetQuery() *go_query_index_dsl.Query

func (*SearchQueryRequest) GetToSecond 

func (m *SearchQueryRequest) GetToSecond() uint32

func (*SearchQueryRequest) Marshal 

func (m *SearchQueryRequest) Marshal() (dAtA []byte, err error)

func (*SearchQueryRequest) MarshalTo 

func (m *SearchQueryRequest) MarshalTo(dAtA []byte) (int, error)

func (*SearchQueryRequest) MarshalToSizedBuffer 

func (m *SearchQueryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SearchQueryRequest) ProtoMessage 

func (*SearchQueryRequest) ProtoMessage()

func (*SearchQueryRequest) Reset 

func (m *SearchQueryRequest) Reset()

func (*SearchQueryRequest) Size 

func (m *SearchQueryRequest) Size() (n int)

func (*SearchQueryRequest) String 

func (m *SearchQueryRequest) String() string

func (*SearchQueryRequest) Unmarshal 

func (m *SearchQueryRequest) Unmarshal(dAtA []byte) error

func (*SearchQueryRequest) XXX_DiscardUnknown 

func (m *SearchQueryRequest) XXX_DiscardUnknown()

func (*SearchQueryRequest) XXX_Marshal 

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

func (*SearchQueryRequest) XXX_Merge 

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

func (*SearchQueryRequest) XXX_Size 

func (m *SearchQueryRequest) XXX_Size() int

func (*SearchQueryRequest) XXX_Unmarshal 

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

type SearchQueryResponse 

type SearchQueryResponse struct {
	Hits  []*Hit `protobuf:"bytes,1,rep,name=hits,proto3" json:"hits,omitempty"`
	Total uint64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
}

func (*SearchQueryResponse) Descriptor 

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

func (*SearchQueryResponse) GetHits 

func (m *SearchQueryResponse) GetHits() []*Hit

func (*SearchQueryResponse) GetTotal 

func (m *SearchQueryResponse) GetTotal() uint64

func (*SearchQueryResponse) Marshal 

func (m *SearchQueryResponse) Marshal() (dAtA []byte, err error)

func (*SearchQueryResponse) MarshalTo 

func (m *SearchQueryResponse) MarshalTo(dAtA []byte) (int, error)

func (*SearchQueryResponse) MarshalToSizedBuffer 

func (m *SearchQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SearchQueryResponse) ProtoMessage 

func (*SearchQueryResponse) ProtoMessage()

func (*SearchQueryResponse) Reset 

func (m *SearchQueryResponse) Reset()

func (*SearchQueryResponse) Size 

func (m *SearchQueryResponse) Size() (n int)

func (*SearchQueryResponse) String 

func (m *SearchQueryResponse) String() string

func (*SearchQueryResponse) Unmarshal 

func (m *SearchQueryResponse) Unmarshal(dAtA []byte) error

func (*SearchQueryResponse) XXX_DiscardUnknown 

func (m *SearchQueryResponse) XXX_DiscardUnknown()

func (*SearchQueryResponse) XXX_Marshal 

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

func (*SearchQueryResponse) XXX_Merge 

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

func (*SearchQueryResponse) XXX_Size 

func (m *SearchQueryResponse) XXX_Size() int

func (*SearchQueryResponse) XXX_Unmarshal 

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

type SearchServer 

type SearchServer interface {
	SayPush(Search_SayPushServer) error
	SaySearch(context.Context, *SearchQueryRequest) (*SearchQueryResponse, error)
	SayFetch(*SearchQueryRequest, Search_SayFetchServer) error
	SayAggregate(context.Context, *AggregateRequest) (*Aggregate, error)
	SayHealth(context.Context, *HealthRequest) (*Success, error)
}

SearchServer is the server API for Search service.

type Search_SayFetchClient 

type Search_SayFetchClient interface {
	Recv() (*Hit, error)
	grpc.ClientStream
}

type Search_SayFetchServer 

type Search_SayFetchServer interface {
	Send(*Hit) error
	grpc.ServerStream
}

type Search_SayPushClient 

type Search_SayPushClient interface {
	Send(*Envelope) error
	CloseAndRecv() (*Success, error)
	grpc.ClientStream
}

type Search_SayPushServer 

type Search_SayPushServer interface {
	SendAndClose(*Success) error
	Recv() (*Envelope, error)
	grpc.ServerStream
}

type SearchableMetadata 

type SearchableMetadata struct {
	Search      []KV              `protobuf:"bytes,1,rep,name=search,proto3" json:"search"`
	EventType   string            `protobuf:"bytes,7,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	ForeignId   string            `protobuf:"bytes,9,opt,name=foreign_id,json=foreignId,proto3" json:"foreign_id,omitempty"`
	ForeignType string            `protobuf:"bytes,10,opt,name=foreign_type,json=foreignType,proto3" json:"foreign_type,omitempty"`
	Track       map[string]uint32 `` /* 153-byte string literal not displayed */
}

func (*SearchableMetadata) Descriptor 

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

func (*SearchableMetadata) GetEventType 

func (m *SearchableMetadata) GetEventType() string

func (*SearchableMetadata) GetForeignId 

func (m *SearchableMetadata) GetForeignId() string

func (*SearchableMetadata) GetForeignType 

func (m *SearchableMetadata) GetForeignType() string

func (*SearchableMetadata) GetSearch 

func (m *SearchableMetadata) GetSearch() []KV

func (*SearchableMetadata) GetTrack 

func (m *SearchableMetadata) GetTrack() map[string]uint32

func (*SearchableMetadata) Marshal 

func (m *SearchableMetadata) Marshal() (dAtA []byte, err error)

func (*SearchableMetadata) MarshalTo 

func (m *SearchableMetadata) MarshalTo(dAtA []byte) (int, error)

func (*SearchableMetadata) MarshalToSizedBuffer 

func (m *SearchableMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SearchableMetadata) ProtoMessage 

func (*SearchableMetadata) ProtoMessage()

func (*SearchableMetadata) Reset 

func (m *SearchableMetadata) Reset()

func (*SearchableMetadata) Size 

func (m *SearchableMetadata) Size() (n int)

func (*SearchableMetadata) String 

func (m *SearchableMetadata) String() string

func (*SearchableMetadata) Unmarshal 

func (m *SearchableMetadata) Unmarshal(dAtA []byte) error

func (*SearchableMetadata) XXX_DiscardUnknown 

func (m *SearchableMetadata) XXX_DiscardUnknown()

func (*SearchableMetadata) XXX_Marshal 

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

func (*SearchableMetadata) XXX_Merge 

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

func (*SearchableMetadata) XXX_Size 

func (m *SearchableMetadata) XXX_Size() int

func (*SearchableMetadata) XXX_Unmarshal 

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

type Success 

type Success struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*Success) Descriptor 

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

func (*Success) GetSuccess 

func (m *Success) GetSuccess() bool

func (*Success) Marshal 

func (m *Success) Marshal() (dAtA []byte, err error)

func (*Success) MarshalTo 

func (m *Success) MarshalTo(dAtA []byte) (int, error)

func (*Success) MarshalToSizedBuffer 

func (m *Success) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Success) ProtoMessage 

func (*Success) ProtoMessage()

func (*Success) Reset 

func (m *Success) Reset()

func (*Success) Size 

func (m *Success) Size() (n int)

func (*Success) String 

func (m *Success) String() string

func (*Success) Unmarshal 

func (m *Success) Unmarshal(dAtA []byte) error

func (*Success) XXX_DiscardUnknown 

func (m *Success) XXX_DiscardUnknown()

func (*Success) XXX_Marshal 

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

func (*Success) XXX_Merge 

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

func (*Success) XXX_Size 

func (m *Success) XXX_Size() int

func (*Success) XXX_Unmarshal 

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

type UnimplementedEnqueueServer 

type UnimplementedEnqueueServer struct {
}

UnimplementedEnqueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedEnqueueServer) SayHealth 

func (*UnimplementedEnqueueServer) SayHealth(ctx context.Context, req *HealthRequest) (*Success, error)

func (*UnimplementedEnqueueServer) SayPush 

func (*UnimplementedEnqueueServer) SayPush(srv Enqueue_SayPushServer) error

type UnimplementedSearchServer 

type UnimplementedSearchServer struct {
}

UnimplementedSearchServer can be embedded to have forward compatible implementations.

func (*UnimplementedSearchServer) SayAggregate 

func (*UnimplementedSearchServer) SayAggregate(ctx context.Context, req *AggregateRequest) (*Aggregate, error)

func (*UnimplementedSearchServer) SayFetch 

func (*UnimplementedSearchServer) SayFetch(req *SearchQueryRequest, srv Search_SayFetchServer) error

func (*UnimplementedSearchServer) SayHealth 

func (*UnimplementedSearchServer) SayHealth(ctx context.Context, req *HealthRequest) (*Success, error)

func (*UnimplementedSearchServer) SayPush 

func (*UnimplementedSearchServer) SayPush(srv Search_SayPushServer) error

func (*UnimplementedSearchServer) SaySearch 

func (*UnimplementedSearchServer) SaySearch(ctx context.Context, req *SearchQueryRequest) (*SearchQueryResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.