grpc

Documentation

Overview

Copyright (C) 2019-2023 vdaas.org vald team <vald@vdaas.org>

Licensed under the Apache License, Version 2.0 (the "License"); You may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Package grpc provides grpc server logic

Package grpc provides grpc server logic

Copyright (C) 2019-2023 vdaas.org vald team <vald@vdaas.org>

Licensed under the Apache License, Version 2.0 (the "License"); You may not use this file except in compliance with the License. You may obtain a copy of the License at

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• func New(opts ...Option) vald.Server
• type Aggregator
• type DistPayload
• type Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithGateway(g service.Gateway) Option
  • func WithIP(ip string) Option
  • func WithMultiConcurrency(c int) Option
  • func WithName(name string) Option
  • func WithReplicationCount(rep int) Option
  • func WithStreamConcurrency(c int) Option
  • func WithTimeout(dur string) Option
• type PairingHeap
  • func (ph *PairingHeap) ExtractMin() (*DistPayload, *PairingHeap)
  • func (ph *PairingHeap) Insert(dp *DistPayload) *PairingHeap
  • func (ph *PairingHeap) IsEmpty() bool
  • func (ph *PairingHeap) Merge(h2 *PairingHeap) *PairingHeap

Functions

func New

func New(opts ...Option) vald.Server

Types

type Aggregator

type Aggregator interface {
	Start(ctx context.Context)
	Send(ctx context.Context, data *payload.Search_Response)
	Result() *payload.Search_Response
}

type DistPayload

type DistPayload struct {
	// contains filtered or unexported fields
}

type Option

type Option func(*server)

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

func WithGateway

func WithGateway(g service.Gateway) Option

func WithIP

func WithIP(ip string) Option

WithIP returns the option to set the IP for server.

func WithMultiConcurrency

func WithMultiConcurrency(c int) Option

func WithName

func WithName(name string) Option

WithName returns the option to set the name for server.

func WithReplicationCount

func WithReplicationCount(rep int) Option

func WithStreamConcurrency

func WithStreamConcurrency(c int) Option

func WithTimeout

func WithTimeout(dur string) Option

type PairingHeap

type PairingHeap struct {
	DistPayload *DistPayload
	Children    []*PairingHeap
}

func (*PairingHeap) ExtractMin

func (ph *PairingHeap) ExtractMin() (*DistPayload, *PairingHeap)

func (*PairingHeap) Insert

func (ph *PairingHeap) Insert(dp *DistPayload) *PairingHeap

func (*PairingHeap) IsEmpty

func (ph *PairingHeap) IsEmpty() bool

func (*PairingHeap) Merge

func (ph *PairingHeap) Merge(h2 *PairingHeap) *PairingHeap