grpc

Documentation

Overview

Package grpc provides grpc server logic

Package grpc provides grpc server logic

Index

• func New(opts ...Option) vald.Server
• 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

Functions

func New

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

Types

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