wggrpc

Mar 22, 2024

Changes in this version

+ const PeerAddrKey

+ type AllowedPeers struct

+ func NewAllowedPeers() *AllowedPeers

+ func (p *AllowedPeers) AddToken(pubKey wgtypes.Key, token string)

+ func (p *AllowedPeers) CheckToken(token string) bool

+ func (p *AllowedPeers) RemoveToken(pubKey wgtypes.Key)

+ type Relay struct

+ func NewRelay(conn *grpc.ClientConn, retryTimeout time.Duration, queues *wgbind.QueuePair, ...) *Relay

+ func NewRelayToHost(host string, retryTimeout time.Duration, queues *wgbind.QueuePair, ...) (*Relay, error)

+ func (r *Relay) Close()

+ func (r *Relay) IsClosed() bool

+ func (r *Relay) Run(ctx context.Context, logger *zap.Logger) error

+ type Service struct

+ func NewService(pt *wgbind.PeerTraffic, allowed *AllowedPeers, logger *zap.Logger) *Service

+ func (s *Service) CreateStream(srv pb.WireGuardOverGRPCService_CreateStreamServer) error

+ func (s *Service) Wait()