common

package
v0.0.0-...-94a8b92 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 52 Imported by: 0

Documentation

Index

Constants

View Source 
const (

	// Full Container Load - The shipper/ consignee or its agent or subcontractor is responsible for stuffing or stripping the cargo into or out of the container and bears every responsibility and liability in such respect.
	CargoMovementFCL string = "FCL"

	// Less than Container Load - The carrier or its agent or subcontractor is responsible for stuffing or stripping the cargo into or out of the container and bears every responsibility and liability in such respect.
	CargoMovementLCL string = "LCL"

	// Break bulk 	Indicates that the carrier has received the cargo which is not containerised.
	CargoMovementBB string = "BB"
)

cargomovementtypes

View Source 
const (
	// ISO,International Organization for Standardization
	CodeListResponsibleAgencyISO string = "ISO"
	// UN/ECE,United Nations Economic Commission for Europe
	CodeListResponsibleAgencyUNECE string = "UNECE"
	// LR,Lloyd's register of shipping
	CodeListResponsibleAgencyLLOYD string = "LLOYD"
	// BIC (Bureau International des Containeurs),The container industry's international organisation responsible for the issuance of container-related codes
	CodeListResponsibleAgencyBIC string = "BIC"
	// IMO (incl. IMDG),International Maritime Organisation
	CodeListResponsibleAgencyIMO string = "IMO"
	// "US, Standard Carrier Alpha Code (Motor)",Organisation maintaining the SCAC lists and transportation operating in North America
	CodeListResponsibleAgencySCAC string = "SCAC"
	// ITIGG,International Transport Implementation Guidelines Group
	CodeListResponsibleAgencyITIGG string = "ITIGG"
	// ITU,International Telecommunication Union
	CodeListResponsibleAgencyITU string = "ITU"
	// SMDG (Ship-planning Message Design Group),User Group for Shipping Lines and Container Terminals
	CodeListResponsibleAgencySMDG string = "SMDG"
	// EXIS,Exis Technologies Ltd.
	CodeListResponsibleAgencyEXIS string = "EXIS"
	// FMC,Federal Maritime Commission
	CodeListResponsibleAgencyFMC string = "FMC"
	// CBSA,Canada Border Services Agency
	CodeListResponsibleAgencyCBSA string = "CBSA"
	// zzz,Mutually defined,A code assigned within a code list to be used on an interim basis and as defined among trading partners until a precise code can be assigned to the code list
	CodeListResponsibleAgencyZZZ string = "ZZZ"
	// Digitial Container Shipping Association,Maintainer of the EBL Solution provider list
	CodeListResponsibleAgencyDCSA string = "DCSA"
)

codelistresponsibleagencycodes

View Source 
const (
	// Electronic mail,Exchange of mail by electronic means
	CommunicationChannelQualifierEM string = "EM"
	// EDI transmission,Number identifying the service and service user
	CommunicationChannelQualifierEI string = "EI"
	// API,Uniform Resource Location
	CommunicationChannelQualifierAO string = "AO"
)

communicationchannelqualifier

View Source 
const (
	// Documentation cut-off,Document cut-off time for SI
	CutOffTimeDCO string = "DCO"
	// VGM cut-off,VGM cut-off time for submission
	CutOffTimeVGM string = "VGM"
	// FCL delivery cut-off,Latest deadline for delivering containers at the terminal gate
	CutOffTimeFCO string = "FCO"
	// LCL delivery cut-off,Latest deadline for delivering LCL cargo at the container freight station
	CutOffTimeLCO string = "LCO"
	// Empty container pick-up date and time,Time and date for shipper to pick-up empty container(s)
	CutOffTimeECP string = "ECP"
	// Earliest full-container delivery date,Earliest date where containers can be delivered at the terminal gate also called gate-opening
	CutOffTimeEFC string = "EFC"
	// AMS filing due date,Date when AMS filing should latest be done in the last port of call before visiting the first US port
	CutOffTimeAFD string = "AFD"
)

cutofftimecodes

View Source 
const (
	// Booking
	DocumentTypeBKG string = "BKG"
	// Shipping Instructions
	DocumentTypeSHI string = "SHI"
	// Verified Gross Mass
	DocumentTypeVGM string = "VGM"
	// Shipment Release Message
	DocumentTypeSRM string = "SRM"
	// Transport document
	DocumentTypeTRD string = "TRD"
	// Arrival Notice
	DocumentTypeARN string = "ARN"
	// Cargo Survey
	DocumentTypeCAS string = "CAS"
	// Customs Inspection
	DocumentTypeCUS string = "CUS"
	// Dangerous Good Declaration
	DocumentTypeDGD string = "DGD"
	// Out Of Gauge
	DocumentTypeOOG string = "OOG"
	// Carrier Booking Request Reference
	DocumentTypeCBR string = "CBR"
)

documenttypecodes

View Source 
const (
	// TRAL,https://www.tradelens.com/
	EblsolutionProviderTRAL string = "TRAL"
	// Wave BL, https://wavebl.com/
	EblsolutionProviderWAVE string = "WAVE"
	// CargoX, https://cargox.io
	EblsolutionProviderCARX string = "CARX"
	// EssDocs, https://www.essdocs.com/
	EblsolutionProviderESSD string = "ESSD"
	// Bolero, https://www.bolero.net/
	EblsolutionProviderBOLE string = "BOLE"
	// EdoxOnline, https://web.edoxonline.com
	EblsolutionProviderEDOX string = "EDOX"
)

eblsolutionproviders

View Source 
const (
	EmptyIndicatorEMPTY string = "EMPTY"
	EmptyIndicatorLADEN string = "LADEN"
)

emptyindicatorcodes

View Source 
const (
	// Load,The action of lifting cargo or a container on board of the mode of transportation. Load is complete once the cargo or container has been lifted on board the mode of transport and secured.
	EquipmentEventTypeLOAD string = "LOAD"
	// Discharge,The action of lifting cargo or containers off a mode of transport. Discharge is the opposite of load.GTIN,Gate in,The action when a container is introduced into a controlled area like a port - or inland terminal. Gate in has been completed once the operator of the area is legally in possession of the container.
	EquipmentEventTypeDISC string = "DISC"
	// Gate in,The action when a container is introduced into a controlled area like a port - or inland terminal. Gate in has been completed once the operator of the area is legally in possession of the container.
	EquipmentEventTypeGTIN string = "GTIN"
	// Gate out,The action when a container is removed from a controlled area like a port – or inland terminal. Gate-out has been completed once the possession of the container has been transferred from the operator of the terminal to the entity who is picking up the container.
	EquipmentEventTypeGTOT string = "GTOT"
	// Stuffing,The process of loading the cargo in a container or in/onto another piece of equipment.
	EquipmentEventTypeSTUF string = "STUF"
	// STRP,Stripping,The action of unloading cargo from containers or equipment.
	EquipmentEventTypeSTRP string = "STRP"
	// Pick-up,The action of collecting the container at customer location.
	EquipmentEventTypePICK string = "PICK"
	// Drop-off, The action of delivering the container at customer location.
	EquipmentEventTypeDROP string = "DROP"
	// Inspected,Identifies that the seal on equipment has been inspected.
	EquipmentEventTypeINSP string = "INSP"
	// Resealed,Identifies that the equipment has been resealed after inspection
	EquipmentEventTypeRSEA string = "RSEA"
	// Removed,Identifies that a Seal has been removed from the equipment for inspection
	EquipmentEventTypeRMVD string = "RMVD"
)

equipmenteventtypecodes

View Source 
const (
	// Actual
	EventClassifierACT string = "ACT"
	// Planned
	EventClassifierPLN string = "PLN"
	// Estimated
	EventClassifierEST string = "EST"
	// Removed
	EventClassifierREQ string = "REQ"
)

eventclassifiercodes

View Source 
const (
	// Border crossing,"Border crossing is the point at a border between two countries where people, transports or goods can cross. This may or may not include a customs checkpoint."
	FacilityTypeBOCR string = "BOCR"
	// Customer location,"Customer location is the premise of the customer, who can be either the shipper or the consignee."
	FacilityTypeCLOC string = "CLOC"
	// Container freight station,"Container freight station is a facility where LCL (Less Than Container Load) shipments are consolidated or dispersed, cargo is stuffed into containers prior to shipment, or cargo is stripped from containers prior to release to the consignee."
	FacilityTypeCOFS string = "COFS"
	// Container yard,"Deprecated, now called OFFD."
	FacilityTypeCOYA string = "COYA"
	// Off dock storage,"An interim storage facility where empty or full containers are stored in transit."DEPO,Depot,"Depot is a designated area where empty equipment is stored between use."
	FacilityTypeOFFD string = "OFFD"
	// Depot,"Depot is a designated area where empty equipment is stored between use."
	FacilityTypeDEPO string = "DEPO"
	// Inland terminal,"Inland terminal is a facility where containers are loaded, moved, or discharged. The inland terminal can be serviced by trucks, rail, and barges (at river terminals)."
	FacilityTypeINTE string = "INTE"
	// Port terminal,"Port terminal is a facility located adjacent to a waterway where containers are loaded, moved, or discharged onto/from sea-going vessels and barges. "
	FacilityTypePOTE string = "POTE"
	// Pilot boarding place,"The place where a pilot boards the vessel upon arrival at the port boundaries."
	FacilityTypePBPL string = "PBPL"
	// Berth,"A designated location in a port or harbour used for mooring vessels when they are not at sea."
	FacilityTypeBRTH string = "BRTH"
	// Ramp,"An inland container terminal (storing both full and empty containers) connected directly to a rail ramp where containers are loaded/discharged to/from a train."
	FacilityTypeRAMP string = "RAMP"
)

facilitytypes

View Source 
const (
	// Free Carrier,"The seller delivers the goods, cleared for export, at a named place (possibly including the seller's own premises)"
	IncotermsFCA string = "FCA"
	// Free on Board,Under FOB terms the seller bears all costs and risks up to the point the goods are loaded on board the vessel.
	IncotermsFOB string = "FOB"
)

incotermscodes

View Source 
const (
	// Maritime transport,Transport of goods and/or persons is by sea.,VESSEL
	ModeOfTransportMaritime string = "Maritime transport"
	// Rail transport,Transport of goods and/or persons is by rail.,RAIL
	ModeOfTransportRail string = "Rail transport"
	// Road transport,Transport of goods and/or persons is by road.,TRUCK
	ModeOfTransportRoad string = "Road transport"
	// Inland water Transport,Transport of goods and/or persons is by inland water.,BARGE
	ModeOfTransportInland string = "Inland water"
)

modeoftransportcodes

View Source 
const (
	// Arrived
	OperationsEventARRI string = "ARRI"
	// Departed
	OperationsEventDEPA string = "DEPA"
	// Started
	OperationsEventSTRT string = "STRT"
	// Completed
	OperationsEventCMPL string = "CMPL"
)

operationseventtypecodes

View Source 
const (
	// Barrels, Wooden, bung type
	Package2C1 string = "2C1"
	// Boxes, Natural wood, ordinary
	Package4C1 string = "4C1"
	// Bags, Plastic film
	Package5H4 string = "5H4"
	// Bags, Paper, multiwall
	Package5M1 string = "5M1"
)

packagecodes

View Source 
const (
	// Original shipper.,The original supplier of the goods.
	PartyFunctionOS string = "OS"
	// Consignee.,Party to which goods are consigned.
	PartyFunctionCN string = "CN"
	// Freight payer on behalf of the consignor.,Freight payer is a third party acting on behalf of the consignor.
	PartyFunctionCOW string = "COW"
	// Freight payer on behalf of the consignee.,Freight payer is a third party acting on behalf of the consignee.
	PartyFunctionCOX string = "COX"
	// "Document/message issuer/sender",Issuer of a document and/or sender of a message.
	PartyFunctionMS string = "MS"
	// First Notify Party.,The first party which is to be notified.
	PartyFunctionN1 string = "N1"
	// Second Notify Party.,The second party which is to be notified.
	PartyFunctionN2 string = "N2"
	// Notify party,Party to be notified of arrival of goods.
	PartyFunctionNI string = "NI"
	// "Consignor's freight forwarder",Identification of freight forwarder giving services to the consignor (shipper).
	PartyFunctionDDR string = "DDR"
	// "Consignee's freight forwarder",Identification of freight forwarder giving services to the consignee.CA,Carrier operations,"The activity of discharging, shifting, loading, and lashing containers (both full and empty) as well as other cargo from/to a vessel during port stay. Normally quantified with a move-count and a number of moves per hour."
	PartyFunctionDDS string = "DDS"
	// Carrier local agent,
	PartyFunctionAG string = "AG"
	// Vessel,"A floating, sea going structure (mother vessels and feeder vessels) with either an internal or external mode of propulsion designed for the transport of cargo and/or passengers. Ocean vessels are uniquely identified by an IMO number consisting of 7 digits, or alternatively by their AIS signal with an MMSI number"
	PartyFunctionVSL string = "VSL"
	// Port Authorities
	PartyFunctionATH string = "ATH"
	// Pilot,The activity of conducting a vessel within restricted waters.
	PartyFunctionPLT string = "PLT"
	// Towage provider
	PartyFunctionTWG string = "TWG"
	// Lashing provider
	PartyFunctionLSH string = "LSH"
	// Bunkering service provider
	PartyFunctionBUK string = "BUK"
	// Terminal,"A facility for loading, moving or discharging containers. Terminals can be both inland terminals for trucks and rail or port terminals are accessed by vessels and these can contain multiple berths."EBL,EBL Solution Provider,"The solution provider for managing the electronic bill of lading."
	PartyFunctionTR string = "TR"
	// EBL Solution Provider,"The solution provider for managing the electronic bill of lading."
	PartyFunctionSCO string = "SCO"
	// Booking Agent,"Party acting as a booking office for transport and forwarding services."
	PartyFunctionBA string = "BA"
	// Carrier booking office (transportation office),"The carrier office responsible for processing the booking."
	PartyFunctionHE string = "HE"
)

partyfunctioncodes

View Source 
const (
	// PrePaid,Fee paid prior to transportation
	PaymentTermPRE string = "PRE"
	// Collect,Fee paid upon collection of the goods
	PaymentTermCOL string = "COL"
)

paymentterms

View Source 
const (
	// Inbound,Ship’s physical movement from approach to (anchor) berth
	PortCallPhaseTypeINBD string = "INBD"
	// Alongside,Time from First Line Secured till Last Line Released
	PortCallPhaseTypeALGS string = "ALGS"
	// Shifting,Ship’s physical movement from (anchor) berth to (anchor) berth
	PortCallPhaseTypeSHIF string = "SHIF"
	// Outbound,Ship’s physical movement from (anchor) berth to its next destination
	PortCallPhaseTypeOUTB string = "OUTB"
)

portcallphasetype

View Source 
const (
	// Carrier operations
	PublisherRoleCA string = "CA"
	// Carrier local agent
	PublisherRoleAG string = "AG"
	// Vessel
	PublisherRoleVSL string = "VSL"
	// Port Authorities
	PublisherRoleATH string = "ATH"
	// Pilot
	PublisherRolePLT string = "PLT"
	// Towage provider
	PublisherRoleTWG string = "TWG"
	// Lashing provider
	PublisherRoleLSH string = "LSH"
	// Bunkering service provider
	PublisherRoleBUK string = "BUK"
	// Terminal
	PublisherRoleTR string = "TR"
)

publisherrole

View Source 
const (
	// Container yard (incl. rail ramp), "Where the carrier takes possession of a fully stuffed container delivered by the customer at the carrier or carrier's appointed supplier's facility or where a container is released to the customer by the carrier."
	ReceiptDeliveryTypeCY string = "CY"
	// Store Door, "Indicating that the carrier is taking possession of or delivers a fully stuffed container at the customer's appointed premises."
	ReceiptDeliveryTypeSD string = "SD"
	// Container Freight Station, "indicating that the carrier has received the cargo and is responsible for stuffing of the cargo within the container or the customer receives the cargo directly from the container freight station."
	ReceiptDeliveryTypeCFS string = "CFS"
)

receiptdeliverytypes

View Source 
const (
	// Freight Forwarder’s Reference,Reference assigned to the shipment by the freight forwarder.
	ReferenceTypeFF string = "FF"
	// Shipper’s Reference,Reference assigned to the shipment by the shipper.
	ReferenceTypeSI string = "SI"
	// Purchase Order Reference,The PO reference that the shipper or freight forwarder received from the consignee and then shared with the carrier.
	ReferenceTypePO string = "PO"
	// Customer’s Reference,Reference assigned to the shipment by the customer.
	ReferenceTypeCR string = "CR"
	// Consignee’s Reference,Reference assigned to the shipment by the consignee.
	ReferenceTypeAAO string = "AAO"
	// Empty container release reference,Unique identifier to enable release of the container from a carrier nominated depot
	ReferenceTypeECR string = "ECR"
	// Customer shipment ID,Unique Shipment ID for the booking in the Shipper or Forwarder system. Used to identify the booking along with the Booking party.
	ReferenceTypeCSI string = "CSI"
	// Booking party reference number,A unique identifier provided by a booking party in the booking request.
	ReferenceTypeBPR string = "BPR"
	// Booking Request ID,The associated booking request ID provided by the shipper.
	ReferenceTypeBID string = "BID"
	// Equipment Reference,Reference to the equipment that is associated with document.
	ReferenceTypeEQ string = "EQ"
)

referencetypes

View Source 
const (
	// Carrier
	SealSourceCAR string = "CAR"
	// Shipper
	SealSourceSHI string = "SHI"
	// Phytosanitary
	SealSourcePHY string = "PHY"
	// Veterinary
	SealSourceVET string = "VET"
	// Customs
	SealSourceCUS string = "CUS"
)

sealsourcecodes

View Source 
const (
	// Keyless padlock
	SealTypeKLP string = "KLP"
	// Bolt
	SealTypeBLT string = "BLT"
	// Wire
	SealTypeWIR string = "WIR"
)

sealtypecodes

View Source 
const (
	// Received,Indicates that a document is received by the carrier or shipper
	ShipmentEventTypeRECE string = "RECE"
	// Drafted,Indicates that a document is in draft mode being updated by either the shipper or the carrier.
	ShipmentEventTypeDRFT string = "DRFT"
	// Pending Approval,Indicates that a document has been submitted by the carrier and is now awaiting approval by the shipper.
	ShipmentEventTypePENA string = "PENA"
	// Pending Update,Indicates that the carrier requested an update from the shipper which is not received yet.
	ShipmentEventTypePENU string = "PENU"
	// Pending Confirmation,Indicates that a document has been submitted by the shipper and is now awaiting approval by the carrier.
	ShipmentEventTypePENC string = "PENC"
	// Rejected,Indicates that a document has been rejected by the carrier.
	ShipmentEventTypeREJE string = "REJE"
	// Approved,Indicates that a document has been approved by the counterpart.
	ShipmentEventTypeAPPR string = "APPR"
	// Issued,Indicates that a document has been issued by the carrier.
	ShipmentEventTypeISSU string = "ISSU"
	// Surrendered,Indicates that a document has been surrendered by the customer to the carrier.
	ShipmentEventTypeSURR string = "SURR"
	// Submitted,Indicates that a document has been submitted by the customer to the carrier.
	ShipmentEventTypeSUBM string = "SUBM"
	// Void,Cancellation of an original document.
	ShipmentEventTypeVOID string = "VOID"
	// Confirmed,Indicates that the document is confirmed.
	ShipmentEventTypeCONF string = "CONF"
	// Requested,"A status indicator that can be used with a number of identifiers to denote that a certain activity, service or document has been requested by the carrier, customer or authorities. This status remains constant until the requested activity is  “Completed”."
	ShipmentEventTypeREQS string = "REQS"
	// Completed,"A status indicator that can be used with a number of activity identifiers to denote that a certain activity, service or document has been completed."
	ShipmentEventTypeCMPL string = "CMPL"
	// On Hold,"A status indicator that can be used with a number of activity identifiers to denote that a container or shipment has been placed on hold i.e. can’t  progress in the process."
	ShipmentEventTypeHOLD string = "HOLD"
	// Released,"A status indicator that can be used with a number of activity identifiers to denote that a container or shipment has been released i.e. allowed to move from depot or terminal by authorities or service provider."
	ShipmentEventTypeRELS string = "RELS"
	// Cancelled, "A status indicator to be used when the booking is cancelled by the Shipper"
	ShipmentEventTypeCANC string = "CANC"
)

shipmenteventtypecodes

View Source 
const (
	// Place of Receipt,"The location where the cargo is handed over by the shipper, or his agent, to the shipping line. This indicates the point at which the shipping line takes on responsibility for carriage of the container."POL,Port of Loading,"The location where the cargo is loaded onto a first sea-going vessel for water transportation."
	ShipmentLocationPRE string = "PRE"
	// Port of Loading,"The location where the cargo is loaded onto a first sea-going vessel for water transportation."
	ShipmentLocationPOL string = "POL"
	// Port of Discharge,"The location where the cargo is discharged from the last sea-going vessel."
	ShipmentLocationPOD string = "POD"
	// Place of Delivery,"The location where the cargo is handed over to the consignee, or his agent, by the shipping line and where responsibility of the shipping line ceases."
	ShipmentLocationPDE string = "PDE"
	// Pre-carriage From,
	ShipmentLocationPCF string = "PCF"
	// Precarriage under shipper’s responsibility,"Place and mode of transportation for pre-carriage (e.g. truck, barge, rail) under shipper's responsibility"
	ShipmentLocationPSR string = "PSR"
	// Onward In-land Routing,"The location where the cargo is transported from port of discharge to consignee location on consignee's responsibility (merchant haulage)."
	ShipmentLocationOIR string = "OIR"
	// Depot release location
	ShipmentLocationDRL string = "DRL"
	// Origin of goods
	ShipmentLocationORI string = "ORI"
	// Container intermediate export stop off location,
	ShipmentLocationIEL string = "IEL"
	// Prohibited transshipment port
	ShipmentLocationPTP string = "PTP"
	// Requested transshipment port
	ShipmentLocationRTP string = "RTP"
	// Full container drop-off location
	ShipmentLocationFCD string = "FCD"
	// Empty container pick-up location
	ShipmentLocationECP string = "ECP"
)

shipmentlocationtypes

View Source 
const (
	// Bill of Lading,"Contractual document issued to the shipper which confirms the carrier's receipt of the cargo, acknowledging goods being shipped or received for shipment and specifying the terms of delivery (as one of the evidences of the contract of carriage). The Bill of Lading is usually prepared based on shipping instructions, including cargo description, given by the shipper on forms issued by the carrier and is the title to the goods and can be a negotiable document."
	TransportDocumentTypeBOL string = "BOL"
	// Sea Waybill,"A separate specific transport document type which is non-negotiable, does not transfer title, but which evidences the contract of carriage and receipt of the goods. It must be issued to a named consignee and can be both in a physical or digital format. Goods can be released at destination without presenting the original sea waybill as proof of ownership."
	TransportDocumentTypeSWB string = "SWB"
)

transportdocumenttypecodes

View Source 
const (
	// Arrival
	TransportEventTypeARRI string = "ARRI"
	// Departure
	TransportEventTypeDEPA string = "DEPA"
)

transporteventtypecodes

View Source 
const (
	// Pre-Carriage,Transport leg occurring prior to the main transport leg.
	TransportPlanStageTypePRC string = "PRC"
	// Main Carriage Transport,"The main transport leg(s), happening on one or more main vessels."
	TransportPlanStageTypeMNC string = "MNC"
	// On-Carriage Transport,The transport leg occuring after the main leg to the final destination.
	TransportPlanStageTypeONC string = "ONC"
)

transportplanstagetypes

View Source 
const (
	// Kilogram
	UnitOfMeasuresKGM string = "KGM"
	// Pounds
	UnitOfMeasuresLBR string = "LBR"
	// Cubic Metres
	UnitOfMeasuresCBM string = "CBM"
	// Cubic Feet
	UnitOfMeasuresCFT string = "CFT"
	// Celsius
	UnitOfMeasuresCEL string = "CEL"
	// Fahrenheit
	UnitOfMeasuresFAH string = "FAH"
)

unitofmeasures

View Source 
const (
	// Smart containers,Smart containers
	ValueAddedServiceSCON string = "SCON"
	// Cargo insurance,Cargo insurance
	ValueAddedServiceCINS string = "CINS"
	// Smart IoT devices,Smart IoT devices
	ValueAddedServiceSIOT string = "SIOT"
	// Customs declaration,Customs Declaration
	ValueAddedServiceCDECL string = "CDECL"
	// Shipping guarantee,Shipping guarantee
	ValueAddedServiceSGUAR string = "SGUAR"
	// Upfront payment,Upfront payment
	ValueAddedServiceUPPY string = "UPPY"
)

valueaddedservicecodes

View Source 
const (
	// Vessel Sharing Agreement,An agreement between two or more carriers agreeing to share vessel capacity in specific trades using a specified number of vessels.
	VesselSharingAgreementTypeVSA string = "VSA"
	// Slot Charter Agreement,An agreement between two carriers to sell or exchange a specific number of TEU slots in one or more trades.
	VesselSharingAgreementTypeSCA string = "SCA"
)

vesselsharingagreementtypes

View Source 
const (
	PartyNameLenMin = 1
	PartyNameLenMax = 50
	PartyDescLenMin = 1
	PartyDescLenMax = 1000
)

validationParty for validation of Party fields

View Source 
const (
	FirstNameLenMin = 1
	FirstNameLenMax = 100
	LastNameLenMin  = 1
	LastNameLenMax  = 100
	PasswordLenMin  = 6
	PasswordLenMax  = 50
)

validationName for validation of user fields

View Source 
const Active = "active"

Active - value of status

View Source 
const DBMysql string = "mysql"

DBMysql for DbType is mysql

View Source 
const DBPgsql string = "pgsql"

DBPgsql for DbType is pgsql

View Source 
const Inactive = "Inactive"

Inactive - value of status

View Source 
const Layout = "01/02/2006"

Layout - value of Layout

View Source 
const RPCReqTimeout = 10 * time.Second

RPCReqTimeout - value of request timeout

Variables

This section is empty.

Functions

func AddMiddleware 

func AddMiddleware(h http.Handler, middleware ...func(http.Handler) http.Handler) http.Handler

AddMiddleware - adds middleware to a Handler

func AddPermisionsToRolesResp 

func AddPermisionsToRolesResp(ctx context.Context, in *commonproto.AddPermisionsToRoles) error

AddPermisionsToRolesResp - Add Permisions To Roles

func AssignRolesToUsersResp 

func AssignRolesToUsersResp(ctx context.Context, in *commonproto.AssignRolesToUsers) error

AssignRolesToUsersResp - Assign Roles To Users

func Contains 

func Contains(s []string, e string) bool

func ConvertTimeToTimestamp 

func ConvertTimeToTimestamp(layout string, date string) (*timestamppb.Timestamp, error)

ConvertTimeToTimestamp - used to convert time.Time to timestamp

func CreateAddress 

func CreateAddress(ctx context.Context, in *commonproto.Address, userEmail string, requestID string) (*commonproto.Address, error)

CreateAddress - For Creating Address

func CreateCtxJWT 

func CreateCtxJWT(ctx context.Context) (context.Context, error)

CreateCtxJWT - used to get context

func CreateRoleResp 

func CreateRoleResp(ctx context.Context, in *commonproto.CreateRole) (*commonproto.Role, error)

CreateRoleResp - For Creating Role

func DecodeCursor 

func DecodeCursor(cursor string) string

DecodeCursor - decode cursor

func DecodeListRespBody 

func DecodeListRespBody(respBody []byte) ([]map[string]interface{}, error)

DecodeListRespBody - decode Response

func DecodeRespBody 

func DecodeRespBody(respBody []byte) (map[string]interface{}, error)

DecodeRespBody - decode Response

func DeleteRoleResp 

func DeleteRoleResp(ctx context.Context, in *commonproto.DeleteRole) error

DeleteRoleResp - to delete Role

func EncodeCursor 

func EncodeCursor(cursor uint32) string

EncodeCursor - encode cursor

func EnsureValidToken 

func EnsureValidToken(audience string, domain string) func(http.Handler) http.Handler

func GetAuthBearerToken 

func GetAuthBearerToken(r *http.Request) (string, error)

GetAuthBearerToken - extract the BEARER token from the auth header

func GetClientCred 

func GetClientCred(log *zap.Logger, isTest bool, pwd string, grpcServerOpt *config.GrpcServerOptions) (credentials.TransportCredentials, error)

GetClientCred -- client credentials

func GetHTTPRateLimiter 

func GetHTTPRateLimiter(store *goredisstore.GoRedisStore, maxRate int, maxBurst int) throttled.HTTPRateLimiter

GetHTTPRateLimiter - Get HTTP Rate Limiter

func GetJWTFromCtx 

func GetJWTFromCtx(ctx context.Context, header string) (string, error)

GetJWTFromCtx - used to get jwt from context

func GetJWTOpt 

func GetJWTOpt() *config.JWTOptions

GetJWTOpt get JWT opt used in auth middleware

func GetPathParts 

func GetPathParts(url string) []string

GetPathParts - given a url, returns a slice of the parts of the url

func GetPathQueryString 

func GetPathQueryString(s string) (string, url.Values, error)

GetPathQueryString -- given url string, returns the path, and the query string Eg. "/v1/users?limit=5&cursor=s4R0Z6ecFTzTC4j=" will return "/v1/users", ["limit"]="5", ["cursor"]="s4R0Z6ecFTzTC4j="

func GetRequestID 

func GetRequestID() string

GetRequestID - used for RequestID generation

func GetRolePermissionsResp 

func GetRolePermissionsResp(ctx context.Context, in *commonproto.GetRolePermissions) ([]*commonproto.RolePermission, error)

GetRolePermissionsResp - to get RolePermissions

func GetRoleResp 

func GetRoleResp(ctx context.Context, in *commonproto.GetRole) (*commonproto.Role, error)

GetRoleResp - to get Role

func GetRolesResp 

func GetRolesResp(ctx context.Context, in *commonproto.GetRoles) ([]*commonproto.Role, error)

GetRolesResp - to get Roles

func GetServices 

func GetServices(log *zap.Logger, isTest bool, dbOpt *config.DBOptions, redisOpt *config.RedisOptions, jwtOpt *config.JWTOptions, mailerOpt *config.MailerOptions) (*DBService, *RedisService, *MailerService)

GetServices - Init Db, Redis, and Mailer services

func GetSrvCred 

func GetSrvCred(log *zap.Logger, isTest bool, pwd string, grpcServerOpt *config.GrpcServerOptions) (credentials.TransportCredentials, error)

GetSrvCred -- server credentials

func GetTimeDetails 

func GetTimeDetails() time.Time

GetTimeDetails - used to populate created_by and updated_by fields when inserting/updating records in the database

func GetUUID 

func GetUUID() uuid.UUID

GetUUID - used for UUID generation

func GetUUIDBytes 

func GetUUIDBytes() ([]byte, error)

GetUUIDBytes - used for UUID generation, to save in the db

func HandleCacheControl 

func HandleCacheControl(next *http.ServeMux) http.Handler

func InsertAddress 

func InsertAddress(ctx context.Context, tx *sqlx.Tx, addr *commonproto.Address, userEmail string, requestID string) (*commonproto.Address, error)

InsertAddress - For Inserting Address

func Int32Ptr 

func Int32Ptr(v int32) *int32

Int32Ptr returns pointer to a int32

func Int64Ptr 

func Int64Ptr(v int64) *int64

Int64Ptr returns pointer to a int64

func ParseTemplate 

func ParseTemplate(templateFileName string, data interface{}) (string, error)

ParseTemplate - used for parsing template (for emails)

func ParseURL 

func ParseURL(urlString string) ([]string, url.Values, error)

ParseURL - parses a url into a slice (GetPathParts) and the query string (GetPathQueryString)

func RemoveRolePermissionResp 

func RemoveRolePermissionResp(ctx context.Context, in *commonproto.RemoveRolePermission) error

RemoveRolePermissionResp - Remove Role Permission

func RenderErrorJSON 

func RenderErrorJSON(w http.ResponseWriter, errorCode string, errorMsg string, httpStatusCode int, requestID string)

RenderErrorJSON - send error JSON response

func RenderJSON 

func RenderJSON(w http.ResponseWriter, data interface{})

RenderJSON - send JSON response

func Router 

func Router(router *http.ServeMux) http.Handler

func SendRequest 

func SendRequest(method, url string, payload io.Reader, mgmtToken string) ([]byte, error)

SendRequest - common code for all requests

func SetJWTOpt 

func SetJWTOpt(jwt *config.JWTOptions)

SetJWTOpt set JWT opt used in auth middleware

func StringPtr 

func StringPtr(v string) *string

StringPtr returns pointer to a string

func TimeToTimestamp 

func TimeToTimestamp(dateAt time.Time) *timestamppb.Timestamp

TimeToTimestamp - used to convert time.Time to timestamp

func TimestampToTime 

func TimestampToTime(dateAt *timestamppb.Timestamp) time.Time

TimestampToTime - used to convert timestamp to time.Time

func UUIDBytesToStr 

func UUIDBytesToStr(b []byte) (string, error)

UUIDBytesToStr - convert a UUID retrieved from the DB as str, to string for sending to the client

func UUIDStrToBytes 

func UUIDStrToBytes(s string) ([]byte, error)

UUIDStrToBytes - convert a UUID str into bytes

func UUIDStrToUUID 

func UUIDStrToUUID(s string) (uuid.UUID, error)

UUIDStrToUUID - convert a UUID str into UUID

func UpdateRoleResp 

func UpdateRoleResp(ctx context.Context, in *commonproto.UpdateRole) (*commonproto.Role, error)

UpdateRoleResp - For Updating Role

func ValidatePermissions 

func ValidatePermissions(expectedClaims []string, audience string, domain string) func(next http.Handler) http.Handler

func ViewUserRolesResp 

func ViewUserRolesResp(ctx context.Context, in *commonproto.ViewUserRoles) ([]*commonproto.Role, error)

ViewUserRolesResp - view user roles

Types

type Auth0Config 

type Auth0Config struct {
	Port          string
	SecureOptions secure.Options
	CorsOptions   cors.Options
	Audience      string
	Domain        string
}

type Configuration 

type Configuration struct {
	DomainName      string                    `yaml:"domain"`
	ServiceName     string                    `yaml:"service"`
	HostNameAndPort string                    `yaml:"host"`
	Prometheus      *prometheus.Configuration `yaml:"prometheus"`
}

Configuration for running samples.

type ContextStruct 

type ContextStruct struct {
	Email       string
	TokenString string
}

ContextStruct - stored in the request context set in AuthMiddleware

func GetAuthData 

func GetAuthData(r *http.Request) ContextStruct

GetAuthData - used to get auth details

type CustomClaims 

type CustomClaims struct {
	Permissions []string `json:"permissions"`
	Email       string   `json:"email"`
}

CustomClaims contains custom data we want from the token.

func (CustomClaims) HasPermissions 

func (c CustomClaims) HasPermissions(expectedClaims []string) bool

func (CustomClaims) Validate 

func (c CustomClaims) Validate(ctx context.Context) error

Validate does nothing for this example, but we need it to satisfy validator.CustomClaims interface.

type DBIntf 

type DBIntf interface {
	DBClose() error
}

DBIntf - Interface to the Database

type DBService 

type DBService struct {
	DBType                string
	DB                    *sqlx.DB
	Schema                string
	LimitSQLRows          string
	MySQLTestFilePath     string
	MySQLSchemaFilePath   string
	MySQLTruncateFilePath string
	PgSQLTestFilePath     string
	PgSQLSchemaFilePath   string
	PgSQLTruncateFilePath string
	// contains filtered or unexported fields
}

DBService - Database type and Pointer to access Db

func CreateDBService 

func CreateDBService(log *zap.Logger, dbOpt *config.DBOptions) (*DBService, error)

CreateDBService -- init DB

func NewDBService 

func NewDBService(log *zap.Logger, dbOpt *config.DBOptions) (*DBService, error)

NewDBService - get connection to DB and create a DBService struct

func (*DBService) DBClose 

func (dbService *DBService) DBClose() error

DBClose - Close connection to database

func (*DBService) InsUpd 

func (dbService *DBService) InsUpd(ctx context.Context, userEmail string, requestID string, ex execFunc) error

InsUpd - Insert, Update to database

func (*DBService) QueryRow 

func (dbService *DBService) QueryRow(ctx context.Context, userEmail string, requestID string, query string, args ...interface{}) PartialQuery

QueryRow - Query a single row

func (*DBService) QueryRows 

func (dbService *DBService) QueryRows(ctx context.Context, userEmail string, requestID string, query string, args ...interface{}) PartialQuery

QueryRows - query multiple rows

type EachRowFunc 

type EachRowFunc func(row ScanFunc) error

EachRowFunc - scan a row

type Email 

type Email struct {
	From    string
	To      string
	Subject string
	Body    string
	Cc      string
}

Email - for sending email notifications

type Error 

type Error struct {
	ErrorCode      string `json:"error_code"`
	ErrorMsg       string `json:"error_msg"`
	HTTPStatusCode int    `json:"status"`
	RequestID      string `json:"request_id"`
}

Error - used for

type GetAuthUserDetailsResponse 

type GetAuthUserDetailsResponse struct {
	Email  string
	UserID string
	Roles  []string
}

GetAuthUserDetailsResponse - details of a user stored in the Redis cache

type Key 

type Key string

Key - type of the key used in the request context 

const KeyEmailToken Key = "emailtoken"

KeyEmailToken - used for the request context key

type MailerIntf 

type MailerIntf interface {
	SendConfirmationMail(hostURL string, userEmail string, emailConfirmationToken string, requestID string) error
	SendResetPasswordMail(hostURL string, userEmail string, resetToken string, requestID string) error
	SendChangeMail(hostURL string, userEmail string, newEmail string, resetToken string, requestID string) error
	SendMail(msg Email) error
}

MailerIntf interface to the Mailer

type MailerService 

type MailerService struct {
	Mailer *gomail.Dialer
	// contains filtered or unexported fields
}

MailerService Pointer to mailer

func CreateMailerService 

func CreateMailerService(log *zap.Logger, mailerOpt *config.MailerOptions) (*MailerService, error)

CreateMailerService -- init mailer

func NewMailerService 

func NewMailerService(log *zap.Logger, mailerOpt *config.MailerOptions) (*MailerService, error)

NewMailerService get connection to mailer and create a MailerService struct

func (*MailerService) SendChangeMail 

func (mailerService *MailerService) SendChangeMail(hostURL string, userEmail string, newEmail string, resetToken string, requestID string) error

SendChangeMail - used for sending change email

func (*MailerService) SendConfirmationMail 

func (mailerService *MailerService) SendConfirmationMail(hostURL string, userEmail string, emailConfirmationToken string, requestID string) error

SendConfirmationMail - used for sending confirmation email

func (*MailerService) SendMail 

func (mailerService *MailerService) SendMail(msg Email) error

SendMail - used for sending email

func (*MailerService) SendResetPasswordMail 

func (mailerService *MailerService) SendResetPasswordMail(hostURL string, userEmail string, resetToken string, requestID string) error

SendResetPasswordMail - used for sending reset password email

type PartialQuery 

type PartialQuery func(row EachRowFunc) error

PartialQuery - function to drive the loop

type RedisIntf 

type RedisIntf interface {
	Get(key string) (string, error)
	Set(key string, value interface{}, expiration time.Duration) error
}

RedisIntf Interface to Redis commands All redis command to be called using this interface

type RedisService 

type RedisService struct {
	RedisClient *redis.Client
	// contains filtered or unexported fields
}

RedisService - Redis Pointer to redis

func CreateRedisService 

func CreateRedisService(log *zap.Logger, redisOpt *config.RedisOptions) (*RedisService, error)

CreateRedisService -- init redis

func NewRedisService 

func NewRedisService(log *zap.Logger, redisOpt *config.RedisOptions) (*RedisService, error)

NewRedisService get connection to redis and create a RedisService struct

func (*RedisService) Get 

func (rds *RedisService) Get(key string) (string, error)

Get - call the Get method on the RedisClient

func (*RedisService) Set 

func (rds *RedisService) Set(key string, value interface{}, expiration time.Duration) error

Set - Call the Set method on the Redis client

type ScanFunc 

type ScanFunc func(dest ...interface{}) error

ScanFunc - process row

type Validator 

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

Validator used for validation

func NewValidator 

func NewValidator() *Validator

NewValidator create a Validator struct

func (*Validator) Error 

func (v *Validator) Error() string

Error error

func (*Validator) IsAlpha 

func (v *Validator) IsAlpha(fieldName string, fieldValue string) bool

IsAlpha validate Alpha characters

func (*Validator) IsAlphaNumeric 

func (v *Validator) IsAlphaNumeric(fieldName string, fieldValue string) bool

IsAlphaNumeric validate alpha numeric characters

func (*Validator) IsCreditCard 

func (v *Validator) IsCreditCard(fieldName string, fieldValue string) bool

IsCreditCard validate credit card

func (*Validator) IsDateFormat 

func (v *Validator) IsDateFormat(fieldName string, fieldValue string) bool

IsDateFormat validate date format

func (*Validator) IsDigits 

func (v *Validator) IsDigits(fieldName string, fieldValue string) bool

IsDigits validate Digits

func (*Validator) IsEmail 

func (v *Validator) IsEmail(fieldName string, fieldValue string) bool

IsEmail validate email address

func (*Validator) IsGreaterThan 

func (v *Validator) IsGreaterThan(fieldName string, fieldValue, high int) bool

IsGreaterThan int comparison

func (*Validator) IsInt64Negative 

func (v *Validator) IsInt64Negative(fieldName string, fieldValue int64) bool

IsInt64Negative returns true if value < 0

func (*Validator) IsInt64NonNegative 

func (v *Validator) IsInt64NonNegative(fieldName string, fieldValue int64) bool

IsInt64NonNegative returns true if value >= 0

func (*Validator) IsInt64NonPositive 

func (v *Validator) IsInt64NonPositive(fieldName string, fieldValue int64) bool

IsInt64NonPositive returns true if value <= 0

func (*Validator) IsInt64Positive 

func (v *Validator) IsInt64Positive(fieldName string, fieldValue int64) bool

IsInt64Positive returns true if value > 0

func (*Validator) IsPhoneNumber 

func (v *Validator) IsPhoneNumber(fieldName string, fieldValue string) bool

IsPhoneNumber validate phone number

func (*Validator) IsStrLenBetMinMax 

func (v *Validator) IsStrLenBetMinMax(fieldName string, fieldValue string, min int, max int) bool

IsStrLenBetMinMax string length between min max

func (*Validator) IsStrLenGtMin 

func (v *Validator) IsStrLenGtMin(fieldName string, fieldValue string, min int) bool

IsStrLenGtMin string length greater than min

func (*Validator) IsStrLenLtMax 

func (v *Validator) IsStrLenLtMax(fieldName string, fieldValue string, max int) bool

IsStrLenLtMax string length less than max

func (*Validator) IsStrNotEmpty 

func (v *Validator) IsStrNotEmpty(fieldName string, fieldValue string) bool

IsStrNotEmpty string not empty

func (*Validator) IsTimeBefore 

func (v *Validator) IsTimeBefore(fieldName string, fieldValue, max time.Time) bool

IsTimeBefore time comparison

func (*Validator) IsUUID4 

func (v *Validator) IsUUID4(fieldName string, fieldValue string) bool

IsUUID4 validate UUID4

func (*Validator) IsValid 

func (v *Validator) IsValid() bool

IsValid bool check

type ValidatorIntf 

type ValidatorIntf interface {
	IsGreaterThan(fieldName string, fieldValue, high int) bool
	IsTimeBefore(fieldName string, fieldValue, max time.Time) bool
	IsStrNotEmpty(fieldName string, fieldValue string) bool
	IsInt64Negative(fieldName string, fieldValue int64) bool
	IsInt64NonNegative(fieldName string, fieldValue int64) bool
	IsInt64Positive(fieldName string, fieldValue int64) bool
	IsInt64NonPositive(fieldName string, fieldValue int64) bool
	IsEmail(fieldName string, fieldValue string) bool
	IsDateFormat(fieldName string, fieldValue string) bool
	IsPhoneNumber(fieldName string, fieldValue string) bool
	IsUUID4(fieldName string, fieldValue string) bool
	IsAlpha(fieldName string, fieldValue string) bool
	IsAlphaNumeric(fieldName string, fieldValue string) bool
	IsDigits(fieldName string, fieldValue string) bool
	IsCreditCard(fieldName string, fieldValue string) bool
	IsStrLenGtMin(fieldName string, fieldValue string, min int) bool
	IsStrLenLtMax(fieldName string, fieldValue string, max int) bool
	IsStrLenBetMinMax(fieldName string, fieldValue string, min int, max int) bool
	IsValid() bool
	Error() string
}

ValidatorIntf interface for Validator

type WfHelper 

type WfHelper struct {
	Service            workflowserviceclient.Interface
	WorkerMetricScope  tally.Scope
	ServiceMetricScope tally.Scope
	Logger             *zap.Logger
	Config             Configuration
	Builder            *WorkflowClientBuilder
	DataConverter      encoded.DataConverter
	CtxPropagators     []workflow.ContextPropagator

	Tracer opentracing.Tracer
	// contains filtered or unexported fields
}

WfHelper class for workflow helper.

func (*WfHelper) CancelWorkflow 

func (h *WfHelper) CancelWorkflow(workflowID string)

func (*WfHelper) ConsistentQueryWorkflow 

func (h *WfHelper) ConsistentQueryWorkflow(
	valuePtr interface{},
	workflowID, runID, queryType string,
	args ...interface{},
) error

func (*WfHelper) QueryWorkflow 

func (h *WfHelper) QueryWorkflow(workflowID, runID, queryType string, args ...interface{})

func (*WfHelper) RegisterActivity 

func (h *WfHelper) RegisterActivity(activity interface{})

func (*WfHelper) RegisterActivityWithAlias 

func (h *WfHelper) RegisterActivityWithAlias(activity interface{}, alias string)

func (*WfHelper) RegisterWorkflow 

func (h *WfHelper) RegisterWorkflow(workflow interface{})

func (*WfHelper) RegisterWorkflowWithAlias 

func (h *WfHelper) RegisterWorkflowWithAlias(workflow interface{}, alias string)

func (*WfHelper) SetConfigFile 

func (h *WfHelper) SetConfigFile(configFile string)

SetConfigFile sets the config file path

func (*WfHelper) SetupServiceConfig 

func (h *WfHelper) SetupServiceConfig(defaultConfigFile string)

SetupServiceConfig setup the config for the sample code run

func (*WfHelper) SignalWithStartWorkflowWithCtx 

func (h *WfHelper) SignalWithStartWorkflowWithCtx(ctx context.Context, workflowID string, signalName string, signalArg interface{},
	options client.StartWorkflowOptions, workflow interface{}, workflowArgs ...interface{},
) *workflow.Execution

SignalWithStartWorkflowWithCtx signals workflow and starts it if it's not yet started

func (*WfHelper) SignalWorkflow 

func (h *WfHelper) SignalWorkflow(workflowID, signal string, data interface{})

func (*WfHelper) StartWorkers 

func (h *WfHelper) StartWorkers(domainName string, groupName string, options worker.Options)

StartWorkers starts workflow worker and activity worker based on configured options.

func (*WfHelper) StartWorkflow 

func (h *WfHelper) StartWorkflow(
	options client.StartWorkflowOptions,
	workflow interface{},
	args ...interface{},
) *workflow.Execution

StartWorkflow starts a workflow

func (*WfHelper) StartWorkflowWithCtx 

func (h *WfHelper) StartWorkflowWithCtx(
	ctx context.Context,
	options client.StartWorkflowOptions,
	workflow interface{},
	args ...interface{},
) *workflow.Execution

StartWorkflowWithCtx starts a workflow with the provided context

type WorkflowClientBuilder 

type WorkflowClientBuilder struct {
	Logger *zap.Logger
	// contains filtered or unexported fields
}

WorkflowClientBuilder build client to cadence service

func NewBuilder 

func NewBuilder(logger *zap.Logger) *WorkflowClientBuilder

NewBuilder creates a new WorkflowClientBuilder

func (*WorkflowClientBuilder) BuildCadenceClient 

func (wcb *WorkflowClientBuilder) BuildCadenceClient() (client.Client, error)

BuildCadenceClient builds a client to cadence service

func (*WorkflowClientBuilder) BuildCadenceDomainClient 

func (wcb *WorkflowClientBuilder) BuildCadenceDomainClient() (client.DomainClient, error)

BuildCadenceDomainClient builds a domain client to cadence service

func (*WorkflowClientBuilder) BuildServiceClient 

func (wcb *WorkflowClientBuilder) BuildServiceClient() (workflowserviceclient.Interface, error)

BuildServiceClient builds a rpc service client to cadence service

func (*WorkflowClientBuilder) SetClientIdentity 

func (wcb *WorkflowClientBuilder) SetClientIdentity(identity string) *WorkflowClientBuilder

SetClientIdentity sets the identity for the builder

func (*WorkflowClientBuilder) SetContextPropagators 

func (wcb *WorkflowClientBuilder) SetContextPropagators(ctxProps []workflow.ContextPropagator) *WorkflowClientBuilder

SetContextPropagators sets the context propagators for the builder

func (*WorkflowClientBuilder) SetDataConverter 

func (wcb *WorkflowClientBuilder) SetDataConverter(dataConverter encoded.DataConverter) *WorkflowClientBuilder

SetDataConverter sets the data converter for the builder

func (*WorkflowClientBuilder) SetDispatcher 

func (wcb *WorkflowClientBuilder) SetDispatcher(dispatcher *yarpc.Dispatcher) *WorkflowClientBuilder

SetDispatcher sets the dispatcher for the builder

func (*WorkflowClientBuilder) SetDomain 

func (wcb *WorkflowClientBuilder) SetDomain(domain string) *WorkflowClientBuilder

SetDomain sets the domain for the builder

func (*WorkflowClientBuilder) SetHostPort 

func (wcb *WorkflowClientBuilder) SetHostPort(hostport string) *WorkflowClientBuilder

SetHostPort sets the hostport for the builder

func (*WorkflowClientBuilder) SetMetricsScope 

func (wcb *WorkflowClientBuilder) SetMetricsScope(metricsScope tally.Scope) *WorkflowClientBuilder

SetMetricsScope sets the metrics scope for the builder

func (*WorkflowClientBuilder) SetTracer 

func (wcb *WorkflowClientBuilder) SetTracer(tracer opentracing.Tracer) *WorkflowClientBuilder

SetTracer sets the tracer for the builder

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.