collector

Documentation

Index

• Variables
• func RegisterAppUsageCollectorServer(s *grpc.Server, srv AppUsageCollectorServer)
• type AppUsageCollectorClient
  • func NewAppUsageCollectorClient(cc grpc.ClientConnInterface) AppUsageCollectorClient
• type AppUsageCollectorServer
• type UnimplementedAppUsageCollectorServer
  • func (*UnimplementedAppUsageCollectorServer) SendUsage(context.Context, *UsageRequest) (*UsageResponse, error)
• type UsageRequest
  • func (*UsageRequest) Descriptor() ([]byte, []int)
  • func (x *UsageRequest) GetPlanId() string
  • func (x *UsageRequest) GetUsage() float32
  • func (x *UsageRequest) GetUserId() string
  • func (*UsageRequest) ProtoMessage()
  • func (x *UsageRequest) ProtoReflect() protoreflect.Message
  • func (x *UsageRequest) Reset()
  • func (x *UsageRequest) String() string
• type UsageResponse
  • func (*UsageResponse) Descriptor() ([]byte, []int)
  • func (*UsageResponse) ProtoMessage()
  • func (x *UsageResponse) ProtoReflect() protoreflect.Message
  • func (x *UsageResponse) Reset()
  • func (x *UsageResponse) String() string

Variables

var File_app_usage_collector_proto protoreflect.FileDescriptor

Functions

func RegisterAppUsageCollectorServer

func RegisterAppUsageCollectorServer(s *grpc.Server, srv AppUsageCollectorServer)

Types

type AppUsageCollectorClient

type AppUsageCollectorClient interface {
	SendUsage(ctx context.Context, in *UsageRequest, opts ...grpc.CallOption) (*UsageResponse, error)
}

AppUsageCollectorClient is the client API for AppUsageCollector service.

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

func NewAppUsageCollectorClient

func NewAppUsageCollectorClient(cc grpc.ClientConnInterface) AppUsageCollectorClient

type AppUsageCollectorServer

type AppUsageCollectorServer interface {
	SendUsage(context.Context, *UsageRequest) (*UsageResponse, error)
}

AppUsageCollectorServer is the server API for AppUsageCollector service.

type UnimplementedAppUsageCollectorServer

type UnimplementedAppUsageCollectorServer struct {
}

UnimplementedAppUsageCollectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedAppUsageCollectorServer) SendUsage

func (*UnimplementedAppUsageCollectorServer) SendUsage(context.Context, *UsageRequest) (*UsageResponse, error)

type UsageRequest

type UsageRequest struct {
	PlanId string  `protobuf:"bytes,1,opt,name=plan_id,json=planId,proto3" json:"plan_id,omitempty"`
	UserId string  `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Usage  float32 `protobuf:"fixed32,3,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

func (*UsageRequest) Descriptor

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

Deprecated: Use UsageRequest.ProtoReflect.Descriptor instead.

func (*UsageRequest) GetPlanId

func (x *UsageRequest) GetPlanId() string

func (*UsageRequest) GetUsage

func (x *UsageRequest) GetUsage() float32

func (*UsageRequest) GetUserId

func (x *UsageRequest) GetUserId() string

func (*UsageRequest) ProtoMessage

func (*UsageRequest) ProtoMessage()

func (*UsageRequest) ProtoReflect

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

func (*UsageRequest) Reset

func (x *UsageRequest) Reset()

func (*UsageRequest) String

func (x *UsageRequest) String() string

type UsageResponse

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

func (*UsageResponse) Descriptor

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

Deprecated: Use UsageResponse.ProtoReflect.Descriptor instead.

func (*UsageResponse) ProtoMessage

func (*UsageResponse) ProtoMessage()

func (*UsageResponse) ProtoReflect

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

func (*UsageResponse) Reset

func (x *UsageResponse) Reset()

func (*UsageResponse) String

func (x *UsageResponse) String() string