relay

package

v0.4.0 Latest Latest Go to latest Published: Jan 9, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Package relay contains the HTTP handler and logic for the relay service.

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Port           string
	ProjectID      string
	RelayTopicID   string
	RelayProjectID string
}

Config defines the set over environment variables required for running this application.

func (cfg *Config) ToFlags(set *cli.FlagSet) *cli.FlagSet

ToFlags binds the config to the give cli.FlagSet and returns it.

func (cfg *Config) Validate() error

Validate validates the service config after load.

type MessageEnricher interface {
	Enrich(ctx context.Context, req []byte) ([]byte, map[string]string, error)
}

func NewDefaultMessageEnricher() MessageEnricher

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

Server acts as a HTTP server for handling relay requests.

func NewServer(ctx context.Context, cfg *Config) (*Server, error)

NewServer creates a new instance of the Server.

func (s *Server) Routes(ctx context.Context) http.Handler

Routes creates a ServeMux of all of the routes that this Router supports.