tntservices

package
v0.0.0-...-cc13779 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 6, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const InsertEquipmentEventSQL = `` /* 417-byte string literal not displayed */

InsertEquipmentEventSQL - insert EquipmentEventSQL query

View Source 
const InsertEquipmentEventTypeSQL = `` /* 273-byte string literal not displayed */

InsertEquipmentEventTypeSQL - insert EquipmentEventTypeSQL query

View Source 
const InsertEventClassifierSQL = ``
View Source 
const InsertEventSQL = ``
View Source 
const InsertOperationsEventSQL = `` /* 767-byte string literal not displayed */

InsertOperationsEventSQL - insert OperationsEventSQL query

View Source 
const InsertOperationsEventTypeSQL = `` /* 282-byte string literal not displayed */

InsertOperationsEventTypeSQL - insert OperationsEventTypeSQL query

View Source 
const InsertShipmentEventSQL = `` /* 380-byte string literal not displayed */

InsertShipmentEventSQL - insert ShipmentEventSQL query

View Source 
const InsertShipmentEventTypeSQL = `` /* 264-byte string literal not displayed */

InsertShipmentEventTypeSQL - insert ShipmentEventTypeSQL query

View Source 
const InsertTransportEventSQL = `` /* 366-byte string literal not displayed */

InsertTransportEventSQL - insert TransportEventSQL query

View Source 
const InsertTransportEventTypeSQL = `` /* 273-byte string literal not displayed */

InsertTransportEventTypeSQL - insert TransportEventTypeSQL query

Variables

This section is empty.

Functions

func StartTntServer 

func StartTntServer(log *zap.Logger, isTest bool, pwd string, dbOpt *config.DBOptions, redisOpt *config.RedisOptions, mailerOpt *config.MailerOptions, grpcServerOpt *config.GrpcServerOptions, jwtOpt *config.JWTOptions, oauthOpt *config.OauthOptions, userOpt *config.UserOptions, uptraceOpt *config.UptraceOptions, dbService *common.DBService, redisService *common.RedisService, mailerService common.MailerIntf)

StartTntServer - Start Tnt server

Types

type EventService 

type EventService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient partyproto.UserServiceClient
	tntproto.UnimplementedEventServiceServer
	// contains filtered or unexported fields
}

EventService - For accessing Transport Document services

func NewEventService 

func NewEventService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *EventService

NewEventService - Create Transport Document service

func (*EventService) CrEquipmentEventStruct 

func (es *EventService) CrEquipmentEventStruct(ctx context.Context, equipmentEvent *tntproto.EquipmentEvent, userEmail string, requestID string) (*tntstruct.EquipmentEvent, error)

CrEquipmentEventStruct - process EquipmentEvent details

func (*EventService) CrEventStruct 

func (es *EventService) CrEventStruct(ctx context.Context, event *tntproto.Event, userEmail string, requestID string) (*tntstruct.Event, error)

CrEventStruct - process Event details

func (*EventService) CrOperationsEventStruct 

func (es *EventService) CrOperationsEventStruct(ctx context.Context, operationsEvent *tntproto.OperationsEvent, userEmail string, requestID string) (*tntstruct.OperationsEvent, error)

CrOperationsEventStruct - process OperationsEvent details

func (*EventService) CrShipmentEventStruct 

func (es *EventService) CrShipmentEventStruct(ctx context.Context, shipmentEvent *tntproto.ShipmentEvent, userEmail string, requestID string) (*tntstruct.ShipmentEvent, error)

CrShipmentEventStruct - process ShipmentEvent details

func (*EventService) CrTransportEventStruct 

func (es *EventService) CrTransportEventStruct(ctx context.Context, transportEvent *tntproto.TransportEvent, userEmail string, requestID string) (*tntstruct.TransportEvent, error)

CrTransportEventStruct - process TransportEvent details

func (*EventService) CreateEquipmentEvent 

func (es *EventService) CreateEquipmentEvent(ctx context.Context, in *tntproto.CreateEquipmentEventRequest) (*tntproto.CreateEquipmentEventResponse, error)

CreateEquipmentEvent - Create EquipmentEvent

func (*EventService) CreateEvent 

func (es *EventService) CreateEvent(ctx context.Context, in *tntproto.CreateEventRequest) (*tntproto.CreateEventResponse, error)

CreateEvent - Create Event

func (*EventService) CreateOperationsEvent 

func (es *EventService) CreateOperationsEvent(ctx context.Context, in *tntproto.CreateOperationsEventRequest) (*tntproto.CreateOperationsEventResponse, error)

CreateOperationsEvent - Create OperationsEvent

func (*EventService) CreateShipmentEvent 

func (es *EventService) CreateShipmentEvent(ctx context.Context, in *tntproto.CreateShipmentEventRequest) (*tntproto.CreateShipmentEventResponse, error)

CreateShipmentEvent - Create ShipmentEvent

func (*EventService) CreateShipmentEventFromShippingInstruction 

func (es *EventService) CreateShipmentEventFromShippingInstruction(ctx context.Context, inReq *tntproto.CreateShipmentEventFromShippingInstructionRequest) (*tntproto.CreateShipmentEventFromShippingInstructionResponse, error)

CreateShipmentEventFromShippingInstruction - CreateShipmentEventFromShippingInstruction

func (*EventService) CreateTransportEvent 

func (es *EventService) CreateTransportEvent(ctx context.Context, in *tntproto.CreateTransportEventRequest) (*tntproto.CreateTransportEventResponse, error)

CreateTransportEvent - Create TransportEvent

func (*EventService) GetEvent 

func (es *EventService) GetEvent(ctx context.Context, inReq *tntproto.GetEventRequest) (*tntproto.GetEventResponse, error)

GetEvent - find By ID

func (*EventService) GetEvents 

func (es *EventService) GetEvents(ctx context.Context, in *tntproto.GetEventsRequest) (*tntproto.GetEventsResponse, error)

GetEvents - Get Events

func (*EventService) LoadOperationsRelatedEntities 

func (es *EventService) LoadOperationsRelatedEntities(ctx context.Context, in *tntproto.LoadOperationsRelatedEntitiesRequest) (*tntproto.LoadOperationsRelatedEntitiesResponse, error)

LoadOperationsRelatedEntities - Get OperationsEvents

func (*EventService) LoadRelatedEntities 

func (es *EventService) LoadRelatedEntities(ctx context.Context, in *tntproto.LoadRelatedEntitiesRequest) (*tntproto.LoadRelatedEntitiesResponse, error)

LoadRelatedEntities - Get EquipmentEvents

func (*EventService) LoadShipmentRelatedEntities 

func (es *EventService) LoadShipmentRelatedEntities(ctx context.Context, in *tntproto.LoadShipmentRelatedEntitiesRequest) (*tntproto.LoadShipmentRelatedEntitiesResponse, error)

LoadShipmentRelatedEntities - Get ShipmentEvents

func (*EventService) LoadTransportRelatedEntities 

func (es *EventService) LoadTransportRelatedEntities(ctx context.Context, in *tntproto.LoadTransportRelatedEntitiesRequest) (*tntproto.LoadTransportRelatedEntitiesResponse, error)

LoadTransportRelatedEntities - Get TransportEvents

func (*EventService) ProcessEquipmentEvent 

func (es *EventService) ProcessEquipmentEvent(ctx context.Context, in *tntproto.CreateEquipmentEventRequest) (*tntproto.EquipmentEvent, error)

ProcessEquipmentEvent - Process EquipmentEvent

func (*EventService) ProcessEventClassifier 

func (es *EventService) ProcessEventClassifier(ctx context.Context, in *tntproto.CreateEventClassifierRequest) (*tntproto.EventClassifier, error)

ProcessEventClassifier - Process EventClassifier

func (*EventService) ProcessOperationsEvent 

func (es *EventService) ProcessOperationsEvent(ctx context.Context, in *tntproto.CreateOperationsEventRequest) (*tntproto.OperationsEvent, error)

ProcessOperationsEvent - Process OperationsEvent

func (*EventService) ProcessShipmentEvent 

func (es *EventService) ProcessShipmentEvent(ctx context.Context, in *tntproto.CreateShipmentEventRequest) (*tntproto.ShipmentEvent, error)

ProcessShipmentEvent - Process ShipmentEvent

func (*EventService) ProcessTransportEvent 

func (es *EventService) ProcessTransportEvent(ctx context.Context, in *tntproto.CreateTransportEventRequest) (*tntproto.TransportEvent, error)

ProcessTransportEvent - Process TransportEvent

type EventSubscriptionService 

type EventSubscriptionService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient partyproto.UserServiceClient
	tntproto.UnimplementedEventSubscriptionServiceServer
	// contains filtered or unexported fields
}

EventSubscriptionService - For accessing Transport Document services

func NewEventSubscriptionService 

func NewEventSubscriptionService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *EventSubscriptionService

NewEventSubscriptionService - Create Transport Document service

func (*EventSubscriptionService) CrEventSubscriptionStruct 

func (ess *EventSubscriptionService) CrEventSubscriptionStruct(ctx context.Context, eventSubscription *tntproto.EventSubscription, userEmail string, requestID string) (*tntstruct.EventSubscription, error)

CrEventSubscriptionStruct - process EventSubscription details

func (*EventSubscriptionService) CreateEventSubscription 

func (ess *EventSubscriptionService) CreateEventSubscription(ctx context.Context, in *tntproto.CreateEventSubscriptionRequest) (*tntproto.CreateEventSubscriptionResponse, error)

CreateEventSubscription - Create EventSubscription

func (*EventSubscriptionService) DeleteEventSubscriptionByID 

func (ess *EventSubscriptionService) DeleteEventSubscriptionByID(ctx context.Context, inReq *tntproto.DeleteEventSubscriptionByIDRequest) (*tntproto.DeleteEventSubscriptionByIDResponse, error)

DeleteEventSubscriptionByID - DeleteEventSubscriptionByID EventSubscription

func (*EventSubscriptionService) FindEventSubscriptionByID 

func (ess *EventSubscriptionService) FindEventSubscriptionByID(ctx context.Context, inReq *tntproto.FindEventSubscriptionByIDRequest) (*tntproto.FindEventSubscriptionByIDResponse, error)

FindEventSubscriptionByID - find By ID

func (*EventSubscriptionService) GetEventSubscriptions 

func (ess *EventSubscriptionService) GetEventSubscriptions(ctx context.Context, in *tntproto.GetEventSubscriptionsRequest) (*tntproto.GetEventSubscriptionsResponse, error)

GetEventSubscriptions - GetEventSubscriptions

func (*EventSubscriptionService) UpdateEventSubscription 

func (ess *EventSubscriptionService) UpdateEventSubscription(ctx context.Context, in *tntproto.UpdateEventSubscriptionRequest) (*tntproto.UpdateEventSubscriptionResponse, error)

UpdateEventSubscription - Update EventSubscription

type SealService 

type SealService struct {
	DBService         *common.DBService
	RedisService      *common.RedisService
	UserServiceClient partyproto.UserServiceClient
	tntproto.UnimplementedSealServiceServer
	// contains filtered or unexported fields
}

SealService - For accessing Transport Document services

func NewSealService 

func NewSealService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *SealService

NewSealService - Create Transport Document service

func (*SealService) CreateSeal 

func (ss *SealService) CreateSeal(ctx context.Context, in *tntproto.CreateSealRequest) (*tntproto.CreateSealResponse, error)

CreateSeal - Create Seal

func (*SealService) GetSeals 

func (ss *SealService) GetSeals(ctx context.Context, in *tntproto.GetSealsRequest) (*tntproto.GetSealsResponse, error)

GetSeals - Get Seals

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.