api

package module
v0.0.0-...-afd3805 Latest Latest
Warning

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

 Go to latest Published: Sep 4, 2019 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ChannelType_name = map[int32]string{
	0:  "NONE",
	1:  "RIDE_SHARE",
	2:  "AD_SERVICE",
	3:  "LIB_SERVICE",
	4:  "PT_SERVICE",
	5:  "ROUTING_SERVICE",
	6:  "MARKETING_SERVICE",
	10: "END",
}
View Source 
var ChannelType_value = map[string]int32{
	"NONE":              0,
	"RIDE_SHARE":        1,
	"AD_SERVICE":        2,
	"LIB_SERVICE":       3,
	"PT_SERVICE":        4,
	"ROUTING_SERVICE":   5,
	"MARKETING_SERVICE": 6,
	"END":               10,
}

Functions

func RegisterSynerexServer 

func RegisterSynerexServer(s *grpc.Server, srv SynerexServer)

Types

type Channel 

type Channel struct {
	ClientId             uint64      `protobuf:"fixed64,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Type                 ChannelType `protobuf:"varint,2,opt,name=type,proto3,enum=api.ChannelType" json:"type,omitempty"`
	ArgJson              string      `protobuf:"bytes,3,opt,name=arg_json,json=argJson,proto3" json:"arg_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Channel) Descriptor 

func (*Channel) Descriptor() ([]byte, []int)

func (*Channel) GetArgJson 

func (m *Channel) GetArgJson() string

func (*Channel) GetClientId 

func (m *Channel) GetClientId() uint64

func (*Channel) GetType 

func (m *Channel) GetType() ChannelType

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) String 

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Channel) XXX_Merge 

func (dst *Channel) XXX_Merge(src proto.Message)

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

func (m *Channel) XXX_Unmarshal(b []byte) error

type ChannelType 

type ChannelType int32
const (
	ChannelType_NONE              ChannelType = 0
	ChannelType_RIDE_SHARE        ChannelType = 1
	ChannelType_AD_SERVICE        ChannelType = 2
	ChannelType_LIB_SERVICE       ChannelType = 3
	ChannelType_PT_SERVICE        ChannelType = 4
	ChannelType_ROUTING_SERVICE   ChannelType = 5
	ChannelType_MARKETING_SERVICE ChannelType = 6
	ChannelType_END               ChannelType = 10
)

func (ChannelType) EnumDescriptor 

func (ChannelType) EnumDescriptor() ([]byte, []int)

func (ChannelType) String 

func (x ChannelType) String() string

type ConfirmResponse 

type ConfirmResponse struct {
	Ok                   bool               `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	MbusId               uint64             `protobuf:"fixed64,2,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	Wait                 *duration.Duration `protobuf:"bytes,3,opt,name=wait,proto3" json:"wait,omitempty"`
	Err                  string             `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ConfirmResponse) Descriptor 

func (*ConfirmResponse) Descriptor() ([]byte, []int)

func (*ConfirmResponse) GetErr 

func (m *ConfirmResponse) GetErr() string

func (*ConfirmResponse) GetMbusId 

func (m *ConfirmResponse) GetMbusId() uint64

func (*ConfirmResponse) GetOk 

func (m *ConfirmResponse) GetOk() bool

func (*ConfirmResponse) GetWait 

func (m *ConfirmResponse) GetWait() *duration.Duration

func (*ConfirmResponse) ProtoMessage 

func (*ConfirmResponse) ProtoMessage()

func (*ConfirmResponse) Reset 

func (m *ConfirmResponse) Reset()

func (*ConfirmResponse) String 

func (m *ConfirmResponse) String() string

func (*ConfirmResponse) XXX_DiscardUnknown 

func (m *ConfirmResponse) XXX_DiscardUnknown()

func (*ConfirmResponse) XXX_Marshal 

func (m *ConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfirmResponse) XXX_Merge 

func (dst *ConfirmResponse) XXX_Merge(src proto.Message)

func (*ConfirmResponse) XXX_Size 

func (m *ConfirmResponse) XXX_Size() int

func (*ConfirmResponse) XXX_Unmarshal 

func (m *ConfirmResponse) XXX_Unmarshal(b []byte) error

type Demand 

type Demand struct {
	Id         uint64               `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	SenderId   uint64               `protobuf:"fixed64,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	TargetId   uint64               `protobuf:"fixed64,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Type       ChannelType          `protobuf:"varint,4,opt,name=type,proto3,enum=api.ChannelType" json:"type,omitempty"`
	DemandName string               `protobuf:"bytes,5,opt,name=demand_name,json=demandName,proto3" json:"demand_name,omitempty"`
	Ts         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=ts,proto3" json:"ts,omitempty"`
	// message content = 7; // json
	ArgJson string `protobuf:"bytes,7,opt,name=arg_json,json=argJson,proto3" json:"arg_json,omitempty"`
	MbusId  uint64 `protobuf:"fixed64,8,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	// Types that are valid to be assigned to ArgOneof:
	//	*Demand_Arg_Fleet
	//	*Demand_Arg_RideShare
	//	*Demand_Arg_AdService
	//	*Demand_Arg_LibService
	//	*Demand_Arg_PTService
	//	*Demand_Arg_RoutingService
	//	*Demand_Arg_MarketingService
	//	*Demand_Arg_PTgtfs
	ArgOneof             isDemand_ArgOneof `protobuf_oneof:"arg_oneof"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewDemand 

func NewDemand() *Demand

NewDemand returns empty Demand.

func (*Demand) Descriptor 

func (*Demand) Descriptor() ([]byte, []int)

func (*Demand) GetArgJson 

func (m *Demand) GetArgJson() string

func (*Demand) GetArgOneof 

func (m *Demand) GetArgOneof() isDemand_ArgOneof

func (*Demand) GetArg_AdService 

func (m *Demand) GetArg_AdService() *adservice.AdService

func (*Demand) GetArg_Fleet 

func (m *Demand) GetArg_Fleet() *fleet.Fleet

func (*Demand) GetArg_LibService 

func (m *Demand) GetArg_LibService() *library.LibService

func (*Demand) GetArg_MarketingService 

func (m *Demand) GetArg_MarketingService() *marketing.MarketingService

func (*Demand) GetArg_PTService 

func (m *Demand) GetArg_PTService() *ptransit.PTService

func (*Demand) GetArg_PTgtfs 

func (m *Demand) GetArg_PTgtfs() *ptransit.PTgtfs

func (*Demand) GetArg_RideShare 

func (m *Demand) GetArg_RideShare() *rideshare.RideShare

func (*Demand) GetArg_RoutingService 

func (m *Demand) GetArg_RoutingService() *routing.RoutingService

func (*Demand) GetDemandName 

func (m *Demand) GetDemandName() string

func (*Demand) GetId 

func (m *Demand) GetId() uint64

func (*Demand) GetMbusId 

func (m *Demand) GetMbusId() uint64

func (*Demand) GetSenderId 

func (m *Demand) GetSenderId() uint64

func (*Demand) GetTargetId 

func (m *Demand) GetTargetId() uint64

func (*Demand) GetTs 

func (m *Demand) GetTs() *timestamp.Timestamp

func (*Demand) GetType 

func (m *Demand) GetType() ChannelType

func (*Demand) ProtoMessage 

func (*Demand) ProtoMessage()

func (*Demand) Reset 

func (m *Demand) Reset()

func (*Demand) String 

func (m *Demand) String() string

func (*Demand) WithAdService 

func (dm *Demand) WithAdService(a *adservice.AdService) *Demand

WithAdShare set a given AdShare to Demand.Demand_Arg_AdShare.Arg_AdShare.

func (*Demand) WithFleet 

func (dm *Demand) WithFleet(f *fleet.Fleet) *Demand

WithFleet set a given Fleet to Demand.Demand_Arg_Fleet.Arg_Fleet.

func (*Demand) WithLibService 

func (dm *Demand) WithLibService(l *library.LibService) *Demand

WithLibService set a given LibService to Demand.Demand_Arg_LibService.Arg_LibService.

func (*Demand) WithMarketingService 

func (dm *Demand) WithMarketingService(m *marketing.MarketingService) *Demand

WithMarketingService set a given MarketingService to Demand.Demand_Arg_MarketingService.Arg_MarketingService.

func (*Demand) WithPTService 

func (dm *Demand) WithPTService(p *ptransit.PTService) *Demand

WithPTService set a given PTService to Demand.Demand_Arg_PTService.Arg_PTService.

func (*Demand) WithRideShare 

func (dm *Demand) WithRideShare(r *rideshare.RideShare) *Demand

WithRideShare set a given RideShare to Demand.Demand_Arg_RideShare.Arg_RideShare.

func (*Demand) WithRoutingService 

func (dm *Demand) WithRoutingService(r *routing.RoutingService) *Demand

WithRoutingService set a given RoutingService to Demand.Demand_Arg_RoutingService.Arg_RoutingService.

func (*Demand) XXX_DiscardUnknown 

func (m *Demand) XXX_DiscardUnknown()

func (*Demand) XXX_Marshal 

func (m *Demand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Demand) XXX_Merge 

func (dst *Demand) XXX_Merge(src proto.Message)

func (*Demand) XXX_OneofFuncs 

func (*Demand) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Demand) XXX_Size 

func (m *Demand) XXX_Size() int

func (*Demand) XXX_Unmarshal 

func (m *Demand) XXX_Unmarshal(b []byte) error

type Demand_Arg_AdService 

type Demand_Arg_AdService struct {
	Arg_AdService *adservice.AdService `protobuf:"bytes,12,opt,name=arg_AdService,json=argAdService,proto3,oneof"`
}

type Demand_Arg_Fleet 

type Demand_Arg_Fleet struct {
	Arg_Fleet *fleet.Fleet `protobuf:"bytes,10,opt,name=arg_Fleet,json=argFleet,proto3,oneof"`
}

type Demand_Arg_LibService 

type Demand_Arg_LibService struct {
	Arg_LibService *library.LibService `protobuf:"bytes,13,opt,name=arg_LibService,json=argLibService,proto3,oneof"`
}

type Demand_Arg_MarketingService 

type Demand_Arg_MarketingService struct {
	Arg_MarketingService *marketing.MarketingService `protobuf:"bytes,16,opt,name=arg_MarketingService,json=argMarketingService,proto3,oneof"`
}

type Demand_Arg_PTService 

type Demand_Arg_PTService struct {
	Arg_PTService *ptransit.PTService `protobuf:"bytes,14,opt,name=arg_PTService,json=argPTService,proto3,oneof"`
}

type Demand_Arg_PTgtfs 

type Demand_Arg_PTgtfs struct {
	Arg_PTgtfs *ptransit.PTgtfs `protobuf:"bytes,17,opt,name=arg_PTgtfs,json=argPTgtfs,proto3,oneof"`
}

type Demand_Arg_RideShare 

type Demand_Arg_RideShare struct {
	Arg_RideShare *rideshare.RideShare `protobuf:"bytes,11,opt,name=arg_RideShare,json=argRideShare,proto3,oneof"`
}

type Demand_Arg_RoutingService 

type Demand_Arg_RoutingService struct {
	Arg_RoutingService *routing.RoutingService `protobuf:"bytes,15,opt,name=arg_RoutingService,json=argRoutingService,proto3,oneof"`
}

type Mbus 

type Mbus struct {
	ClientId             uint64   `protobuf:"fixed64,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	MbusId               uint64   `protobuf:"fixed64,2,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	ArgJson              string   `protobuf:"bytes,3,opt,name=arg_json,json=argJson,proto3" json:"arg_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mbus) Descriptor 

func (*Mbus) Descriptor() ([]byte, []int)

func (*Mbus) GetArgJson 

func (m *Mbus) GetArgJson() string

func (*Mbus) GetClientId 

func (m *Mbus) GetClientId() uint64

func (*Mbus) GetMbusId 

func (m *Mbus) GetMbusId() uint64

func (*Mbus) ProtoMessage 

func (*Mbus) ProtoMessage()

func (*Mbus) Reset 

func (m *Mbus) Reset()

func (*Mbus) String 

func (m *Mbus) String() string

func (*Mbus) XXX_DiscardUnknown 

func (m *Mbus) XXX_DiscardUnknown()

func (*Mbus) XXX_Marshal 

func (m *Mbus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mbus) XXX_Merge 

func (dst *Mbus) XXX_Merge(src proto.Message)

func (*Mbus) XXX_Size 

func (m *Mbus) XXX_Size() int

func (*Mbus) XXX_Unmarshal 

func (m *Mbus) XXX_Unmarshal(b []byte) error

type MbusMsg 

type MbusMsg struct {
	MsgId                uint64   `protobuf:"fixed64,1,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	SenderId             uint64   `protobuf:"fixed64,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	TargetId             uint64   `protobuf:"fixed64,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	MbusId               uint64   `protobuf:"fixed64,4,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	MsgType              uint32   `protobuf:"varint,5,opt,name=msg_type,json=msgType,proto3" json:"msg_type,omitempty"`
	MsgInfo              string   `protobuf:"bytes,6,opt,name=msg_info,json=msgInfo,proto3" json:"msg_info,omitempty"`
	ArgJson              string   `protobuf:"bytes,7,opt,name=arg_json,json=argJson,proto3" json:"arg_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MbusMsg) Descriptor 

func (*MbusMsg) Descriptor() ([]byte, []int)

func (*MbusMsg) GetArgJson 

func (m *MbusMsg) GetArgJson() string

func (*MbusMsg) GetMbusId 

func (m *MbusMsg) GetMbusId() uint64

func (*MbusMsg) GetMsgId 

func (m *MbusMsg) GetMsgId() uint64

func (*MbusMsg) GetMsgInfo 

func (m *MbusMsg) GetMsgInfo() string

func (*MbusMsg) GetMsgType 

func (m *MbusMsg) GetMsgType() uint32

func (*MbusMsg) GetSenderId 

func (m *MbusMsg) GetSenderId() uint64

func (*MbusMsg) GetTargetId 

func (m *MbusMsg) GetTargetId() uint64

func (*MbusMsg) ProtoMessage 

func (*MbusMsg) ProtoMessage()

func (*MbusMsg) Reset 

func (m *MbusMsg) Reset()

func (*MbusMsg) String 

func (m *MbusMsg) String() string

func (*MbusMsg) XXX_DiscardUnknown 

func (m *MbusMsg) XXX_DiscardUnknown()

func (*MbusMsg) XXX_Marshal 

func (m *MbusMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MbusMsg) XXX_Merge 

func (dst *MbusMsg) XXX_Merge(src proto.Message)

func (*MbusMsg) XXX_Size 

func (m *MbusMsg) XXX_Size() int

func (*MbusMsg) XXX_Unmarshal 

func (m *MbusMsg) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Err                  string   `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetErr 

func (m *Response) GetErr() string

func (*Response) GetOk 

func (m *Response) GetOk() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (dst *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type Supply 

type Supply struct {
	Id         uint64               `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	SenderId   uint64               `protobuf:"fixed64,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	TargetId   uint64               `protobuf:"fixed64,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Type       ChannelType          `protobuf:"varint,4,opt,name=type,proto3,enum=api.ChannelType" json:"type,omitempty"`
	SupplyName string               `protobuf:"bytes,5,opt,name=supply_name,json=supplyName,proto3" json:"supply_name,omitempty"`
	Ts         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=ts,proto3" json:"ts,omitempty"`
	// message content = 7; // json
	ArgJson string `protobuf:"bytes,7,opt,name=arg_json,json=argJson,proto3" json:"arg_json,omitempty"`
	MbusId  uint64 `protobuf:"fixed64,8,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	// Types that are valid to be assigned to ArgOneof:
	//	*Supply_Arg_Fleet
	//	*Supply_Arg_RideShare
	//	*Supply_Arg_AdService
	//	*Supply_Arg_LibService
	//	*Supply_Arg_PTService
	//	*Supply_Arg_RoutingService
	//	*Supply_Arg_MarketingService
	//	*Supply_Arg_PTgtfs
	ArgOneof             isSupply_ArgOneof `protobuf_oneof:"arg_oneof"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func NewSupply 

func NewSupply() *Supply

NewSupply returns empty Supply.

func (*Supply) Descriptor 

func (*Supply) Descriptor() ([]byte, []int)

func (*Supply) GetArgJson 

func (m *Supply) GetArgJson() string

func (*Supply) GetArgOneof 

func (m *Supply) GetArgOneof() isSupply_ArgOneof

func (*Supply) GetArg_AdService 

func (m *Supply) GetArg_AdService() *adservice.AdService

func (*Supply) GetArg_Fleet 

func (m *Supply) GetArg_Fleet() *fleet.Fleet

func (*Supply) GetArg_LibService 

func (m *Supply) GetArg_LibService() *library.LibService

func (*Supply) GetArg_MarketingService 

func (m *Supply) GetArg_MarketingService() *marketing.MarketingService

func (*Supply) GetArg_PTService 

func (m *Supply) GetArg_PTService() *ptransit.PTService

func (*Supply) GetArg_PTgtfs 

func (m *Supply) GetArg_PTgtfs() *ptransit.PTgtfs

func (*Supply) GetArg_RideShare 

func (m *Supply) GetArg_RideShare() *rideshare.RideShare

func (*Supply) GetArg_RoutingService 

func (m *Supply) GetArg_RoutingService() *routing.RoutingService

func (*Supply) GetId 

func (m *Supply) GetId() uint64

func (*Supply) GetMbusId 

func (m *Supply) GetMbusId() uint64

func (*Supply) GetSenderId 

func (m *Supply) GetSenderId() uint64

func (*Supply) GetSupplyName 

func (m *Supply) GetSupplyName() string

func (*Supply) GetTargetId 

func (m *Supply) GetTargetId() uint64

func (*Supply) GetTs 

func (m *Supply) GetTs() *timestamp.Timestamp

func (*Supply) GetType 

func (m *Supply) GetType() ChannelType

func (*Supply) ProtoMessage 

func (*Supply) ProtoMessage()

func (*Supply) Reset 

func (m *Supply) Reset()

func (*Supply) String 

func (m *Supply) String() string

func (*Supply) WithAdService 

func (sp *Supply) WithAdService(a *adservice.AdService) *Supply

WithAdService set a given AdService to Supply.Supply_Arg_AdService.Arg_AdService.

func (*Supply) WithFleet 

func (sp *Supply) WithFleet(f *fleet.Fleet) *Supply

WithFleet set a given Fleet to Supply.Supply_Arg_Fleet.Arg_Fleet.

func (*Supply) WithLibService 

func (sp *Supply) WithLibService(l *library.LibService) *Supply

WithLibService set a given LibService to Supply.Supply_Arg_LibService.Arg_LibService.

func (*Supply) WithMarketingService 

func (sp *Supply) WithMarketingService(m *marketing.MarketingService) *Supply

WithMarketingService set a given MarketingService to Supply.Supply_Arg_MarketingService.Arg_MarketingService.

func (*Supply) WithPTService 

func (sp *Supply) WithPTService(p *ptransit.PTService) *Supply

WithPTService set a given PTService to Supply.Supply_Arg_PTService.Arg_PTService.

func (*Supply) WithRideShare 

func (sp *Supply) WithRideShare(r *rideshare.RideShare) *Supply

WithRideShare set a given RideShare to Supply.Supply_Arg_RideShare.Arg_RideShare.

func (*Supply) WithRoutingService 

func (sp *Supply) WithRoutingService(r *routing.RoutingService) *Supply

WithRoutingService set a given RoutingService to Supply.Supply_Arg_RoutingService.Arg_RoutingService.

func (*Supply) XXX_DiscardUnknown 

func (m *Supply) XXX_DiscardUnknown()

func (*Supply) XXX_Marshal 

func (m *Supply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Supply) XXX_Merge 

func (dst *Supply) XXX_Merge(src proto.Message)

func (*Supply) XXX_OneofFuncs 

func (*Supply) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Supply) XXX_Size 

func (m *Supply) XXX_Size() int

func (*Supply) XXX_Unmarshal 

func (m *Supply) XXX_Unmarshal(b []byte) error

type Supply_Arg_AdService 

type Supply_Arg_AdService struct {
	Arg_AdService *adservice.AdService `protobuf:"bytes,12,opt,name=arg_AdService,json=argAdService,proto3,oneof"`
}

type Supply_Arg_Fleet 

type Supply_Arg_Fleet struct {
	Arg_Fleet *fleet.Fleet `protobuf:"bytes,10,opt,name=arg_Fleet,json=argFleet,proto3,oneof"`
}

type Supply_Arg_LibService 

type Supply_Arg_LibService struct {
	Arg_LibService *library.LibService `protobuf:"bytes,13,opt,name=arg_LibService,json=argLibService,proto3,oneof"`
}

type Supply_Arg_MarketingService 

type Supply_Arg_MarketingService struct {
	Arg_MarketingService *marketing.MarketingService `protobuf:"bytes,16,opt,name=arg_MarketingService,json=argMarketingService,proto3,oneof"`
}

type Supply_Arg_PTService 

type Supply_Arg_PTService struct {
	Arg_PTService *ptransit.PTService `protobuf:"bytes,14,opt,name=arg_PTService,json=argPTService,proto3,oneof"`
}

type Supply_Arg_PTgtfs 

type Supply_Arg_PTgtfs struct {
	Arg_PTgtfs *ptransit.PTgtfs `protobuf:"bytes,17,opt,name=arg_PTgtfs,json=argPTgtfs,proto3,oneof"`
}

type Supply_Arg_RideShare 

type Supply_Arg_RideShare struct {
	Arg_RideShare *rideshare.RideShare `protobuf:"bytes,11,opt,name=arg_RideShare,json=argRideShare,proto3,oneof"`
}

type Supply_Arg_RoutingService 

type Supply_Arg_RoutingService struct {
	Arg_RoutingService *routing.RoutingService `protobuf:"bytes,15,opt,name=arg_RoutingService,json=argRoutingService,proto3,oneof"`
}

type SynerexClient 

type SynerexClient interface {
	RegisterDemand(ctx context.Context, in *Demand, opts ...grpc.CallOption) (*Response, error)
	RegisterSupply(ctx context.Context, in *Supply, opts ...grpc.CallOption) (*Response, error)
	ProposeDemand(ctx context.Context, in *Demand, opts ...grpc.CallOption) (*Response, error)
	ProposeSupply(ctx context.Context, in *Supply, opts ...grpc.CallOption) (*Response, error)
	ReserveSupply(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)
	ReserveDemand(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)
	SelectSupply(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)
	SelectDemand(ctx context.Context, in *Target, opts ...grpc.CallOption) (*ConfirmResponse, error)
	Confirm(ctx context.Context, in *Target, opts ...grpc.CallOption) (*Response, error)
	SubscribeDemand(ctx context.Context, in *Channel, opts ...grpc.CallOption) (Synerex_SubscribeDemandClient, error)
	SubscribeSupply(ctx context.Context, in *Channel, opts ...grpc.CallOption) (Synerex_SubscribeSupplyClient, error)
	SubscribeMbus(ctx context.Context, in *Mbus, opts ...grpc.CallOption) (Synerex_SubscribeMbusClient, error)
	SendMsg(ctx context.Context, in *MbusMsg, opts ...grpc.CallOption) (*Response, error)
	CloseMbus(ctx context.Context, in *Mbus, opts ...grpc.CallOption) (*Response, error)
}

SynerexClient is the client API for Synerex service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSynerexClient 

func NewSynerexClient(cc *grpc.ClientConn) SynerexClient

type SynerexServer 

type SynerexServer interface {
	RegisterDemand(context.Context, *Demand) (*Response, error)
	RegisterSupply(context.Context, *Supply) (*Response, error)
	ProposeDemand(context.Context, *Demand) (*Response, error)
	ProposeSupply(context.Context, *Supply) (*Response, error)
	ReserveSupply(context.Context, *Target) (*ConfirmResponse, error)
	ReserveDemand(context.Context, *Target) (*ConfirmResponse, error)
	SelectSupply(context.Context, *Target) (*ConfirmResponse, error)
	SelectDemand(context.Context, *Target) (*ConfirmResponse, error)
	Confirm(context.Context, *Target) (*Response, error)
	SubscribeDemand(*Channel, Synerex_SubscribeDemandServer) error
	SubscribeSupply(*Channel, Synerex_SubscribeSupplyServer) error
	SubscribeMbus(*Mbus, Synerex_SubscribeMbusServer) error
	SendMsg(context.Context, *MbusMsg) (*Response, error)
	CloseMbus(context.Context, *Mbus) (*Response, error)
}

SynerexServer is the server API for Synerex service.

type Synerex_SubscribeDemandClient 

type Synerex_SubscribeDemandClient interface {
	Recv() (*Demand, error)
	grpc.ClientStream
}

type Synerex_SubscribeDemandServer 

type Synerex_SubscribeDemandServer interface {
	Send(*Demand) error
	grpc.ServerStream
}

type Synerex_SubscribeMbusClient 

type Synerex_SubscribeMbusClient interface {
	Recv() (*MbusMsg, error)
	grpc.ClientStream
}

type Synerex_SubscribeMbusServer 

type Synerex_SubscribeMbusServer interface {
	Send(*MbusMsg) error
	grpc.ServerStream
}

type Synerex_SubscribeSupplyClient 

type Synerex_SubscribeSupplyClient interface {
	Recv() (*Supply, error)
	grpc.ClientStream
}

type Synerex_SubscribeSupplyServer 

type Synerex_SubscribeSupplyServer interface {
	Send(*Supply) error
	grpc.ServerStream
}

type Target 

type Target struct {
	Id                   uint64             `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	SenderId             uint64             `protobuf:"fixed64,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	TargetId             uint64             `protobuf:"fixed64,3,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Type                 ChannelType        `protobuf:"varint,4,opt,name=type,proto3,enum=api.ChannelType" json:"type,omitempty"`
	Wait                 *duration.Duration `protobuf:"bytes,5,opt,name=wait,proto3" json:"wait,omitempty"`
	MbusId               uint64             `protobuf:"fixed64,6,opt,name=mbus_id,json=mbusId,proto3" json:"mbus_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Target) Descriptor 

func (*Target) Descriptor() ([]byte, []int)

func (*Target) GetId 

func (m *Target) GetId() uint64

func (*Target) GetMbusId 

func (m *Target) GetMbusId() uint64

func (*Target) GetSenderId 

func (m *Target) GetSenderId() uint64

func (*Target) GetTargetId 

func (m *Target) GetTargetId() uint64

func (*Target) GetType 

func (m *Target) GetType() ChannelType

func (*Target) GetWait 

func (m *Target) GetWait() *duration.Duration

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) Reset 

func (m *Target) Reset()

func (*Target) String 

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown 

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal 

func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Target) XXX_Merge 

func (dst *Target) XXX_Merge(src proto.Message)

func (*Target) XXX_Size 

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal 

func (m *Target) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
adservice module
common module
fleet module
library module
ptransit module
rideshare module

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.