grpc

Documentation

Index

• type Gateway
  • func New(registry discovery.Registry) *Gateway
  • func (g *Gateway) SearchFighters(ctx context.Context, req fightersmodel.FightersRequest) ([]*fightersmodel.Fighter, error)
  • func (g *Gateway) ServiceHealthCheck() (*model.HealthStatus, error)

Types

type Gateway

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

Gateway defines an gRPC gateway for a fighters service.

func New

func New(registry discovery.Registry) *Gateway

New creates a new gRPC gateway for a fighters service.

func (*Gateway) SearchFighters

func (g *Gateway) SearchFighters(ctx context.Context, req fightersmodel.FightersRequest) ([]*fightersmodel.Fighter, error)

SearchFighters searches for fighters with the given status. It establishes a gRPC connection to the Fighters service, sends a search request, and returns a list of fighters.

func (*Gateway) ServiceHealthCheck

func (g *Gateway) ServiceHealthCheck() (*model.HealthStatus, error)

ServiceHealthCheck connects to the fighters-service via gRPC to check its health status. It creates a new client for the fighters-service, sends a HealthCheck request, and retrieves the response. If successful, it converts the response from protobuf to the internal HealthStatus model. Returns the health status or an error if the connection or request fails.