Documentation ¶
Index ¶
- Variables
- func RegisterRawRecordsServiceServer(s *grpc.Server, srv RawRecordsServiceServer)
- type FetchByRequestIdRequest
- func (*FetchByRequestIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchByRequestIdRequest) GetRequestID() string
- func (*FetchByRequestIdRequest) ProtoMessage()
- func (x *FetchByRequestIdRequest) ProtoReflect() protoreflect.Message
- func (x *FetchByRequestIdRequest) Reset()
- func (x *FetchByRequestIdRequest) String() string
- type FetchByRequestIdResponse
- func (*FetchByRequestIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchByRequestIdResponse) GetRawRecords() []*RawRecord
- func (*FetchByRequestIdResponse) ProtoMessage()
- func (x *FetchByRequestIdResponse) ProtoReflect() protoreflect.Message
- func (x *FetchByRequestIdResponse) Reset()
- func (x *FetchByRequestIdResponse) String() string
- type RawRecord
- func (*RawRecord) Descriptor() ([]byte, []int)deprecated
- func (x *RawRecord) GetCheckInInfo() string
- func (x *RawRecord) GetCheckInText() string
- func (x *RawRecord) GetCreatedAt() *timestamp.Timestamp
- func (x *RawRecord) GetEPurseMut() *wrappers.DoubleValue
- func (x *RawRecord) GetEPurseMutInfo() string
- func (x *RawRecord) GetFare() *wrappers.DoubleValue
- func (x *RawRecord) GetFareCalculation() string
- func (x *RawRecord) GetFareText() string
- func (x *RawRecord) GetModalType() string
- func (x *RawRecord) GetProductInfo() string
- func (x *RawRecord) GetProductText() string
- func (x *RawRecord) GetPto() string
- func (x *RawRecord) GetSource() string
- func (x *RawRecord) GetTransactionDateTime() *timestamp.Timestamp
- func (x *RawRecord) GetTransactionExplanation() string
- func (x *RawRecord) GetTransactionInfo() string
- func (x *RawRecord) GetTransactionName() string
- func (x *RawRecord) GetTransactionPriority() string
- func (x *RawRecord) GetUpdatedAt() *timestamp.Timestamp
- func (*RawRecord) ProtoMessage()
- func (x *RawRecord) ProtoReflect() protoreflect.Message
- func (x *RawRecord) Reset()
- func (x *RawRecord) String() string
- type RawRecordsServiceClient
- type RawRecordsServiceServer
- type StoreTransactionsRequest
- func (*StoreTransactionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreTransactionsRequest) GetAnalyzeRequestId() string
- func (x *StoreTransactionsRequest) GetSource() string
- func (x *StoreTransactionsRequest) GetTransactions() []*transactions_service.Transaction
- func (*StoreTransactionsRequest) ProtoMessage()
- func (x *StoreTransactionsRequest) ProtoReflect() protoreflect.Message
- func (x *StoreTransactionsRequest) Reset()
- func (x *StoreTransactionsRequest) String() string
- type UnimplementedRawRecordsServiceServer
- type UnsafeRawRecordsServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_raw_records_service_raw_records_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterRawRecordsServiceServer ¶
func RegisterRawRecordsServiceServer(s *grpc.Server, srv RawRecordsServiceServer)
Types ¶
type FetchByRequestIdRequest ¶
type FetchByRequestIdRequest struct { RequestID string `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"` // contains filtered or unexported fields }
func (*FetchByRequestIdRequest) Descriptor
deprecated
func (*FetchByRequestIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchByRequestIdRequest.ProtoReflect.Descriptor instead.
func (*FetchByRequestIdRequest) GetRequestID ¶
func (x *FetchByRequestIdRequest) GetRequestID() string
func (*FetchByRequestIdRequest) ProtoMessage ¶
func (*FetchByRequestIdRequest) ProtoMessage()
func (*FetchByRequestIdRequest) ProtoReflect ¶
func (x *FetchByRequestIdRequest) ProtoReflect() protoreflect.Message
func (*FetchByRequestIdRequest) Reset ¶
func (x *FetchByRequestIdRequest) Reset()
func (*FetchByRequestIdRequest) String ¶
func (x *FetchByRequestIdRequest) String() string
type FetchByRequestIdResponse ¶
type FetchByRequestIdResponse struct { RawRecords []*RawRecord `protobuf:"bytes,1,rep,name=rawRecords,proto3" json:"rawRecords,omitempty"` // contains filtered or unexported fields }
func (*FetchByRequestIdResponse) Descriptor
deprecated
func (*FetchByRequestIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchByRequestIdResponse.ProtoReflect.Descriptor instead.
func (*FetchByRequestIdResponse) GetRawRecords ¶
func (x *FetchByRequestIdResponse) GetRawRecords() []*RawRecord
func (*FetchByRequestIdResponse) ProtoMessage ¶
func (*FetchByRequestIdResponse) ProtoMessage()
func (*FetchByRequestIdResponse) ProtoReflect ¶
func (x *FetchByRequestIdResponse) ProtoReflect() protoreflect.Message
func (*FetchByRequestIdResponse) Reset ¶
func (x *FetchByRequestIdResponse) Reset()
func (*FetchByRequestIdResponse) String ¶
func (x *FetchByRequestIdResponse) String() string
type RawRecord ¶
type RawRecord struct { CheckInInfo string `protobuf:"bytes,1,opt,name=checkInInfo,proto3" json:"checkInInfo,omitempty"` CheckInText string `protobuf:"bytes,2,opt,name=checkInText,proto3" json:"checkInText,omitempty"` Fare *wrappers.DoubleValue `protobuf:"bytes,3,opt,name=fare,proto3" json:"fare,omitempty"` FareCalculation string `protobuf:"bytes,4,opt,name=fareCalculation,proto3" json:"fareCalculation,omitempty"` FareText string `protobuf:"bytes,5,opt,name=fareText,proto3" json:"fareText,omitempty"` ModalType string `protobuf:"bytes,6,opt,name=modalType,proto3" json:"modalType,omitempty"` ProductInfo string `protobuf:"bytes,7,opt,name=productInfo,proto3" json:"productInfo,omitempty"` ProductText string `protobuf:"bytes,8,opt,name=productText,proto3" json:"productText,omitempty"` Pto string `protobuf:"bytes,9,opt,name=pto,proto3" json:"pto,omitempty"` TransactionDateTime *timestamp.Timestamp `protobuf:"bytes,10,opt,name=transactionDateTime,proto3" json:"transactionDateTime,omitempty"` TransactionInfo string `protobuf:"bytes,11,opt,name=transactionInfo,proto3" json:"transactionInfo,omitempty"` TransactionName string `protobuf:"bytes,12,opt,name=transactionName,proto3" json:"transactionName,omitempty"` EPurseMut *wrappers.DoubleValue `protobuf:"bytes,13,opt,name=ePurseMut,proto3" json:"ePurseMut,omitempty"` EPurseMutInfo string `protobuf:"bytes,14,opt,name=ePurseMutInfo,proto3" json:"ePurseMutInfo,omitempty"` TransactionExplanation string `protobuf:"bytes,15,opt,name=transactionExplanation,proto3" json:"transactionExplanation,omitempty"` TransactionPriority string `protobuf:"bytes,16,opt,name=transactionPriority,proto3" json:"transactionPriority,omitempty"` CreatedAt *timestamp.Timestamp `protobuf:"bytes,17,opt,name=createdAt,proto3" json:"createdAt,omitempty"` UpdatedAt *timestamp.Timestamp `protobuf:"bytes,18,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"` Source string `protobuf:"bytes,19,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*RawRecord) Descriptor
deprecated
func (*RawRecord) GetCheckInInfo ¶
func (*RawRecord) GetCheckInText ¶
func (*RawRecord) GetCreatedAt ¶
func (*RawRecord) GetEPurseMut ¶
func (x *RawRecord) GetEPurseMut() *wrappers.DoubleValue
func (*RawRecord) GetEPurseMutInfo ¶
func (*RawRecord) GetFare ¶
func (x *RawRecord) GetFare() *wrappers.DoubleValue
func (*RawRecord) GetFareCalculation ¶
func (*RawRecord) GetFareText ¶
func (*RawRecord) GetModalType ¶
func (*RawRecord) GetProductInfo ¶
func (*RawRecord) GetProductText ¶
func (*RawRecord) GetTransactionDateTime ¶
func (*RawRecord) GetTransactionExplanation ¶
func (*RawRecord) GetTransactionInfo ¶
func (*RawRecord) GetTransactionName ¶
func (*RawRecord) GetTransactionPriority ¶
func (*RawRecord) GetUpdatedAt ¶
func (*RawRecord) ProtoMessage ¶
func (*RawRecord) ProtoMessage()
func (*RawRecord) ProtoReflect ¶
func (x *RawRecord) ProtoReflect() protoreflect.Message
type RawRecordsServiceClient ¶
type RawRecordsServiceClient interface { FetchByRequestId(ctx context.Context, in *FetchByRequestIdRequest, opts ...grpc.CallOption) (*FetchByRequestIdResponse, error) StoreTransactions(ctx context.Context, in *StoreTransactionsRequest, opts ...grpc.CallOption) (*empty.Empty, error) }
RawRecordsServiceClient is the client API for RawRecordsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRawRecordsServiceClient ¶
func NewRawRecordsServiceClient(cc grpc.ClientConnInterface) RawRecordsServiceClient
type RawRecordsServiceServer ¶
type RawRecordsServiceServer interface { FetchByRequestId(context.Context, *FetchByRequestIdRequest) (*FetchByRequestIdResponse, error) StoreTransactions(context.Context, *StoreTransactionsRequest) (*empty.Empty, error) // contains filtered or unexported methods }
RawRecordsServiceServer is the server API for RawRecordsService service. All implementations must embed UnimplementedRawRecordsServiceServer for forward compatibility
type StoreTransactionsRequest ¶
type StoreTransactionsRequest struct { Transactions []*transactions_service.Transaction `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"` Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` AnalyzeRequestId string `protobuf:"bytes,3,opt,name=analyzeRequestId,proto3" json:"analyzeRequestId,omitempty"` // contains filtered or unexported fields }
func (*StoreTransactionsRequest) Descriptor
deprecated
func (*StoreTransactionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreTransactionsRequest.ProtoReflect.Descriptor instead.
func (*StoreTransactionsRequest) GetAnalyzeRequestId ¶
func (x *StoreTransactionsRequest) GetAnalyzeRequestId() string
func (*StoreTransactionsRequest) GetSource ¶
func (x *StoreTransactionsRequest) GetSource() string
func (*StoreTransactionsRequest) GetTransactions ¶
func (x *StoreTransactionsRequest) GetTransactions() []*transactions_service.Transaction
func (*StoreTransactionsRequest) ProtoMessage ¶
func (*StoreTransactionsRequest) ProtoMessage()
func (*StoreTransactionsRequest) ProtoReflect ¶
func (x *StoreTransactionsRequest) ProtoReflect() protoreflect.Message
func (*StoreTransactionsRequest) Reset ¶
func (x *StoreTransactionsRequest) Reset()
func (*StoreTransactionsRequest) String ¶
func (x *StoreTransactionsRequest) String() string
type UnimplementedRawRecordsServiceServer ¶
type UnimplementedRawRecordsServiceServer struct { }
UnimplementedRawRecordsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRawRecordsServiceServer) FetchByRequestId ¶
func (UnimplementedRawRecordsServiceServer) FetchByRequestId(context.Context, *FetchByRequestIdRequest) (*FetchByRequestIdResponse, error)
func (UnimplementedRawRecordsServiceServer) StoreTransactions ¶
func (UnimplementedRawRecordsServiceServer) StoreTransactions(context.Context, *StoreTransactionsRequest) (*empty.Empty, error)
type UnsafeRawRecordsServiceServer ¶
type UnsafeRawRecordsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRawRecordsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RawRecordsServiceServer will result in compilation errors.