raw_records_service

package
v0.0.0-...-1a5deed Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2020 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use RawRecord.ProtoReflect.Descriptor instead.

func (*RawRecord) GetCheckInInfo

func (x *RawRecord) GetCheckInInfo() string

func (*RawRecord) GetCheckInText

func (x *RawRecord) GetCheckInText() string

func (*RawRecord) GetCreatedAt

func (x *RawRecord) GetCreatedAt() *timestamp.Timestamp

func (*RawRecord) GetEPurseMut

func (x *RawRecord) GetEPurseMut() *wrappers.DoubleValue

func (*RawRecord) GetEPurseMutInfo

func (x *RawRecord) GetEPurseMutInfo() string

func (*RawRecord) GetFare

func (x *RawRecord) GetFare() *wrappers.DoubleValue

func (*RawRecord) GetFareCalculation

func (x *RawRecord) GetFareCalculation() string

func (*RawRecord) GetFareText

func (x *RawRecord) GetFareText() string

func (*RawRecord) GetModalType

func (x *RawRecord) GetModalType() string

func (*RawRecord) GetProductInfo

func (x *RawRecord) GetProductInfo() string

func (*RawRecord) GetProductText

func (x *RawRecord) GetProductText() string

func (*RawRecord) GetPto

func (x *RawRecord) GetPto() string

func (*RawRecord) GetSource

func (x *RawRecord) GetSource() string

func (*RawRecord) GetTransactionDateTime

func (x *RawRecord) GetTransactionDateTime() *timestamp.Timestamp

func (*RawRecord) GetTransactionExplanation

func (x *RawRecord) GetTransactionExplanation() string

func (*RawRecord) GetTransactionInfo

func (x *RawRecord) GetTransactionInfo() string

func (*RawRecord) GetTransactionName

func (x *RawRecord) GetTransactionName() string

func (*RawRecord) GetTransactionPriority

func (x *RawRecord) GetTransactionPriority() string

func (*RawRecord) GetUpdatedAt

func (x *RawRecord) GetUpdatedAt() *timestamp.Timestamp

func (*RawRecord) ProtoMessage

func (*RawRecord) ProtoMessage()

func (*RawRecord) ProtoReflect

func (x *RawRecord) ProtoReflect() protoreflect.Message

func (*RawRecord) Reset

func (x *RawRecord) Reset()

func (*RawRecord) String

func (x *RawRecord) String() string

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.

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) StoreTransactions

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL