service

Documentation

Overview

Package service manages the main logic of server.

Package service

Package service represents gateway's service logic

Index

• type Gateway
  • func NewGateway(opts ...Option) (gw Gateway, err error)
• type Option
  • func WithDiscoverer(c discoverer.Client) Option
  • func WithErrGroup(eg errgroup.Group) Option

Types

type Gateway

type Gateway interface {
	Start(ctx context.Context) (<-chan error, error)
	GetAgentCount(ctx context.Context) int
	Addrs(ctx context.Context) []string
	DoMulti(ctx context.Context, num int,
		f func(ctx context.Context, tgt string, ac vald.Client, copts ...grpc.CallOption) error) error
	BroadCast(ctx context.Context,
		f func(ctx context.Context, tgt string, ac vald.Client, copts ...grpc.CallOption) error) error
}

func NewGateway

func NewGateway(opts ...Option) (gw Gateway, err error)

type Option

type Option func(g *gateway) error

func WithDiscoverer

func WithDiscoverer(c discoverer.Client) Option

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option