usage

Jun 22, 2023

Changes in this version

+ var File_strmprivacy_api_usage_v1_usage_v1_proto protoreflect.FileDescriptor

+ var UsageService_ServiceDesc = grpc.ServiceDesc

+ func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)

+ type GetStreamEventUsageRequest struct

+ EndTime *timestamppb.Timestamp

+ Interval *durationpb.Duration

+ Ref *v1.StreamRef

+ StartTime *timestamppb.Timestamp

+ func (*GetStreamEventUsageRequest) Descriptor() ([]byte, []int)

+ func (*GetStreamEventUsageRequest) ProtoMessage()

+ func (x *GetStreamEventUsageRequest) GetEndTime() *timestamppb.Timestamp

+ func (x *GetStreamEventUsageRequest) GetInterval() *durationpb.Duration

+ func (x *GetStreamEventUsageRequest) GetRef() *v1.StreamRef

+ func (x *GetStreamEventUsageRequest) GetStartTime() *timestamppb.Timestamp

+ func (x *GetStreamEventUsageRequest) ProtoReflect() protoreflect.Message

+ func (x *GetStreamEventUsageRequest) Reset()

+ func (x *GetStreamEventUsageRequest) String() string

+ type GetStreamEventUsageResponse struct

+ Ref *v1.StreamRef

+ Windows []*v1.WindowedEventCount

+ func (*GetStreamEventUsageResponse) Descriptor() ([]byte, []int)

+ func (*GetStreamEventUsageResponse) ProtoMessage()

+ func (x *GetStreamEventUsageResponse) GetRef() *v1.StreamRef

+ func (x *GetStreamEventUsageResponse) GetWindows() []*v1.WindowedEventCount

+ func (x *GetStreamEventUsageResponse) ProtoReflect() protoreflect.Message

+ func (x *GetStreamEventUsageResponse) Reset()

+ func (x *GetStreamEventUsageResponse) String() string

+ type StoreUsageEventRequest struct

+ BillingId string

+ EventArrivalTime *timestamppb.Timestamp

+ EventCount int32

+ ProjectId string

+ Stream string

+ func (*StoreUsageEventRequest) Descriptor() ([]byte, []int)

+ func (*StoreUsageEventRequest) ProtoMessage()

+ func (x *StoreUsageEventRequest) GetBillingId() string

+ func (x *StoreUsageEventRequest) GetEventArrivalTime() *timestamppb.Timestamp

+ func (x *StoreUsageEventRequest) GetEventCount() int32

+ func (x *StoreUsageEventRequest) GetProjectId() string

+ func (x *StoreUsageEventRequest) GetStream() string

+ func (x *StoreUsageEventRequest) ProtoReflect() protoreflect.Message

+ func (x *StoreUsageEventRequest) Reset()

+ func (x *StoreUsageEventRequest) String() string

+ type StoreUsageEventResponse struct

+ func (*StoreUsageEventResponse) Descriptor() ([]byte, []int)

+ func (*StoreUsageEventResponse) ProtoMessage()

+ func (x *StoreUsageEventResponse) ProtoReflect() protoreflect.Message

+ func (x *StoreUsageEventResponse) Reset()

+ func (x *StoreUsageEventResponse) String() string

+ type UnimplementedUsageServiceServer struct

+ func (UnimplementedUsageServiceServer) GetStreamEventUsage(context.Context, *GetStreamEventUsageRequest) (*GetStreamEventUsageResponse, error)

+ func (UnimplementedUsageServiceServer) StoreUsageEvent(context.Context, *StoreUsageEventRequest) (*StoreUsageEventResponse, error)

+ type UnsafeUsageServiceServer interface

+ type UsageServiceClient interface

+ GetStreamEventUsage func(ctx context.Context, in *GetStreamEventUsageRequest, opts ...grpc.CallOption) (*GetStreamEventUsageResponse, error)

+ StoreUsageEvent func(ctx context.Context, in *StoreUsageEventRequest, opts ...grpc.CallOption) (*StoreUsageEventResponse, error)

+ func NewUsageServiceClient(cc grpc.ClientConnInterface) UsageServiceClient

+ type UsageServiceServer interface

+ GetStreamEventUsage func(context.Context, *GetStreamEventUsageRequest) (*GetStreamEventUsageResponse, error)

+ StoreUsageEvent func(context.Context, *StoreUsageEventRequest) (*StoreUsageEventResponse, error)