grpctrack

Documentation

Index

• type QueuePublisher
• type TrackGRPCApi
  • func NewTrackGRPCApi(log logger.Logger, tracking Tracking) *TrackGRPCApi
  • func (s *TrackGRPCApi) GetResult(ctx context.Context, in *trackingService2.GetTrackingID) (*trackingService2.GetTrackingResponse, error)
  • func (s *TrackGRPCApi) PostTracking(ctx context.Context, in *trackingService2.PostTrackingRequest) (*trackingService2.PostTrackingResponse, error)
• type Tracking
• type TrackingResultGetter

Types

type QueuePublisher

type QueuePublisher interface {
	PublishTrackingNumbersToQueue(
		ctx context.Context,
		id string,
		trackingNumbers []string,
	) ([]appmodels.TrackingNumber, error)
}

type TrackGRPCApi

type TrackGRPCApi struct {
	trackingService2.UnimplementedTrackingServer
	// contains filtered or unexported fields
}

func NewTrackGRPCApi

func NewTrackGRPCApi(log logger.Logger, tracking Tracking) *TrackGRPCApi

func (*TrackGRPCApi) GetResult

func (s *TrackGRPCApi) GetResult(
	ctx context.Context,
	in *trackingService2.GetTrackingID,
) (*trackingService2.GetTrackingResponse, error)

func (*TrackGRPCApi) PostTracking

func (s *TrackGRPCApi) PostTracking(
	ctx context.Context,
	in *trackingService2.PostTrackingRequest,
) (*trackingService2.PostTrackingResponse, error)

type Tracking

type Tracking interface {
	QueuePublisher
	TrackingResultGetter
}

type TrackingResultGetter

type TrackingResultGetter interface {
	GetTrackingResult(ctx context.Context, id string) ([]*appmodels.Crawler, error)
}