Documentation ¶
Index ¶
- Constants
- func StartOvsServer(log *zap.Logger, isTest bool, pwd string, dbOpt *config.DBOptions, ...)
- type LegService
- func (lg *LegService) CrLegStruct(ctx context.Context, leg *ovsproto.Leg, userEmail string, requestID string) (*ovsstruct.Leg, error)
- func (lg *LegService) CreateLeg(ctx context.Context, in *ovsproto.CreateLegRequest) (*ovsproto.CreateLegResponse, error)
- func (lg *LegService) CreatePointToPointRouting(ctx context.Context, in *ovsproto.CreatePointToPointRoutingRequest) (*ovsproto.CreatePointToPointRoutingResponse, error)
- func (lg *LegService) GetLeg(ctx context.Context, inReq *ovsproto.GetLegRequest) (*ovsproto.GetLegResponse, error)
- func (lg *LegService) GetLegByPk(ctx context.Context, inReq *ovsproto.GetLegByPkRequest) (*ovsproto.GetLegByPkResponse, error)
- func (lg *LegService) GetLegs(ctx context.Context, in *ovsproto.GetLegsRequest) (*ovsproto.GetLegsResponse, error)
- func (lg *LegService) GetPointToPointRouting(ctx context.Context, inReq *ovsproto.GetPointToPointRoutingRequest) (*ovsproto.GetPointToPointRoutingResponse, error)
- func (lg *LegService) GetPointToPointRoutingByPk(ctx context.Context, inReq *ovsproto.GetPointToPointRoutingByPkRequest) (*ovsproto.GetPointToPointRoutingByPkResponse, error)
- func (lg *LegService) GetPointToPointRoutings(ctx context.Context, in *ovsproto.GetPointToPointRoutingsRequest) (*ovsproto.GetPointToPointRoutingsResponse, error)
- func (lg *LegService) ProcessLeg(ctx context.Context, in *ovsproto.CreateLegRequest) (*ovsproto.Leg, error)
- type ServiceScheduleService
- func (ss *ServiceScheduleService) CreateServiceSchedule(ctx context.Context, in *ovsproto.CreateServiceScheduleRequest) (*ovsproto.CreateServiceScheduleResponse, error)
- func (ss *ServiceScheduleService) GetServiceSchedule(ctx context.Context, inReq *ovsproto.GetServiceScheduleRequest) (*ovsproto.GetServiceScheduleResponse, error)
- func (ss *ServiceScheduleService) GetServiceScheduleByPk(ctx context.Context, inReq *ovsproto.GetServiceScheduleByPkRequest) (*ovsproto.GetServiceScheduleByPkResponse, error)
- func (ss *ServiceScheduleService) GetServiceScheduleByUniversalServiceReference(ctx context.Context, ...) (*ovsproto.GetServiceScheduleByUniversalServiceReferenceResponse, error)
- func (ss *ServiceScheduleService) GetServiceSchedules(ctx context.Context, in *ovsproto.GetServiceSchedulesRequest) (*ovsproto.GetServiceSchedulesResponse, error)
- func (ss *ServiceScheduleService) UpdateServiceScheduleByUniversalServiceReference(ctx context.Context, ...) (*ovsproto.UpdateServiceScheduleByUniversalServiceReferenceResponse, error)
- type VesselScheduleService
- func (vs *VesselScheduleService) CreateVessel(ctx context.Context, in *ovsproto.CreateVesselRequest) (*ovsproto.CreateVesselResponse, error)
- func (vs *VesselScheduleService) CreateVesselSchedule(ctx context.Context, in *ovsproto.CreateVesselScheduleRequest) (*ovsproto.CreateVesselScheduleResponse, error)
- func (vs *VesselScheduleService) GetVessel(ctx context.Context, inReq *ovsproto.GetVesselRequest) (*ovsproto.GetVesselResponse, error)
- func (vs *VesselScheduleService) GetVesselByPk(ctx context.Context, inReq *ovsproto.GetVesselByPkRequest) (*ovsproto.GetVesselByPkResponse, error)
- func (vs *VesselScheduleService) GetVesselSchedule(ctx context.Context, inReq *ovsproto.GetVesselScheduleRequest) (*ovsproto.GetVesselScheduleResponse, error)
- func (vs *VesselScheduleService) GetVesselScheduleByPk(ctx context.Context, inReq *ovsproto.GetVesselScheduleByPkRequest) (*ovsproto.GetVesselScheduleByPkResponse, error)
- func (vs *VesselScheduleService) GetVesselSchedules(ctx context.Context, in *ovsproto.GetVesselSchedulesRequest) (*ovsproto.GetVesselSchedulesResponse, error)
- func (vs *VesselScheduleService) GetVessels(ctx context.Context, in *ovsproto.GetVesselsRequest) (*ovsproto.GetVesselsResponse, error)
Constants ¶
const InsertLegSQL = `` /* 939-byte string literal not displayed */
InsertLegSQL - insert LegSQL query
Variables ¶
This section is empty.
Functions ¶
func StartOvsServer ¶
func StartOvsServer(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)
StartOvsServer - Start Ovs server
Types ¶
type LegService ¶
type LegService struct { DBService *common.DBService RedisService *common.RedisService UserServiceClient partyproto.UserServiceClient ovsproto.UnimplementedLegServiceServer // contains filtered or unexported fields }
LegService - For accessing Leg services
func NewLegService ¶
func NewLegService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *LegService
NewLegService - Create Leg service
func (*LegService) CrLegStruct ¶
func (lg *LegService) CrLegStruct(ctx context.Context, leg *ovsproto.Leg, userEmail string, requestID string) (*ovsstruct.Leg, error)
CrLegStruct - process Leg details
func (*LegService) CreateLeg ¶
func (lg *LegService) CreateLeg(ctx context.Context, in *ovsproto.CreateLegRequest) (*ovsproto.CreateLegResponse, error)
CreateLeg - Create Leg
func (*LegService) CreatePointToPointRouting ¶
func (lg *LegService) CreatePointToPointRouting(ctx context.Context, in *ovsproto.CreatePointToPointRoutingRequest) (*ovsproto.CreatePointToPointRoutingResponse, error)
CreatePointToPointRouting - Create PointToPointRouting
func (*LegService) GetLeg ¶
func (lg *LegService) GetLeg(ctx context.Context, inReq *ovsproto.GetLegRequest) (*ovsproto.GetLegResponse, error)
GetLeg - Get Leg
func (*LegService) GetLegByPk ¶
func (lg *LegService) GetLegByPk(ctx context.Context, inReq *ovsproto.GetLegByPkRequest) (*ovsproto.GetLegByPkResponse, error)
GetLegByPk - Get Leg By Primary key(Id)
func (*LegService) GetLegs ¶
func (lg *LegService) GetLegs(ctx context.Context, in *ovsproto.GetLegsRequest) (*ovsproto.GetLegsResponse, error)
GetLegs - Get Legs
func (*LegService) GetPointToPointRouting ¶
func (lg *LegService) GetPointToPointRouting(ctx context.Context, inReq *ovsproto.GetPointToPointRoutingRequest) (*ovsproto.GetPointToPointRoutingResponse, error)
GetPointToPointRouting - Get PointToPointRouting
func (*LegService) GetPointToPointRoutingByPk ¶
func (lg *LegService) GetPointToPointRoutingByPk(ctx context.Context, inReq *ovsproto.GetPointToPointRoutingByPkRequest) (*ovsproto.GetPointToPointRoutingByPkResponse, error)
GetPointToPointRoutingByPk - Get PointToPointRouting By Primary key(Id)
func (*LegService) GetPointToPointRoutings ¶
func (lg *LegService) GetPointToPointRoutings(ctx context.Context, in *ovsproto.GetPointToPointRoutingsRequest) (*ovsproto.GetPointToPointRoutingsResponse, error)
GetPointToPointRoutings - Get PointToPointRoutings
func (*LegService) ProcessLeg ¶
func (lg *LegService) ProcessLeg(ctx context.Context, in *ovsproto.CreateLegRequest) (*ovsproto.Leg, error)
ProcessLeg - Process Leg
type ServiceScheduleService ¶
type ServiceScheduleService struct { DBService *common.DBService RedisService *common.RedisService UserServiceClient partyproto.UserServiceClient ovsproto.UnimplementedServiceScheduleServiceServer // contains filtered or unexported fields }
ServiceScheduleService - For accessing ServiceSchedule services
func NewServiceScheduleService ¶
func NewServiceScheduleService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *ServiceScheduleService
NewServiceScheduleService - Create ServiceSchedule service
func (*ServiceScheduleService) CreateServiceSchedule ¶
func (ss *ServiceScheduleService) CreateServiceSchedule(ctx context.Context, in *ovsproto.CreateServiceScheduleRequest) (*ovsproto.CreateServiceScheduleResponse, error)
CreateServiceSchedule - Create ServiceSchedule
func (*ServiceScheduleService) GetServiceSchedule ¶
func (ss *ServiceScheduleService) GetServiceSchedule(ctx context.Context, inReq *ovsproto.GetServiceScheduleRequest) (*ovsproto.GetServiceScheduleResponse, error)
GetServiceSchedule - Get ServiceSchedule
func (*ServiceScheduleService) GetServiceScheduleByPk ¶
func (ss *ServiceScheduleService) GetServiceScheduleByPk(ctx context.Context, inReq *ovsproto.GetServiceScheduleByPkRequest) (*ovsproto.GetServiceScheduleByPkResponse, error)
GetServiceScheduleByPk - Get ServiceSchedule By Primary key(Id)
func (*ServiceScheduleService) GetServiceScheduleByUniversalServiceReference ¶
func (ss *ServiceScheduleService) GetServiceScheduleByUniversalServiceReference(ctx context.Context, in *ovsproto.GetServiceScheduleByUniversalServiceReferenceRequest) (*ovsproto.GetServiceScheduleByUniversalServiceReferenceResponse, error)
GetServiceScheduleByUniversalServiceReference - Get ServiceScheduleByUniversalServiceReference
func (*ServiceScheduleService) GetServiceSchedules ¶
func (ss *ServiceScheduleService) GetServiceSchedules(ctx context.Context, in *ovsproto.GetServiceSchedulesRequest) (*ovsproto.GetServiceSchedulesResponse, error)
GetServiceSchedules - Get ServiceSchedules
func (*ServiceScheduleService) UpdateServiceScheduleByUniversalServiceReference ¶
func (ss *ServiceScheduleService) UpdateServiceScheduleByUniversalServiceReference(ctx context.Context, in *ovsproto.UpdateServiceScheduleByUniversalServiceReferenceRequest) (*ovsproto.UpdateServiceScheduleByUniversalServiceReferenceResponse, error)
UpdateServiceScheduleByUniversalServiceReference - UpdateServiceScheduleByUniversalServiceReference
type VesselScheduleService ¶
type VesselScheduleService struct { DBService *common.DBService RedisService *common.RedisService UserServiceClient partyproto.UserServiceClient ovsproto.UnimplementedVesselScheduleServiceServer // contains filtered or unexported fields }
VesselScheduleService - For accessing VesselSchedule services
func NewVesselScheduleService ¶
func NewVesselScheduleService(log *zap.Logger, dbOpt *common.DBService, redisOpt *common.RedisService, userServiceClient partyproto.UserServiceClient) *VesselScheduleService
NewVesselScheduleService - Create VesselSchedule service
func (*VesselScheduleService) CreateVessel ¶
func (vs *VesselScheduleService) CreateVessel(ctx context.Context, in *ovsproto.CreateVesselRequest) (*ovsproto.CreateVesselResponse, error)
CreateVessel - Create Vessel
func (*VesselScheduleService) CreateVesselSchedule ¶
func (vs *VesselScheduleService) CreateVesselSchedule(ctx context.Context, in *ovsproto.CreateVesselScheduleRequest) (*ovsproto.CreateVesselScheduleResponse, error)
CreateVesselSchedule - Create VesselSchedule
func (*VesselScheduleService) GetVessel ¶
func (vs *VesselScheduleService) GetVessel(ctx context.Context, inReq *ovsproto.GetVesselRequest) (*ovsproto.GetVesselResponse, error)
GetVessel - Get Vessel
func (*VesselScheduleService) GetVesselByPk ¶
func (vs *VesselScheduleService) GetVesselByPk(ctx context.Context, inReq *ovsproto.GetVesselByPkRequest) (*ovsproto.GetVesselByPkResponse, error)
GetVesselByPk - Get Vessel By Primary key(Id)
func (*VesselScheduleService) GetVesselSchedule ¶
func (vs *VesselScheduleService) GetVesselSchedule(ctx context.Context, inReq *ovsproto.GetVesselScheduleRequest) (*ovsproto.GetVesselScheduleResponse, error)
GetVesselSchedule - Get VesselSchedule
func (*VesselScheduleService) GetVesselScheduleByPk ¶
func (vs *VesselScheduleService) GetVesselScheduleByPk(ctx context.Context, inReq *ovsproto.GetVesselScheduleByPkRequest) (*ovsproto.GetVesselScheduleByPkResponse, error)
GetVesselScheduleByPk - Get VesselSchedule By Primary key(Id)
func (*VesselScheduleService) GetVesselSchedules ¶
func (vs *VesselScheduleService) GetVesselSchedules(ctx context.Context, in *ovsproto.GetVesselSchedulesRequest) (*ovsproto.GetVesselSchedulesResponse, error)
GetVesselSchedules - Get VesselSchedules
func (*VesselScheduleService) GetVessels ¶
func (vs *VesselScheduleService) GetVessels(ctx context.Context, in *ovsproto.GetVesselsRequest) (*ovsproto.GetVesselsResponse, error)
GetVessels - Get Vessels