usage

package
v2.87.1 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_strmprivacy_api_usage_v1_usage_v1_proto protoreflect.FileDescriptor
View Source 
var UsageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "strmprivacy.api.usage.v1.UsageService",
	HandlerType: (*UsageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetStreamEventUsage",
			Handler:    _UsageService_GetStreamEventUsage_Handler,
		},
		{
			MethodName: "StoreUsageEvent",
			Handler:    _UsageService_StoreUsageEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "strmprivacy/api/usage/v1/usage_v1.proto",
}

UsageService_ServiceDesc is the grpc.ServiceDesc for UsageService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterUsageServiceServer 

func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)

Types

type GetStreamEventUsageRequest 

type GetStreamEventUsageRequest struct {
	Ref       *v1.StreamRef          `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Interval  *durationpb.Duration   `protobuf:"bytes,4,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamEventUsageRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamEventUsageRequest.ProtoReflect.Descriptor instead.

func (*GetStreamEventUsageRequest) GetEndTime 

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

func (*GetStreamEventUsageRequest) GetInterval 

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

func (*GetStreamEventUsageRequest) GetRef 

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

func (*GetStreamEventUsageRequest) GetStartTime 

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

func (*GetStreamEventUsageRequest) ProtoMessage 

func (*GetStreamEventUsageRequest) ProtoMessage()

func (*GetStreamEventUsageRequest) ProtoReflect 

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

func (*GetStreamEventUsageRequest) Reset 

func (x *GetStreamEventUsageRequest) Reset()

func (*GetStreamEventUsageRequest) String 

func (x *GetStreamEventUsageRequest) String() string

type GetStreamEventUsageResponse 

type GetStreamEventUsageResponse struct {
	Ref     *v1.StreamRef            `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Windows []*v1.WindowedEventCount `protobuf:"bytes,2,rep,name=windows,proto3" json:"windows,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamEventUsageResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamEventUsageResponse.ProtoReflect.Descriptor instead.

func (*GetStreamEventUsageResponse) GetRef 

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

func (*GetStreamEventUsageResponse) GetWindows 

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

func (*GetStreamEventUsageResponse) ProtoMessage 

func (*GetStreamEventUsageResponse) ProtoMessage()

func (*GetStreamEventUsageResponse) ProtoReflect 

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

func (*GetStreamEventUsageResponse) Reset 

func (x *GetStreamEventUsageResponse) Reset()

func (*GetStreamEventUsageResponse) String 

func (x *GetStreamEventUsageResponse) String() string

type StoreUsageEventRequest added in v2.34.0 

type StoreUsageEventRequest struct {

	// Deprecated: Do not use.
	BillingId        string                 `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	Stream           string                 `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	EventCount       int32                  `protobuf:"varint,3,opt,name=event_count,json=eventCount,proto3" json:"event_count,omitempty"`
	EventArrivalTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=event_arrival_time,json=eventArrivalTime,proto3" json:"event_arrival_time,omitempty"`
	ProjectId        string                 `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreUsageEventRequest) Descriptor deprecated added in v2.34.0 

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

Deprecated: Use StoreUsageEventRequest.ProtoReflect.Descriptor instead.

func (*StoreUsageEventRequest) GetBillingId deprecated added in v2.34.0 

func (x *StoreUsageEventRequest) GetBillingId() string

Deprecated: Do not use.

func (*StoreUsageEventRequest) GetEventArrivalTime added in v2.34.0 

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

func (*StoreUsageEventRequest) GetEventCount added in v2.34.0 

func (x *StoreUsageEventRequest) GetEventCount() int32

func (*StoreUsageEventRequest) GetProjectId added in v2.38.0 

func (x *StoreUsageEventRequest) GetProjectId() string

func (*StoreUsageEventRequest) GetStream added in v2.34.0 

func (x *StoreUsageEventRequest) GetStream() string

func (*StoreUsageEventRequest) ProtoMessage added in v2.34.0 

func (*StoreUsageEventRequest) ProtoMessage()

func (*StoreUsageEventRequest) ProtoReflect added in v2.34.0 

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

func (*StoreUsageEventRequest) Reset added in v2.34.0 

func (x *StoreUsageEventRequest) Reset()

func (*StoreUsageEventRequest) String added in v2.34.0 

func (x *StoreUsageEventRequest) String() string

type StoreUsageEventResponse added in v2.34.0 

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

func (*StoreUsageEventResponse) Descriptor deprecated added in v2.34.0 

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

Deprecated: Use StoreUsageEventResponse.ProtoReflect.Descriptor instead.

func (*StoreUsageEventResponse) ProtoMessage added in v2.34.0 

func (*StoreUsageEventResponse) ProtoMessage()

func (*StoreUsageEventResponse) ProtoReflect added in v2.34.0 

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

func (*StoreUsageEventResponse) Reset added in v2.34.0 

func (x *StoreUsageEventResponse) Reset()

func (*StoreUsageEventResponse) String added in v2.34.0 

func (x *StoreUsageEventResponse) String() string

type UnimplementedUsageServiceServer 

type UnimplementedUsageServiceServer struct {
}

UnimplementedUsageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUsageServiceServer) GetStreamEventUsage 

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

func (UnimplementedUsageServiceServer) StoreUsageEvent added in v2.34.0 

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

type UnsafeUsageServiceServer 

type UnsafeUsageServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUsageServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UsageServiceServer will result in compilation errors.

type UsageServiceClient 

type UsageServiceClient interface {
	GetStreamEventUsage(ctx context.Context, in *GetStreamEventUsageRequest, opts ...grpc.CallOption) (*GetStreamEventUsageResponse, error)
	StoreUsageEvent(ctx context.Context, in *StoreUsageEventRequest, opts ...grpc.CallOption) (*StoreUsageEventResponse, error)
}

UsageServiceClient is the client API for UsageService 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 NewUsageServiceClient 

func NewUsageServiceClient(cc grpc.ClientConnInterface) UsageServiceClient

type UsageServiceServer 

type UsageServiceServer interface {
	GetStreamEventUsage(context.Context, *GetStreamEventUsageRequest) (*GetStreamEventUsageResponse, error)
	StoreUsageEvent(context.Context, *StoreUsageEventRequest) (*StoreUsageEventResponse, error)
}

UsageServiceServer is the server API for UsageService service. All implementations should embed UnimplementedUsageServiceServer for forward compatibility

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.