client

Documentation

Index

• Constants
• func MarshalCredential(myKey wgtypes.Key, myPort int, remoteKey string, credential *Credential, ...) (*proto.Message, error)
• type Client
• type ConnStateNotifier
• type Credential
  • func UnMarshalCredential(msg *proto.Message) (*Credential, error)
• type GrpcClient
  • func NewClient(ctx context.Context, addr string, key wgtypes.Key, tlsEnabled bool) (*GrpcClient, error)
  • func (c *GrpcClient) Close() error
  • func (c *GrpcClient) GetStatus() Status
  • func (c *GrpcClient) IsHealthy() bool
  • func (c *GrpcClient) Ready() bool
  • func (c *GrpcClient) Receive(ctx context.Context, msgHandler func(msg *proto.Message) error) error
  • func (c *GrpcClient) Send(msg *proto.Message) error
  • func (c *GrpcClient) SendToStream(msg *proto.EncryptedMessage) error
  • func (c *GrpcClient) SetConnStateListener(notifier ConnStateNotifier)
  • func (c *GrpcClient) SetOnReconnectedListener(fn func())
  • func (c *GrpcClient) StreamConnected() bool
  • func (c *GrpcClient) WaitStreamConnected()
• type MockClient
  • func (sm *MockClient) Close() error
  • func (sm *MockClient) GetStatus() Status
  • func (sm *MockClient) IsHealthy() bool
  • func (sm *MockClient) Ready() bool
  • func (sm *MockClient) Receive(ctx context.Context, msgHandler func(msg *proto.Message) error) error
  • func (sm *MockClient) Send(msg *proto.Message) error
  • func (sm *MockClient) SendToStream(msg *proto.EncryptedMessage) error
  • func (sm *MockClient) SetOnReconnectedListener(_ func())
  • func (sm *MockClient) StreamConnected() bool
  • func (sm *MockClient) WaitStreamConnected()
• type Status

Constants

const (
	// DirectCheck indicates support to direct mode checks
	DirectCheck uint32 = 1
)

Functions

func MarshalCredential

func MarshalCredential(myKey wgtypes.Key, myPort int, remoteKey string, credential *Credential, t proto.Body_Type, rosenpassPubKey []byte, rosenpassAddr string, relaySrvAddress string) (*proto.Message, error)

MarshalCredential marshal a Credential instance and returns a Message object

Types

type Client

type Client interface {
	io.Closer
	StreamConnected() bool
	GetStatus() Status
	Receive(ctx context.Context, msgHandler func(msg *proto.Message) error) error
	Ready() bool
	IsHealthy() bool
	WaitStreamConnected()
	SendToStream(msg *proto.EncryptedMessage) error
	Send(msg *proto.Message) error
	SetOnReconnectedListener(func())
}

type ConnStateNotifier

type ConnStateNotifier interface {
	MarkSignalDisconnected(error)
	MarkSignalConnected()
}

ConnStateNotifier is a wrapper interface of the status recorder

type Credential

type Credential struct {
	UFrag string
	Pwd   string
}

Credential is an instance of a GrpcClient's Credential

func UnMarshalCredential

func UnMarshalCredential(msg *proto.Message) (*Credential, error)

UnMarshalCredential parses the credentials from the message and returns a Credential instance

type GrpcClient

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

GrpcClient Wraps the Signal Exchange Service gRpc client

func NewClient

func NewClient(ctx context.Context, addr string, key wgtypes.Key, tlsEnabled bool) (*GrpcClient, error)

NewClient creates a new Signal client

func (*GrpcClient) Close

func (c *GrpcClient) Close() error

Close Closes underlying connections to the Signal Exchange

func (*GrpcClient) GetStatus

func (c *GrpcClient) GetStatus() Status

func (*GrpcClient) IsHealthy

func (c *GrpcClient) IsHealthy() bool

IsHealthy probes the gRPC connection and returns false on errors

func (*GrpcClient) Ready

func (c *GrpcClient) Ready() bool

Ready indicates whether the client is okay and Ready to be used for now it just checks whether gRPC connection to the service is in state Ready

func (*GrpcClient) Receive

func (c *GrpcClient) Receive(ctx context.Context, msgHandler func(msg *proto.Message) error) error

Receive Connects to the Signal Exchange message stream and starts receiving messages. The messages will be handled by msgHandler function provided. This function is blocking and reconnects to the Signal Exchange if errors occur (e.g. Exchange restart) The connection retry logic will try to reconnect for 30 min and if wasn't successful will propagate the error to the function caller.

func (*GrpcClient) Send

func (c *GrpcClient) Send(msg *proto.Message) error

Send sends a message to the remote Peer through the Signal Exchange.

func (*GrpcClient) SendToStream

func (c *GrpcClient) SendToStream(msg *proto.EncryptedMessage) error

SendToStream sends a message to the remote Peer through the Signal Exchange using established stream connection to the Signal Server The GrpcClient.Receive method must be called before sending messages to establish initial connection to the Signal Exchange GrpcClient.connWg can be used to wait

func (*GrpcClient) SetConnStateListener

func (c *GrpcClient) SetConnStateListener(notifier ConnStateNotifier)

SetConnStateListener set the ConnStateNotifier

func (*GrpcClient) SetOnReconnectedListener

func (c *GrpcClient) SetOnReconnectedListener(fn func())

func (*GrpcClient) StreamConnected

func (c *GrpcClient) StreamConnected() bool

func (*GrpcClient) WaitStreamConnected

func (c *GrpcClient) WaitStreamConnected()

WaitStreamConnected waits until the client is connected to the Signal stream

type MockClient

type MockClient struct {
	CloseFunc                    func() error
	GetStatusFunc                func() Status
	StreamConnectedFunc          func() bool
	ReadyFunc                    func() bool
	WaitStreamConnectedFunc      func()
	ReceiveFunc                  func(ctx context.Context, msgHandler func(msg *proto.Message) error) error
	SendToStreamFunc             func(msg *proto.EncryptedMessage) error
	SendFunc                     func(msg *proto.Message) error
	SetOnReconnectedListenerFunc func(f func())
}

func (*MockClient) Close

func (sm *MockClient) Close() error

func (*MockClient) GetStatus

func (sm *MockClient) GetStatus() Status

func (*MockClient) IsHealthy

func (sm *MockClient) IsHealthy() bool

func (*MockClient) Ready

func (sm *MockClient) Ready() bool

func (*MockClient) Receive

func (sm *MockClient) Receive(ctx context.Context, msgHandler func(msg *proto.Message) error) error

func (*MockClient) Send

func (sm *MockClient) Send(msg *proto.Message) error

func (*MockClient) SendToStream

func (sm *MockClient) SendToStream(msg *proto.EncryptedMessage) error

func (*MockClient) SetOnReconnectedListener

func (sm *MockClient) SetOnReconnectedListener(_ func())

SetOnReconnectedListener sets the function to be called when the client reconnects.

func (*MockClient) StreamConnected

func (sm *MockClient) StreamConnected() bool

func (*MockClient) WaitStreamConnected

func (sm *MockClient) WaitStreamConnected()

type Status

type Status string

Status is the status of the client

const StreamConnected Status = "Connected"

const StreamDisconnected Status = "Disconnected"