grpc

package

v0.58.2 Latest Latest Go to latest Published: Jan 29, 2026 License: Unlicense Imports: 7 Imported by: 0

Details

Package grpc provides a gRPC client for the relay group service.

This section is empty.

This section is empty.

This section is empty.

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

Client is a gRPC client for the relay group service.

func New(ctx context.Context, cfg *ClientConfig) (*Client, error)

New creates a new gRPC relay group client.

func (c *Client) Close() error

Close closes the gRPC connection.

func (c *Client) FindAuthoritativeConfig(ctx context.Context) (*relaygroupv1.RelayGroupConfigResponse, error)

FindAuthoritativeConfig finds the authoritative relay group configuration.

func (c *Client) GetAuthorizedPubkeys(ctx context.Context) ([][]byte, error)

GetAuthorizedPubkeys returns all authorized publisher pubkeys.

func (c *Client) GetRelays(ctx context.Context) ([]string, error)

GetRelays returns the list of relays from the authoritative config.

func (c *Client) HandleRelayGroupEvent(ctx context.Context, event *commonv1.Event) error

HandleRelayGroupEvent processes a relay group event and triggers peer updates.

func (c *Client) IsAuthorizedPublisher(ctx context.Context, pubkey []byte) (bool, error)

IsAuthorizedPublisher checks if a pubkey can publish relay group configs.

func (c *Client) Ready() <-chan struct{}

Ready returns a channel that closes when the client is ready.

func (c *Client) ValidateRelayGroupEvent(ctx context.Context, event *commonv1.Event) (bool, string, error)

ValidateRelayGroupEvent validates a relay group configuration event.

type ClientConfig struct {
	ServerAddress  string
	ConnectTimeout time.Duration
}

ClientConfig holds configuration for the gRPC client.