client

Documentation

Index

• type Client
• type GRPCClient
  • func NewGRPCClient(endpoint string) (*GRPCClient, error)
  • func (c *GRPCClient) Aggregate(ctx context.Context, req *types.AggregateRequest) error
• type HTTPClient
  • func NewHTTPClient(endpoint string) *HTTPClient
  • func (c *HTTPClient) Aggregate(ctx context.Context, aggReq *types.AggregateRequest) error
  • func (c *HTTPClient) GetInvoice(ctx context.Context, id int) (*types.Invoice, error)

Types

type Client

type Client interface {
	Aggregate(context.Context, *types.AggregateRequest) error //being used by distance calaculator to aggregate the tolls
	GetInvoice(context.Context, int) (*types.Invoice, error)  //being used by gateway to get the invoice
}

type GRPCClient

type GRPCClient struct {
	Endpoint string
	Client   types.AggregatorClient
}

func NewGRPCClient

func NewGRPCClient(endpoint string) (*GRPCClient, error)

func (*GRPCClient) Aggregate

func (c *GRPCClient) Aggregate(ctx context.Context, req *types.AggregateRequest) error

type HTTPClient

type HTTPClient struct {
	EndPoint string
}

func NewHTTPClient

func NewHTTPClient(endpoint string) *HTTPClient

func (*HTTPClient) Aggregate

func (c *HTTPClient) Aggregate(ctx context.Context, aggReq *types.AggregateRequest) error

the client here is putting all the distance data coming from distance calculator to the aggregator service

func (*HTTPClient) GetInvoice

func (c *HTTPClient) GetInvoice(ctx context.Context, id int) (*types.Invoice, error)