Documentation ¶
Overview ¶
Package proto is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterBillingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterBillingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BillingServiceClient) error
- func RegisterBillingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterBillingServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BillingServiceServer) error
- func RegisterBillingServiceServer(s grpc.ServiceRegistrar, srv BillingServiceServer)
- func RegisterRecordsServiceServer(s grpc.ServiceRegistrar, srv RecordsServiceServer)
- type BillingServiceClient
- type BillingServiceServer
- type GetActiveRequest
- type GetTransactionsRequest
- func (*GetTransactionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTransactionsRequest) GetAccount() string
- func (x *GetTransactionsRequest) GetService() string
- func (*GetTransactionsRequest) ProtoMessage()
- func (x *GetTransactionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTransactionsRequest) Reset()
- func (x *GetTransactionsRequest) String() string
- type Kind
- type ListRequest
- type ListResponse
- type Plan
- func (*Plan) Descriptor() ([]byte, []int)deprecated
- func (x *Plan) GetLinkedInstances() []string
- func (x *Plan) GetPublic() bool
- func (x *Plan) GetResources() []*ResourceConf
- func (x *Plan) GetTitle() string
- func (x *Plan) GetType() string
- func (x *Plan) GetUuid() string
- func (*Plan) ProtoMessage()
- func (x *Plan) ProtoReflect() protoreflect.Message
- func (x *Plan) Reset()
- func (x *Plan) String() string
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetEnd() int64
- func (x *Record) GetExec() int64
- func (x *Record) GetInstance() string
- func (x *Record) GetMeta() map[string]*structpb.Value
- func (x *Record) GetProcessed() bool
- func (x *Record) GetResource() string
- func (x *Record) GetStart() int64
- func (x *Record) GetState() proto.NoCloudState
- func (x *Record) GetTotal() float64
- func (x *Record) GetUuid() string
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- type Records
- type RecordsServiceClient
- type RecordsServiceServer
- type ReprocessTransactionsRequest
- func (*ReprocessTransactionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReprocessTransactionsRequest) GetAccount() string
- func (*ReprocessTransactionsRequest) ProtoMessage()
- func (x *ReprocessTransactionsRequest) ProtoReflect() protoreflect.Message
- func (x *ReprocessTransactionsRequest) Reset()
- func (x *ReprocessTransactionsRequest) String() string
- type ResourceConf
- func (*ResourceConf) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceConf) GetExcept() bool
- func (x *ResourceConf) GetKey() string
- func (x *ResourceConf) GetKind() Kind
- func (x *ResourceConf) GetOn() []proto.NoCloudState
- func (x *ResourceConf) GetPeriod() int64
- func (x *ResourceConf) GetPrice() float64
- func (*ResourceConf) ProtoMessage()
- func (x *ResourceConf) ProtoReflect() protoreflect.Message
- func (x *ResourceConf) Reset()
- func (x *ResourceConf) String() string
- type Transaction
- func (*Transaction) Descriptor() ([]byte, []int)deprecated
- func (x *Transaction) GetAccount() string
- func (x *Transaction) GetExec() int64
- func (x *Transaction) GetMeta() map[string]*structpb.Value
- func (x *Transaction) GetProc() int64
- func (x *Transaction) GetProcessed() bool
- func (x *Transaction) GetRecords() []string
- func (x *Transaction) GetService() string
- func (x *Transaction) GetTotal() float64
- func (x *Transaction) GetUuid() string
- func (*Transaction) ProtoMessage()
- func (x *Transaction) ProtoReflect() protoreflect.Message
- func (x *Transaction) Reset()
- func (x *Transaction) String() string
- type Transactions
- type UnimplementedBillingServiceServer
- func (UnimplementedBillingServiceServer) CreatePlan(context.Context, *Plan) (*Plan, error)
- func (UnimplementedBillingServiceServer) CreateTransaction(context.Context, *Transaction) (*Transaction, error)
- func (UnimplementedBillingServiceServer) DeletePlan(context.Context, *Plan) (*Plan, error)
- func (UnimplementedBillingServiceServer) GetPlan(context.Context, *Plan) (*Plan, error)
- func (UnimplementedBillingServiceServer) GetRecords(context.Context, *Transaction) (*Records, error)
- func (UnimplementedBillingServiceServer) GetTransactions(context.Context, *GetTransactionsRequest) (*Transactions, error)
- func (UnimplementedBillingServiceServer) ListPlans(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedBillingServiceServer) Reprocess(context.Context, *ReprocessTransactionsRequest) (*Transactions, error)
- func (UnimplementedBillingServiceServer) UpdatePlan(context.Context, *Plan) (*Plan, error)
- type UnimplementedRecordsServiceServer
- type UnsafeBillingServiceServer
- type UnsafeRecordsServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( Kind_name = map[int32]string{ 0: "UNSPECIFIED", 1: "POSTPAID", 2: "PREPAID", } Kind_value = map[string]int32{ "UNSPECIFIED": 0, "POSTPAID": 1, "PREPAID": 2, } )
Enum value maps for Kind.
var BillingService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nocloud.billing.BillingService", HandlerType: (*BillingServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreatePlan", Handler: _BillingService_CreatePlan_Handler, }, { MethodName: "UpdatePlan", Handler: _BillingService_UpdatePlan_Handler, }, { MethodName: "GetPlan", Handler: _BillingService_GetPlan_Handler, }, { MethodName: "ListPlans", Handler: _BillingService_ListPlans_Handler, }, { MethodName: "DeletePlan", Handler: _BillingService_DeletePlan_Handler, }, { MethodName: "CreateTransaction", Handler: _BillingService_CreateTransaction_Handler, }, { MethodName: "GetTransactions", Handler: _BillingService_GetTransactions_Handler, }, { MethodName: "GetRecords", Handler: _BillingService_GetRecords_Handler, }, { MethodName: "Reprocess", Handler: _BillingService_Reprocess_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/billing/proto/billing.proto", }
BillingService_ServiceDesc is the grpc.ServiceDesc for BillingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_billing_proto_billing_proto protoreflect.FileDescriptor
var RecordsService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "nocloud.billing.RecordsService", HandlerType: (*RecordsServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetActive", Handler: _RecordsService_GetActive_Handler, }, { MethodName: "Create", Handler: _RecordsService_Create_Handler, }, { MethodName: "Update", Handler: _RecordsService_Update_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/billing/proto/billing.proto", }
RecordsService_ServiceDesc is the grpc.ServiceDesc for RecordsService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBillingServiceHandler ¶
func RegisterBillingServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterBillingServiceHandler registers the http handlers for service BillingService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterBillingServiceHandlerClient ¶
func RegisterBillingServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client BillingServiceClient) error
RegisterBillingServiceHandlerClient registers the http handlers for service BillingService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "BillingServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "BillingServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "BillingServiceClient" to call the correct interceptors.
func RegisterBillingServiceHandlerFromEndpoint ¶
func RegisterBillingServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterBillingServiceHandlerFromEndpoint is same as RegisterBillingServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterBillingServiceHandlerServer ¶
func RegisterBillingServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server BillingServiceServer) error
RegisterBillingServiceHandlerServer registers the http handlers for service BillingService to "mux". UnaryRPC :call BillingServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterBillingServiceHandlerFromEndpoint instead.
func RegisterBillingServiceServer ¶
func RegisterBillingServiceServer(s grpc.ServiceRegistrar, srv BillingServiceServer)
func RegisterRecordsServiceServer ¶
func RegisterRecordsServiceServer(s grpc.ServiceRegistrar, srv RecordsServiceServer)
Types ¶
type BillingServiceClient ¶
type BillingServiceClient interface { CreatePlan(ctx context.Context, in *Plan, opts ...grpc.CallOption) (*Plan, error) UpdatePlan(ctx context.Context, in *Plan, opts ...grpc.CallOption) (*Plan, error) GetPlan(ctx context.Context, in *Plan, opts ...grpc.CallOption) (*Plan, error) ListPlans(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) DeletePlan(ctx context.Context, in *Plan, opts ...grpc.CallOption) (*Plan, error) CreateTransaction(ctx context.Context, in *Transaction, opts ...grpc.CallOption) (*Transaction, error) GetTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (*Transactions, error) GetRecords(ctx context.Context, in *Transaction, opts ...grpc.CallOption) (*Records, error) Reprocess(ctx context.Context, in *ReprocessTransactionsRequest, opts ...grpc.CallOption) (*Transactions, error) }
BillingServiceClient is the client API for BillingService 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 NewBillingServiceClient ¶
func NewBillingServiceClient(cc grpc.ClientConnInterface) BillingServiceClient
type BillingServiceServer ¶
type BillingServiceServer interface { CreatePlan(context.Context, *Plan) (*Plan, error) UpdatePlan(context.Context, *Plan) (*Plan, error) GetPlan(context.Context, *Plan) (*Plan, error) ListPlans(context.Context, *ListRequest) (*ListResponse, error) DeletePlan(context.Context, *Plan) (*Plan, error) CreateTransaction(context.Context, *Transaction) (*Transaction, error) GetTransactions(context.Context, *GetTransactionsRequest) (*Transactions, error) GetRecords(context.Context, *Transaction) (*Records, error) Reprocess(context.Context, *ReprocessTransactionsRequest) (*Transactions, error) // contains filtered or unexported methods }
BillingServiceServer is the server API for BillingService service. All implementations must embed UnimplementedBillingServiceServer for forward compatibility
type GetActiveRequest ¶
type GetActiveRequest struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // Instance UUID // contains filtered or unexported fields }
func (*GetActiveRequest) Descriptor
deprecated
func (*GetActiveRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveRequest.ProtoReflect.Descriptor instead.
func (*GetActiveRequest) GetUuid ¶
func (x *GetActiveRequest) GetUuid() string
func (*GetActiveRequest) ProtoMessage ¶
func (*GetActiveRequest) ProtoMessage()
func (*GetActiveRequest) ProtoReflect ¶
func (x *GetActiveRequest) ProtoReflect() protoreflect.Message
func (*GetActiveRequest) Reset ¶
func (x *GetActiveRequest) Reset()
func (*GetActiveRequest) String ¶
func (x *GetActiveRequest) String() string
type GetTransactionsRequest ¶
type GetTransactionsRequest struct { Account *string `protobuf:"bytes,1,opt,name=account,proto3,oneof" json:"account,omitempty"` Service *string `protobuf:"bytes,2,opt,name=service,proto3,oneof" json:"service,omitempty"` // contains filtered or unexported fields }
func (*GetTransactionsRequest) Descriptor
deprecated
func (*GetTransactionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTransactionsRequest.ProtoReflect.Descriptor instead.
func (*GetTransactionsRequest) GetAccount ¶
func (x *GetTransactionsRequest) GetAccount() string
func (*GetTransactionsRequest) GetService ¶
func (x *GetTransactionsRequest) GetService() string
func (*GetTransactionsRequest) ProtoMessage ¶
func (*GetTransactionsRequest) ProtoMessage()
func (*GetTransactionsRequest) ProtoReflect ¶
func (x *GetTransactionsRequest) ProtoReflect() protoreflect.Message
func (*GetTransactionsRequest) Reset ¶
func (x *GetTransactionsRequest) Reset()
func (*GetTransactionsRequest) String ¶
func (x *GetTransactionsRequest) String() string
type Kind ¶
type Kind int32
func (Kind) Descriptor ¶
func (Kind) Descriptor() protoreflect.EnumDescriptor
func (Kind) EnumDescriptor
deprecated
func (Kind) Number ¶
func (x Kind) Number() protoreflect.EnumNumber
func (Kind) Type ¶
func (Kind) Type() protoreflect.EnumType
type ListRequest ¶
type ListRequest struct {
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Pool []*Plan `protobuf:"bytes,1,rep,name=pool,proto3" json:"pool,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetPool ¶
func (x *ListResponse) GetPool() []*Plan
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type Plan ¶
type Plan struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // Instance / InstanceGroup type supported by this plan Public bool `protobuf:"varint,4,opt,name=public,proto3" json:"public,omitempty"` // if true, then this plan is available for all users Resources []*ResourceConf `protobuf:"bytes,5,rep,name=resources,proto3" json:"resources,omitempty"` LinkedInstances []string `protobuf:"bytes,6,rep,name=linked_instances,json=linkedInstances,proto3" json:"linked_instances,omitempty"` // uuids of instances that are linked to this plan // contains filtered or unexported fields }
func (*Plan) Descriptor
deprecated
func (*Plan) GetLinkedInstances ¶
func (*Plan) GetResources ¶
func (x *Plan) GetResources() []*ResourceConf
func (*Plan) ProtoMessage ¶
func (*Plan) ProtoMessage()
func (*Plan) ProtoReflect ¶
func (x *Plan) ProtoReflect() protoreflect.Message
type Record ¶
type Record struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // Record UUID Start int64 `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"` // Timestamp of Record coverage frame start End int64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"` // Timestamp of Record coverage frame end Exec int64 `protobuf:"varint,4,opt,name=exec,proto3" json:"exec,omitempty"` // Time when Record must be processed Processed bool `protobuf:"varint,5,opt,name=processed,proto3" json:"processed,omitempty"` // Wether Record has been processed(converted to Transaction) Instance string `protobuf:"bytes,6,opt,name=instance,proto3" json:"instance,omitempty"` // Instance UUID State proto.NoCloudState `protobuf:"varint,7,opt,name=state,proto3,enum=nocloud.states.NoCloudState" json:"state,omitempty"` // Instance state Resource string `protobuf:"bytes,8,opt,name=resource,proto3" json:"resource,omitempty"` // Resource key Total float64 `protobuf:"fixed64,9,opt,name=total,proto3" json:"total,omitempty"` // Record total value in NCU // Record meta data, like // meta: { // total: <number> // resource "quantity", e.g. CPU cores, RAM Mb, Drive Mb, IP quantity // price_atm: <number> // hourly price per quant of resouce at the moment, e.g. 1 NCU // [other keys]: <any> // for example Drive Type(SSD/HDD/NVMe/etc) // } Meta map[string]*structpb.Value `` /* 150-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Record) Descriptor
deprecated
func (*Record) GetInstance ¶
func (*Record) GetProcessed ¶
func (*Record) GetResource ¶
func (*Record) GetState ¶
func (x *Record) GetState() proto.NoCloudState
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
type Records ¶
type Records struct { Pool []*Record `protobuf:"bytes,1,rep,name=pool,proto3" json:"pool,omitempty"` // contains filtered or unexported fields }
func (*Records) Descriptor
deprecated
func (*Records) ProtoMessage ¶
func (*Records) ProtoMessage()
func (*Records) ProtoReflect ¶
func (x *Records) ProtoReflect() protoreflect.Message
type RecordsServiceClient ¶
type RecordsServiceClient interface { GetActive(ctx context.Context, in *GetActiveRequest, opts ...grpc.CallOption) (*Records, error) Create(ctx context.Context, in *Records, opts ...grpc.CallOption) (*Records, error) Update(ctx context.Context, in *Records, opts ...grpc.CallOption) (*Records, error) }
RecordsServiceClient is the client API for RecordsService 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 NewRecordsServiceClient ¶
func NewRecordsServiceClient(cc grpc.ClientConnInterface) RecordsServiceClient
type RecordsServiceServer ¶
type RecordsServiceServer interface { GetActive(context.Context, *GetActiveRequest) (*Records, error) Create(context.Context, *Records) (*Records, error) Update(context.Context, *Records) (*Records, error) // contains filtered or unexported methods }
RecordsServiceServer is the server API for RecordsService service. All implementations must embed UnimplementedRecordsServiceServer for forward compatibility
type ReprocessTransactionsRequest ¶
type ReprocessTransactionsRequest struct { Account string `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"` // contains filtered or unexported fields }
func (*ReprocessTransactionsRequest) Descriptor
deprecated
func (*ReprocessTransactionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReprocessTransactionsRequest.ProtoReflect.Descriptor instead.
func (*ReprocessTransactionsRequest) GetAccount ¶
func (x *ReprocessTransactionsRequest) GetAccount() string
func (*ReprocessTransactionsRequest) ProtoMessage ¶
func (*ReprocessTransactionsRequest) ProtoMessage()
func (*ReprocessTransactionsRequest) ProtoReflect ¶
func (x *ReprocessTransactionsRequest) ProtoReflect() protoreflect.Message
func (*ReprocessTransactionsRequest) Reset ¶
func (x *ReprocessTransactionsRequest) Reset()
func (*ReprocessTransactionsRequest) String ¶
func (x *ReprocessTransactionsRequest) String() string
type ResourceConf ¶
type ResourceConf struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Kind Kind `protobuf:"varint,2,opt,name=kind,proto3,enum=nocloud.billing.Kind" json:"kind,omitempty"` Price float64 `protobuf:"fixed64,3,opt,name=price,proto3" json:"price,omitempty"` // Price per period Period int64 `protobuf:"varint,4,opt,name=period,proto3" json:"period,omitempty"` // if set to 0, then it's a one-time payment // If except set to true then transaction will be created if Instance is in one of the states listed in on // If except set to false then transaction will be created if Instance is NOT in one of the states listed in on Except bool `protobuf:"varint,5,opt,name=except,proto3" json:"except,omitempty"` On []proto.NoCloudState `protobuf:"varint,6,rep,packed,name=on,proto3,enum=nocloud.states.NoCloudState" json:"on,omitempty"` // contains filtered or unexported fields }
func (*ResourceConf) Descriptor
deprecated
func (*ResourceConf) Descriptor() ([]byte, []int)
Deprecated: Use ResourceConf.ProtoReflect.Descriptor instead.
func (*ResourceConf) GetExcept ¶
func (x *ResourceConf) GetExcept() bool
func (*ResourceConf) GetKey ¶
func (x *ResourceConf) GetKey() string
func (*ResourceConf) GetKind ¶
func (x *ResourceConf) GetKind() Kind
func (*ResourceConf) GetOn ¶
func (x *ResourceConf) GetOn() []proto.NoCloudState
func (*ResourceConf) GetPeriod ¶
func (x *ResourceConf) GetPeriod() int64
func (*ResourceConf) GetPrice ¶
func (x *ResourceConf) GetPrice() float64
func (*ResourceConf) ProtoMessage ¶
func (*ResourceConf) ProtoMessage()
func (*ResourceConf) ProtoReflect ¶
func (x *ResourceConf) ProtoReflect() protoreflect.Message
func (*ResourceConf) Reset ¶
func (x *ResourceConf) Reset()
func (*ResourceConf) String ¶
func (x *ResourceConf) String() string
type Transaction ¶
type Transaction struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` // transaction UUID Exec int64 `protobuf:"varint,2,opt,name=exec,proto3" json:"exec,omitempty"` // Timestamp of Transaction planned execution time Proc int64 `protobuf:"varint,3,opt,name=proc,proto3" json:"proc,omitempty"` // Timestamp of Transaction processing time Processed bool `protobuf:"varint,4,opt,name=processed,proto3" json:"processed,omitempty"` // Wether Transaction has been processed(applied to Account balance, etc) Account string `protobuf:"bytes,5,opt,name=account,proto3" json:"account,omitempty"` Service string `protobuf:"bytes,6,opt,name=service,proto3" json:"service,omitempty"` Records []string `protobuf:"bytes,7,rep,name=records,proto3" json:"records,omitempty"` // list of records UUIDs Total float64 `protobuf:"fixed64,8,opt,name=total,proto3" json:"total,omitempty"` // Transaction total value in NCU // Transaction meta data, like // meta: { // total: <number> // resource "quantity", e.g. CPU cores, RAM Mb, Drive Mb, IP quantity // price_atm: <number> // hourly price per quant of resouce at the moment, e.g. 1 NCU // [other keys]: <any> // for example Drive Type(SSD/HDD/NVMe/etc) // } Meta map[string]*structpb.Value `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Transaction) Descriptor
deprecated
func (*Transaction) Descriptor() ([]byte, []int)
Deprecated: Use Transaction.ProtoReflect.Descriptor instead.
func (*Transaction) GetAccount ¶
func (x *Transaction) GetAccount() string
func (*Transaction) GetExec ¶
func (x *Transaction) GetExec() int64
func (*Transaction) GetProc ¶
func (x *Transaction) GetProc() int64
func (*Transaction) GetProcessed ¶
func (x *Transaction) GetProcessed() bool
func (*Transaction) GetRecords ¶
func (x *Transaction) GetRecords() []string
func (*Transaction) GetService ¶
func (x *Transaction) GetService() string
func (*Transaction) GetTotal ¶
func (x *Transaction) GetTotal() float64
func (*Transaction) GetUuid ¶
func (x *Transaction) GetUuid() string
func (*Transaction) ProtoMessage ¶
func (*Transaction) ProtoMessage()
func (*Transaction) ProtoReflect ¶
func (x *Transaction) ProtoReflect() protoreflect.Message
func (*Transaction) Reset ¶
func (x *Transaction) Reset()
func (*Transaction) String ¶
func (x *Transaction) String() string
type Transactions ¶
type Transactions struct { Pool []*Transaction `protobuf:"bytes,1,rep,name=pool,proto3" json:"pool,omitempty"` // contains filtered or unexported fields }
func (*Transactions) Descriptor
deprecated
func (*Transactions) Descriptor() ([]byte, []int)
Deprecated: Use Transactions.ProtoReflect.Descriptor instead.
func (*Transactions) GetPool ¶
func (x *Transactions) GetPool() []*Transaction
func (*Transactions) ProtoMessage ¶
func (*Transactions) ProtoMessage()
func (*Transactions) ProtoReflect ¶
func (x *Transactions) ProtoReflect() protoreflect.Message
func (*Transactions) Reset ¶
func (x *Transactions) Reset()
func (*Transactions) String ¶
func (x *Transactions) String() string
type UnimplementedBillingServiceServer ¶
type UnimplementedBillingServiceServer struct { }
UnimplementedBillingServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedBillingServiceServer) CreatePlan ¶
func (UnimplementedBillingServiceServer) CreateTransaction ¶
func (UnimplementedBillingServiceServer) CreateTransaction(context.Context, *Transaction) (*Transaction, error)
func (UnimplementedBillingServiceServer) DeletePlan ¶
func (UnimplementedBillingServiceServer) GetRecords ¶
func (UnimplementedBillingServiceServer) GetRecords(context.Context, *Transaction) (*Records, error)
func (UnimplementedBillingServiceServer) GetTransactions ¶
func (UnimplementedBillingServiceServer) GetTransactions(context.Context, *GetTransactionsRequest) (*Transactions, error)
func (UnimplementedBillingServiceServer) ListPlans ¶
func (UnimplementedBillingServiceServer) ListPlans(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedBillingServiceServer) Reprocess ¶
func (UnimplementedBillingServiceServer) Reprocess(context.Context, *ReprocessTransactionsRequest) (*Transactions, error)
func (UnimplementedBillingServiceServer) UpdatePlan ¶
type UnimplementedRecordsServiceServer ¶
type UnimplementedRecordsServiceServer struct { }
UnimplementedRecordsServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedRecordsServiceServer) GetActive ¶
func (UnimplementedRecordsServiceServer) GetActive(context.Context, *GetActiveRequest) (*Records, error)
type UnsafeBillingServiceServer ¶
type UnsafeBillingServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBillingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BillingServiceServer will result in compilation errors.
type UnsafeRecordsServiceServer ¶
type UnsafeRecordsServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRecordsServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RecordsServiceServer will result in compilation errors.