v1

Documentation

Index

• Constants
• Variables
• func RegisterCollectionInternalServiceServer(s grpc.ServiceRegistrar, srv CollectionInternalServiceServer)
• type CollectionInternalServiceClient
  • func NewCollectionInternalServiceClient(cc grpc.ClientConnInterface) CollectionInternalServiceClient
• type CollectionInternalServiceServer
• type CreateUsageRequest
  • func (*CreateUsageRequest) Descriptor() ([]byte, []int)
  • func (x *CreateUsageRequest) GetRecords() []*UsageRecord
  • func (*CreateUsageRequest) ProtoMessage()
  • func (x *CreateUsageRequest) ProtoReflect() protoreflect.Message
  • func (x *CreateUsageRequest) Reset()
  • func (x *CreateUsageRequest) String() string
• type UnimplementedCollectionInternalServiceServer
  • func (UnimplementedCollectionInternalServiceServer) CreateUsage(context.Context, *CreateUsageRequest) (*Usage, error)
• type UnsafeCollectionInternalServiceServer
• type Usage
  • func (*Usage) Descriptor() ([]byte, []int)
  • func (*Usage) ProtoMessage()
  • func (x *Usage) ProtoReflect() protoreflect.Message
  • func (x *Usage) Reset()
  • func (x *Usage) String() string
• type UsageRecord
  • func (*UsageRecord) Descriptor() ([]byte, []int)
  • func (x *UsageRecord) GetApiMethod() string
  • func (x *UsageRecord) GetLatencyMs() int32
  • func (x *UsageRecord) GetOrganization() string
  • func (x *UsageRecord) GetProject() string
  • func (x *UsageRecord) GetStatusCode() int32
  • func (x *UsageRecord) GetTenant() string
  • func (x *UsageRecord) GetTimestamp() int64
  • func (x *UsageRecord) GetUser() string
  • func (*UsageRecord) ProtoMessage()
  • func (x *UsageRecord) ProtoReflect() protoreflect.Message
  • func (x *UsageRecord) Reset()
  • func (x *UsageRecord) String() string

Constants

const (
	CollectionInternalService_CreateUsage_FullMethodName = "/llmariner.apiusage.server.v1.CollectionInternalService/CreateUsage"
)

Variables

var CollectionInternalService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "llmariner.apiusage.server.v1.CollectionInternalService",
	HandlerType: (*CollectionInternalServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateUsage",
			Handler:    _CollectionInternalService_CreateUsage_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/collector_server.proto",
}

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

var File_api_v1_collector_server_proto protoreflect.FileDescriptor

Functions

func RegisterCollectionInternalServiceServer

func RegisterCollectionInternalServiceServer(s grpc.ServiceRegistrar, srv CollectionInternalServiceServer)

Types

type CollectionInternalServiceClient

type CollectionInternalServiceClient interface {
	CreateUsage(ctx context.Context, in *CreateUsageRequest, opts ...grpc.CallOption) (*Usage, error)
}

CollectionInternalServiceClient is the client API for CollectionInternalService 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 NewCollectionInternalServiceClient

func NewCollectionInternalServiceClient(cc grpc.ClientConnInterface) CollectionInternalServiceClient

type CollectionInternalServiceServer

type CollectionInternalServiceServer interface {
	CreateUsage(context.Context, *CreateUsageRequest) (*Usage, error)
	// contains filtered or unexported methods
}

CollectionInternalServiceServer is the server API for CollectionInternalService service. All implementations must embed UnimplementedCollectionInternalServiceServer for forward compatibility

type CreateUsageRequest

type CreateUsageRequest struct {
	Records []*UsageRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateUsageRequest) Descriptor

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

Deprecated: Use CreateUsageRequest.ProtoReflect.Descriptor instead.

func (*CreateUsageRequest) GetRecords

func (x *CreateUsageRequest) GetRecords() []*UsageRecord

func (*CreateUsageRequest) ProtoMessage

func (*CreateUsageRequest) ProtoMessage()

func (*CreateUsageRequest) ProtoReflect

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

func (*CreateUsageRequest) Reset

func (x *CreateUsageRequest) Reset()

func (*CreateUsageRequest) String

func (x *CreateUsageRequest) String() string

type UnimplementedCollectionInternalServiceServer

type UnimplementedCollectionInternalServiceServer struct {
}

UnimplementedCollectionInternalServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCollectionInternalServiceServer) CreateUsage

func (UnimplementedCollectionInternalServiceServer) CreateUsage(context.Context, *CreateUsageRequest) (*Usage, error)

type UnsafeCollectionInternalServiceServer

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

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

type Usage

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

func (*Usage) Descriptor

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

Deprecated: Use Usage.ProtoReflect.Descriptor instead.

func (*Usage) ProtoMessage

func (*Usage) ProtoMessage()

func (*Usage) ProtoReflect

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

func (*Usage) Reset

func (x *Usage) Reset()

func (*Usage) String

func (x *Usage) String() string

type UsageRecord

type UsageRecord struct {
	User         string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Tenant       string `protobuf:"bytes,2,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Organization string `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
	Project      string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	ApiMethod    string `protobuf:"bytes,5,opt,name=api_method,json=apiMethod,proto3" json:"api_method,omitempty"`
	StatusCode   int32  `protobuf:"varint,6,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Timestamp    int64  `protobuf:"varint,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	LatencyMs    int32  `protobuf:"varint,8,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*UsageRecord) Descriptor

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

Deprecated: Use UsageRecord.ProtoReflect.Descriptor instead.

func (*UsageRecord) GetApiMethod

func (x *UsageRecord) GetApiMethod() string

func (*UsageRecord) GetLatencyMs

func (x *UsageRecord) GetLatencyMs() int32

func (*UsageRecord) GetOrganization

func (x *UsageRecord) GetOrganization() string

func (*UsageRecord) GetProject

func (x *UsageRecord) GetProject() string

func (*UsageRecord) GetStatusCode

func (x *UsageRecord) GetStatusCode() int32

func (*UsageRecord) GetTenant

func (x *UsageRecord) GetTenant() string

func (*UsageRecord) GetTimestamp

func (x *UsageRecord) GetTimestamp() int64

func (*UsageRecord) GetUser

func (x *UsageRecord) GetUser() string

func (*UsageRecord) ProtoMessage

func (*UsageRecord) ProtoMessage()

func (*UsageRecord) ProtoReflect

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

func (*UsageRecord) Reset

func (x *UsageRecord) Reset()

func (*UsageRecord) String

func (x *UsageRecord) String() string