peer

Documentation

Index

• type ConnectionHandlerFn
• type CreateServiceClientFn
• type PeerLeaveHandler
• type PeerPool
  • func NewPool[T ServiceClient](ctx context.Context, conf *config.Config, service *client.Service, ...) PeerPool[T]
• type ServiceClient

Types

type ConnectionHandlerFn

type ConnectionHandlerFn[T ServiceClient] func(address string, client T) bool

ConnectionHandlerFn returns true if the next connection can be handled. Return false if you do not want to handle the next connection.

type CreateServiceClientFn

type CreateServiceClientFn[T ServiceClient] func(cc grpc.ClientConnInterface) T

type PeerLeaveHandler

type PeerLeaveHandler func(address string)

type PeerPool

type PeerPool[T ServiceClient] interface {
	IsPeer(address string) bool
	Iterate(ctx context.Context, handler ConnectionHandlerFn[T]) error
	OnPeerLeave(handler PeerLeaveHandler)
}

func NewPool

func NewPool[T ServiceClient](
	ctx context.Context,
	conf *config.Config,
	service *client.Service,
	createServiceClient CreateServiceClientFn[T],
	ownIp string,
) PeerPool[T]

type ServiceClient

type ServiceClient any