usagev1beta

package
v0.3.3-alpha.0...-c3d8111 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package usagev1beta is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	UsageService_Liveness_FullMethodName          = "/core.usage.v1beta.UsageService/Liveness"
	UsageService_Readiness_FullMethodName         = "/core.usage.v1beta.UsageService/Readiness"
	UsageService_CreateSession_FullMethodName     = "/core.usage.v1beta.UsageService/CreateSession"
	UsageService_SendSessionReport_FullMethodName = "/core.usage.v1beta.UsageService/SendSessionReport"
)

Variables

View Source 
var (
	Session_Service_name = map[int32]string{
		0: "SERVICE_UNSPECIFIED",
		1: "SERVICE_MGMT",
		2: "SERVICE_CONNECTOR",
		3: "SERVICE_MODEL",
		4: "SERVICE_PIPELINE",
		5: "SERVICE_ARTIFACT",
	}
	Session_Service_value = map[string]int32{
		"SERVICE_UNSPECIFIED": 0,
		"SERVICE_MGMT":        1,
		"SERVICE_CONNECTOR":   2,
		"SERVICE_MODEL":       3,
		"SERVICE_PIPELINE":    4,
		"SERVICE_ARTIFACT":    5,
	}
)

Enum value maps for Session_Service.

View Source 
var File_core_usage_v1beta_usage_proto protoreflect.FileDescriptor
View Source 
var File_core_usage_v1beta_usage_service_proto protoreflect.FileDescriptor
View Source 
var UsageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "core.usage.v1beta.UsageService",
	HandlerType: (*UsageServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Liveness",
			Handler:    _UsageService_Liveness_Handler,
		},
		{
			MethodName: "Readiness",
			Handler:    _UsageService_Readiness_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _UsageService_CreateSession_Handler,
		},
		{
			MethodName: "SendSessionReport",
			Handler:    _UsageService_SendSessionReport_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "core/usage/v1beta/usage_service.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 RegisterUsageServiceHandler 

func RegisterUsageServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterUsageServiceHandler registers the http handlers for service UsageService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterUsageServiceHandlerClient 

func RegisterUsageServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UsageServiceClient) error

RegisterUsageServiceHandlerClient registers the http handlers for service UsageService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UsageServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UsageServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "UsageServiceClient" to call the correct interceptors.

func RegisterUsageServiceHandlerFromEndpoint 

func RegisterUsageServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterUsageServiceHandlerFromEndpoint is same as RegisterUsageServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterUsageServiceHandlerServer 

func RegisterUsageServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UsageServiceServer) error

RegisterUsageServiceHandlerServer registers the http handlers for service UsageService to "mux". UnaryRPC :call UsageServiceServer 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 RegisterUsageServiceHandlerFromEndpoint instead.

func RegisterUsageServiceServer 

func RegisterUsageServiceServer(s grpc.ServiceRegistrar, srv UsageServiceServer)

Types

type ArtifactUsageData 

type ArtifactUsageData struct {

	// Usage data of all users in the artifact service
	Usages []*ArtifactUsageData_UserUsageData `protobuf:"bytes,1,rep,name=usages,proto3" json:"usages,omitempty"`
	// contains filtered or unexported fields
}

Artifact service usage data

func (*ArtifactUsageData) Descriptor deprecated 

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

Deprecated: Use ArtifactUsageData.ProtoReflect.Descriptor instead.

func (*ArtifactUsageData) GetUsages 

func (x *ArtifactUsageData) GetUsages() []*ArtifactUsageData_UserUsageData

func (*ArtifactUsageData) ProtoMessage 

func (*ArtifactUsageData) ProtoMessage()

func (*ArtifactUsageData) ProtoReflect 

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

func (*ArtifactUsageData) Reset 

func (x *ArtifactUsageData) Reset()

func (*ArtifactUsageData) String 

func (x *ArtifactUsageData) String() string

type ArtifactUsageData_UserUsageData 

type ArtifactUsageData_UserUsageData struct {

	// Owner UUID
	OwnerUid string `protobuf:"bytes,1,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
	// Owner type
	OwnerType v1beta1.OwnerType `protobuf:"varint,2,opt,name=owner_type,json=ownerType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"owner_type,omitempty"`
	// contains filtered or unexported fields
}

Per user usage data in the artifact service

func (*ArtifactUsageData_UserUsageData) Descriptor deprecated 

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

Deprecated: Use ArtifactUsageData_UserUsageData.ProtoReflect.Descriptor instead.

func (*ArtifactUsageData_UserUsageData) GetOwnerType 

func (x *ArtifactUsageData_UserUsageData) GetOwnerType() v1beta1.OwnerType

func (*ArtifactUsageData_UserUsageData) GetOwnerUid 

func (x *ArtifactUsageData_UserUsageData) GetOwnerUid() string

func (*ArtifactUsageData_UserUsageData) ProtoMessage 

func (*ArtifactUsageData_UserUsageData) ProtoMessage()

func (*ArtifactUsageData_UserUsageData) ProtoReflect 

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

func (*ArtifactUsageData_UserUsageData) Reset 

func (x *ArtifactUsageData_UserUsageData) Reset()

func (*ArtifactUsageData_UserUsageData) String 

func (x *ArtifactUsageData_UserUsageData) String() string

type ConnectorUsageData 

type ConnectorUsageData struct {

	// Usage data of all users in the connector service
	Usages []*ConnectorUsageData_UserUsageData `protobuf:"bytes,1,rep,name=usages,proto3" json:"usages,omitempty"`
	// contains filtered or unexported fields
}

Connector service usage data

func (*ConnectorUsageData) Descriptor deprecated 

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

Deprecated: Use ConnectorUsageData.ProtoReflect.Descriptor instead.

func (*ConnectorUsageData) GetUsages 

func (x *ConnectorUsageData) GetUsages() []*ConnectorUsageData_UserUsageData

func (*ConnectorUsageData) ProtoMessage 

func (*ConnectorUsageData) ProtoMessage()

func (*ConnectorUsageData) ProtoReflect 

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

func (*ConnectorUsageData) Reset 

func (x *ConnectorUsageData) Reset()

func (*ConnectorUsageData) String 

func (x *ConnectorUsageData) String() string

type ConnectorUsageData_UserUsageData 

type ConnectorUsageData_UserUsageData struct {

	// Owner UUID
	OwnerUid string `protobuf:"bytes,1,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
	// Execution data for each user
	ConnectorExecuteData []*ConnectorUsageData_UserUsageData_ConnectorExecuteData `protobuf:"bytes,2,rep,name=connector_execute_data,json=connectorExecuteData,proto3" json:"connector_execute_data,omitempty"`
	// Owner type
	OwnerType v1beta1.OwnerType `protobuf:"varint,3,opt,name=owner_type,json=ownerType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"owner_type,omitempty"`
	// contains filtered or unexported fields
}

Per user usage data in the connector service

func (*ConnectorUsageData_UserUsageData) Descriptor deprecated 

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

Deprecated: Use ConnectorUsageData_UserUsageData.ProtoReflect.Descriptor instead.

func (*ConnectorUsageData_UserUsageData) GetConnectorExecuteData 

func (x *ConnectorUsageData_UserUsageData) GetConnectorExecuteData() []*ConnectorUsageData_UserUsageData_ConnectorExecuteData

func (*ConnectorUsageData_UserUsageData) GetOwnerType 

func (x *ConnectorUsageData_UserUsageData) GetOwnerType() v1beta1.OwnerType

func (*ConnectorUsageData_UserUsageData) GetOwnerUid 

func (x *ConnectorUsageData_UserUsageData) GetOwnerUid() string

func (*ConnectorUsageData_UserUsageData) ProtoMessage 

func (*ConnectorUsageData_UserUsageData) ProtoMessage()

func (*ConnectorUsageData_UserUsageData) ProtoReflect 

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

func (*ConnectorUsageData_UserUsageData) Reset 

func (x *ConnectorUsageData_UserUsageData) Reset()

func (*ConnectorUsageData_UserUsageData) String 

func (x *ConnectorUsageData_UserUsageData) String() string

type ConnectorUsageData_UserUsageData_ConnectorExecuteData 

type ConnectorUsageData_UserUsageData_ConnectorExecuteData struct {

	// UID for the executed connector
	ConnectorUid string `protobuf:"bytes,1,opt,name=connector_uid,json=connectorUid,proto3" json:"connector_uid,omitempty"`
	// UID for the execute log
	ExecuteUid string `protobuf:"bytes,2,opt,name=execute_uid,json=executeUid,proto3" json:"execute_uid,omitempty"`
	// Timestamp for the execution
	ExecuteTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=execute_time,json=executeTime,proto3" json:"execute_time,omitempty"`
	// Definition UID of the connector
	ConnectorDefinitionUid string `` /* 129-byte string literal not displayed */
	// Final status of the execution
	Status v1beta1.Status `protobuf:"varint,5,opt,name=status,proto3,enum=core.mgmt.v1beta.Status" json:"status,omitempty"`
	// UUID of the user who execute the connector
	UserUid string `protobuf:"bytes,8,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Type of the user who execute the connector
	UserType v1beta1.OwnerType `protobuf:"varint,9,opt,name=user_type,json=userType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"user_type,omitempty"`
	// contains filtered or unexported fields
}

Per execute usage metadata

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) Descriptor deprecated 

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

Deprecated: Use ConnectorUsageData_UserUsageData_ConnectorExecuteData.ProtoReflect.Descriptor instead.

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetConnectorDefinitionUid 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetConnectorDefinitionUid() string

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetConnectorUid 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetConnectorUid() string

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetExecuteTime 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetExecuteTime() *timestamppb.Timestamp

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetExecuteUid 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetExecuteUid() string

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetStatus 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetStatus() v1beta1.Status

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetUserType 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetUserType() v1beta1.OwnerType

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetUserUid 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) GetUserUid() string

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) ProtoMessage 

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) ProtoMessage()

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) ProtoReflect 

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

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) Reset 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) Reset()

func (*ConnectorUsageData_UserUsageData_ConnectorExecuteData) String 

func (x *ConnectorUsageData_UserUsageData_ConnectorExecuteData) String() string

type CreateSessionRequest 

type CreateSessionRequest struct {

	// A session resource to create
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

CreateSessionRequest represents a request to create a new session

func (*CreateSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateSessionRequest) GetSession 

func (x *CreateSessionRequest) GetSession() *Session

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) ProtoReflect 

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

func (*CreateSessionRequest) Reset 

func (x *CreateSessionRequest) Reset()

func (*CreateSessionRequest) String 

func (x *CreateSessionRequest) String() string

type CreateSessionResponse 

type CreateSessionResponse struct {

	// A session resource
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

CreateSessionResponse represents a response for a session response

func (*CreateSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateSessionResponse) GetSession 

func (x *CreateSessionResponse) GetSession() *Session

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) ProtoReflect 

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

func (*CreateSessionResponse) Reset 

func (x *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String 

func (x *CreateSessionResponse) String() string

type LivenessRequest 

type LivenessRequest struct {

	// HealthCheckRequest message
	HealthCheckRequest *v1beta.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"`
	// contains filtered or unexported fields
}

LivenessRequest represents a request to check a service liveness status

func (*LivenessRequest) Descriptor deprecated 

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

Deprecated: Use LivenessRequest.ProtoReflect.Descriptor instead.

func (*LivenessRequest) GetHealthCheckRequest 

func (x *LivenessRequest) GetHealthCheckRequest() *v1beta.HealthCheckRequest

func (*LivenessRequest) ProtoMessage 

func (*LivenessRequest) ProtoMessage()

func (*LivenessRequest) ProtoReflect 

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

func (*LivenessRequest) Reset 

func (x *LivenessRequest) Reset()

func (*LivenessRequest) String 

func (x *LivenessRequest) String() string

type LivenessResponse 

type LivenessResponse struct {

	// HealthCheckResponse message
	HealthCheckResponse *v1beta.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"`
	// contains filtered or unexported fields
}

LivenessResponse represents a response for a service liveness status

func (*LivenessResponse) Descriptor deprecated 

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

Deprecated: Use LivenessResponse.ProtoReflect.Descriptor instead.

func (*LivenessResponse) GetHealthCheckResponse 

func (x *LivenessResponse) GetHealthCheckResponse() *v1beta.HealthCheckResponse

func (*LivenessResponse) ProtoMessage 

func (*LivenessResponse) ProtoMessage()

func (*LivenessResponse) ProtoReflect 

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

func (*LivenessResponse) Reset 

func (x *LivenessResponse) Reset()

func (*LivenessResponse) String 

func (x *LivenessResponse) String() string

type MgmtUsageData 

type MgmtUsageData struct {

	// Repeated user usage data
	UserUsages []*v1beta1.AuthenticatedUser `protobuf:"bytes,1,rep,name=user_usages,json=userUsages,proto3" json:"user_usages,omitempty"`
	// Repeated org usage data
	OrgUsages []*v1beta1.Organization `protobuf:"bytes,2,rep,name=org_usages,json=orgUsages,proto3" json:"org_usages,omitempty"`
	// contains filtered or unexported fields
}

Management service usage data

func (*MgmtUsageData) Descriptor deprecated 

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

Deprecated: Use MgmtUsageData.ProtoReflect.Descriptor instead.

func (*MgmtUsageData) GetOrgUsages 

func (x *MgmtUsageData) GetOrgUsages() []*v1beta1.Organization

func (*MgmtUsageData) GetUserUsages 

func (x *MgmtUsageData) GetUserUsages() []*v1beta1.AuthenticatedUser

func (*MgmtUsageData) ProtoMessage 

func (*MgmtUsageData) ProtoMessage()

func (*MgmtUsageData) ProtoReflect 

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

func (*MgmtUsageData) Reset 

func (x *MgmtUsageData) Reset()

func (*MgmtUsageData) String 

func (x *MgmtUsageData) String() string

type ModelUsageData 

type ModelUsageData struct {

	// Usage data of all users in the model service
	Usages []*ModelUsageData_UserUsageData `protobuf:"bytes,1,rep,name=usages,proto3" json:"usages,omitempty"`
	// contains filtered or unexported fields
}

Model service usage data

func (*ModelUsageData) Descriptor deprecated 

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

Deprecated: Use ModelUsageData.ProtoReflect.Descriptor instead.

func (*ModelUsageData) GetUsages 

func (x *ModelUsageData) GetUsages() []*ModelUsageData_UserUsageData

func (*ModelUsageData) ProtoMessage 

func (*ModelUsageData) ProtoMessage()

func (*ModelUsageData) ProtoReflect 

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

func (*ModelUsageData) Reset 

func (x *ModelUsageData) Reset()

func (*ModelUsageData) String 

func (x *ModelUsageData) String() string

type ModelUsageData_UserUsageData 

type ModelUsageData_UserUsageData struct {

	// Owner UUID
	OwnerUid string `protobuf:"bytes,1,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
	// Trigger data for each user
	ModelTriggerData []*ModelUsageData_UserUsageData_ModelTriggerData `protobuf:"bytes,2,rep,name=model_trigger_data,json=modelTriggerData,proto3" json:"model_trigger_data,omitempty"`
	// Owner type
	OwnerType v1beta1.OwnerType `protobuf:"varint,3,opt,name=owner_type,json=ownerType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"owner_type,omitempty"`
	// contains filtered or unexported fields
}

Per user usage data in the model service

func (*ModelUsageData_UserUsageData) Descriptor deprecated 

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

Deprecated: Use ModelUsageData_UserUsageData.ProtoReflect.Descriptor instead.

func (*ModelUsageData_UserUsageData) GetModelTriggerData 

func (x *ModelUsageData_UserUsageData) GetModelTriggerData() []*ModelUsageData_UserUsageData_ModelTriggerData

func (*ModelUsageData_UserUsageData) GetOwnerType 

func (x *ModelUsageData_UserUsageData) GetOwnerType() v1beta1.OwnerType

func (*ModelUsageData_UserUsageData) GetOwnerUid 

func (x *ModelUsageData_UserUsageData) GetOwnerUid() string

func (*ModelUsageData_UserUsageData) ProtoMessage 

func (*ModelUsageData_UserUsageData) ProtoMessage()

func (*ModelUsageData_UserUsageData) ProtoReflect 

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

func (*ModelUsageData_UserUsageData) Reset 

func (x *ModelUsageData_UserUsageData) Reset()

func (*ModelUsageData_UserUsageData) String 

func (x *ModelUsageData_UserUsageData) String() string

type ModelUsageData_UserUsageData_ModelTriggerData 

type ModelUsageData_UserUsageData_ModelTriggerData struct {

	// UID for the trigged model
	ModelUid string `protobuf:"bytes,1,opt,name=model_uid,json=modelUid,proto3" json:"model_uid,omitempty"`
	// UID for the trigger log
	TriggerUid string `protobuf:"bytes,2,opt,name=trigger_uid,json=triggerUid,proto3" json:"trigger_uid,omitempty"`
	// Timestamp for the trigger
	TriggerTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=trigger_time,json=triggerTime,proto3" json:"trigger_time,omitempty"`
	// Definition UID of the model
	ModelDefinitionUid string `protobuf:"bytes,4,opt,name=model_definition_uid,json=modelDefinitionUid,proto3" json:"model_definition_uid,omitempty"`
	// Task of the model
	ModelTask v1alpha.Task `protobuf:"varint,5,opt,name=model_task,json=modelTask,proto3,enum=common.task.v1alpha.Task" json:"model_task,omitempty"`
	// Final status of the execution
	Status v1beta1.Status `protobuf:"varint,6,opt,name=status,proto3,enum=core.mgmt.v1beta.Status" json:"status,omitempty"`
	// UUID of the user who trigger the model
	UserUid string `protobuf:"bytes,7,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Type of the user who trigger the model
	UserType v1beta1.OwnerType `protobuf:"varint,8,opt,name=user_type,json=userType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"user_type,omitempty"`
	// contains filtered or unexported fields
}

Per trigger usage metadata

func (*ModelUsageData_UserUsageData_ModelTriggerData) Descriptor deprecated 

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

Deprecated: Use ModelUsageData_UserUsageData_ModelTriggerData.ProtoReflect.Descriptor instead.

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetModelDefinitionUid 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetModelDefinitionUid() string

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetModelTask 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetModelTask() v1alpha.Task

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetModelUid 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetModelUid() string

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetStatus 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetStatus() v1beta1.Status

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetTriggerTime 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetTriggerTime() *timestamppb.Timestamp

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetTriggerUid 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetTriggerUid() string

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetUserType 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetUserType() v1beta1.OwnerType

func (*ModelUsageData_UserUsageData_ModelTriggerData) GetUserUid 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) GetUserUid() string

func (*ModelUsageData_UserUsageData_ModelTriggerData) ProtoMessage 

func (*ModelUsageData_UserUsageData_ModelTriggerData) ProtoMessage()

func (*ModelUsageData_UserUsageData_ModelTriggerData) ProtoReflect 

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

func (*ModelUsageData_UserUsageData_ModelTriggerData) Reset 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) Reset()

func (*ModelUsageData_UserUsageData_ModelTriggerData) String 

func (x *ModelUsageData_UserUsageData_ModelTriggerData) String() string

type PipelineUsageData 

type PipelineUsageData struct {

	// Usage data of all users in the pipeline service
	Usages []*PipelineUsageData_UserUsageData `protobuf:"bytes,1,rep,name=usages,proto3" json:"usages,omitempty"`
	// contains filtered or unexported fields
}

Pipeline service usage data

func (*PipelineUsageData) Descriptor deprecated 

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

Deprecated: Use PipelineUsageData.ProtoReflect.Descriptor instead.

func (*PipelineUsageData) GetUsages 

func (x *PipelineUsageData) GetUsages() []*PipelineUsageData_UserUsageData

func (*PipelineUsageData) ProtoMessage 

func (*PipelineUsageData) ProtoMessage()

func (*PipelineUsageData) ProtoReflect 

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

func (*PipelineUsageData) Reset 

func (x *PipelineUsageData) Reset()

func (*PipelineUsageData) String 

func (x *PipelineUsageData) String() string

type PipelineUsageData_UserUsageData 

type PipelineUsageData_UserUsageData struct {

	// Owner UUID
	OwnerUid string `protobuf:"bytes,1,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
	// Trigger data for each user
	PipelineTriggerData []*PipelineUsageData_UserUsageData_PipelineTriggerData `protobuf:"bytes,2,rep,name=pipeline_trigger_data,json=pipelineTriggerData,proto3" json:"pipeline_trigger_data,omitempty"`
	// Owner type
	OwnerType v1beta1.OwnerType `protobuf:"varint,3,opt,name=owner_type,json=ownerType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"owner_type,omitempty"`
	// contains filtered or unexported fields
}

Per user usage data in the pipeline service

func (*PipelineUsageData_UserUsageData) Descriptor deprecated 

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

Deprecated: Use PipelineUsageData_UserUsageData.ProtoReflect.Descriptor instead.

func (*PipelineUsageData_UserUsageData) GetOwnerType 

func (x *PipelineUsageData_UserUsageData) GetOwnerType() v1beta1.OwnerType

func (*PipelineUsageData_UserUsageData) GetOwnerUid 

func (x *PipelineUsageData_UserUsageData) GetOwnerUid() string

func (*PipelineUsageData_UserUsageData) GetPipelineTriggerData 

func (x *PipelineUsageData_UserUsageData) GetPipelineTriggerData() []*PipelineUsageData_UserUsageData_PipelineTriggerData

func (*PipelineUsageData_UserUsageData) ProtoMessage 

func (*PipelineUsageData_UserUsageData) ProtoMessage()

func (*PipelineUsageData_UserUsageData) ProtoReflect 

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

func (*PipelineUsageData_UserUsageData) Reset 

func (x *PipelineUsageData_UserUsageData) Reset()

func (*PipelineUsageData_UserUsageData) String 

func (x *PipelineUsageData_UserUsageData) String() string

type PipelineUsageData_UserUsageData_PipelineTriggerData 

type PipelineUsageData_UserUsageData_PipelineTriggerData struct {

	// UID for the triggered pipeline
	PipelineUid string `protobuf:"bytes,1,opt,name=pipeline_uid,json=pipelineUid,proto3" json:"pipeline_uid,omitempty"`
	// UID for the trigger log
	TriggerUid string `protobuf:"bytes,2,opt,name=trigger_uid,json=triggerUid,proto3" json:"trigger_uid,omitempty"`
	// Timestamp for the trigger
	TriggerTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=trigger_time,json=triggerTime,proto3" json:"trigger_time,omitempty"`
	// Trigger mode
	TriggerMode v1beta1.Mode `protobuf:"varint,4,opt,name=trigger_mode,json=triggerMode,proto3,enum=core.mgmt.v1beta.Mode" json:"trigger_mode,omitempty"`
	// Final status of the execution
	Status v1beta1.Status `protobuf:"varint,5,opt,name=status,proto3,enum=core.mgmt.v1beta.Status" json:"status,omitempty"`
	// Version for the triggered release pipeline, empty string if not release
	PipelineReleaseId string `protobuf:"bytes,6,opt,name=pipeline_release_id,json=pipelineReleaseId,proto3" json:"pipeline_release_id,omitempty"`
	// UID for the triggered release pipeline, empty string if not release
	PipelineReleaseUid string `protobuf:"bytes,7,opt,name=pipeline_release_uid,json=pipelineReleaseUid,proto3" json:"pipeline_release_uid,omitempty"`
	// UUID of the user who trigger the pipeline
	UserUid string `protobuf:"bytes,8,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Type of the user who trigger the pipeline
	UserType v1beta1.OwnerType `protobuf:"varint,9,opt,name=user_type,json=userType,proto3,enum=core.mgmt.v1beta.OwnerType" json:"user_type,omitempty"`
	// ID for the triggered pipeline
	PipelineId string `protobuf:"bytes,10,opt,name=pipeline_id,json=pipelineId,proto3" json:"pipeline_id,omitempty"`
	// contains filtered or unexported fields
}

Per trigger usage metadata

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) Descriptor deprecated 

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

Deprecated: Use PipelineUsageData_UserUsageData_PipelineTriggerData.ProtoReflect.Descriptor instead.

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineId 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineId() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineReleaseId 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineReleaseId() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineReleaseUid 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineReleaseUid() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineUid 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetPipelineUid() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetStatus 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetStatus() v1beta1.Status

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerMode 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerMode() v1beta1.Mode

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerTime 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerTime() *timestamppb.Timestamp

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerUid 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetTriggerUid() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetUserType 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetUserType() v1beta1.OwnerType

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) GetUserUid 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) GetUserUid() string

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) ProtoMessage 

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) ProtoMessage()

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) ProtoReflect 

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

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) Reset 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) Reset()

func (*PipelineUsageData_UserUsageData_PipelineTriggerData) String 

func (x *PipelineUsageData_UserUsageData_PipelineTriggerData) String() string

type ReadinessRequest 

type ReadinessRequest struct {

	// HealthCheckRequest message
	HealthCheckRequest *v1beta.HealthCheckRequest `protobuf:"bytes,1,opt,name=health_check_request,json=healthCheckRequest,proto3,oneof" json:"health_check_request,omitempty"`
	// contains filtered or unexported fields
}

ReadinessRequest represents a request to check a service readiness status

func (*ReadinessRequest) Descriptor deprecated 

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

Deprecated: Use ReadinessRequest.ProtoReflect.Descriptor instead.

func (*ReadinessRequest) GetHealthCheckRequest 

func (x *ReadinessRequest) GetHealthCheckRequest() *v1beta.HealthCheckRequest

func (*ReadinessRequest) ProtoMessage 

func (*ReadinessRequest) ProtoMessage()

func (*ReadinessRequest) ProtoReflect 

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

func (*ReadinessRequest) Reset 

func (x *ReadinessRequest) Reset()

func (*ReadinessRequest) String 

func (x *ReadinessRequest) String() string

type ReadinessResponse 

type ReadinessResponse struct {

	// HealthCheckResponse message
	HealthCheckResponse *v1beta.HealthCheckResponse `protobuf:"bytes,1,opt,name=health_check_response,json=healthCheckResponse,proto3" json:"health_check_response,omitempty"`
	// contains filtered or unexported fields
}

ReadinessResponse represents a response for a service readiness status

func (*ReadinessResponse) Descriptor deprecated 

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

Deprecated: Use ReadinessResponse.ProtoReflect.Descriptor instead.

func (*ReadinessResponse) GetHealthCheckResponse 

func (x *ReadinessResponse) GetHealthCheckResponse() *v1beta.HealthCheckResponse

func (*ReadinessResponse) ProtoMessage 

func (*ReadinessResponse) ProtoMessage()

func (*ReadinessResponse) ProtoReflect 

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

func (*ReadinessResponse) Reset 

func (x *ReadinessResponse) Reset()

func (*ReadinessResponse) String 

func (x *ReadinessResponse) String() string

type SendSessionReportRequest 

type SendSessionReportRequest struct {

	// A report resource to create
	Report *SessionReport `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
	// contains filtered or unexported fields
}

SendReportRequest represents a request to send a usage report

func (*SendSessionReportRequest) Descriptor deprecated 

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

Deprecated: Use SendSessionReportRequest.ProtoReflect.Descriptor instead.

func (*SendSessionReportRequest) GetReport 

func (x *SendSessionReportRequest) GetReport() *SessionReport

func (*SendSessionReportRequest) ProtoMessage 

func (*SendSessionReportRequest) ProtoMessage()

func (*SendSessionReportRequest) ProtoReflect 

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

func (*SendSessionReportRequest) Reset 

func (x *SendSessionReportRequest) Reset()

func (*SendSessionReportRequest) String 

func (x *SendSessionReportRequest) String() string

type SendSessionReportResponse 

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

SendReportResponse represents an empty response

func (*SendSessionReportResponse) Descriptor deprecated 

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

Deprecated: Use SendSessionReportResponse.ProtoReflect.Descriptor instead.

func (*SendSessionReportResponse) ProtoMessage 

func (*SendSessionReportResponse) ProtoMessage()

func (*SendSessionReportResponse) ProtoReflect 

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

func (*SendSessionReportResponse) Reset 

func (x *SendSessionReportResponse) Reset()

func (*SendSessionReportResponse) String 

func (x *SendSessionReportResponse) String() string

type Session 

type Session struct {

	// Resource name in the format of 'sessions/uid'
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Resource UUID
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// name of the service to collect data from
	Service Session_Service `protobuf:"varint,3,opt,name=service,proto3,enum=core.usage.v1beta.Session_Service" json:"service,omitempty"`
	// Session edition, allowed values include: 'local-ce' and 'local-ce:dev'
	Edition string `protobuf:"bytes,4,opt,name=edition,proto3" json:"edition,omitempty"`
	// Version of the service
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Architecture of the system
	Arch string `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`
	// Operating system
	Os string `protobuf:"bytes,7,opt,name=os,proto3" json:"os,omitempty"`
	// Session service uptime
	Uptime int64 `protobuf:"varint,8,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// Report time
	ReportTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=report_time,json=reportTime,proto3" json:"report_time,omitempty"`
	// Token to send report. The token is generated by the server and sent to
	// the client. Client needs to use the token to send report to the server.
	Token string `protobuf:"bytes,10,opt,name=token,proto3" json:"token,omitempty"`
	// Session creation time
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Session update time
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Owner UUID of the instance, can also be considered as instance UUID
	OwnerUid string `protobuf:"bytes,13,opt,name=owner_uid,json=ownerUid,proto3" json:"owner_uid,omitempty"`
	// contains filtered or unexported fields
}

Session represents a unique session whenever a new instance of VDP service gets started. The usage server returns a token that should be used as part of the challenge when sending a report with data collected from this session

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetArch 

func (x *Session) GetArch() string

func (*Session) GetCreateTime 

func (x *Session) GetCreateTime() *timestamppb.Timestamp

func (*Session) GetEdition 

func (x *Session) GetEdition() string

func (*Session) GetName 

func (x *Session) GetName() string

func (*Session) GetOs 

func (x *Session) GetOs() string

func (*Session) GetOwnerUid 

func (x *Session) GetOwnerUid() string

func (*Session) GetReportTime 

func (x *Session) GetReportTime() *timestamppb.Timestamp

func (*Session) GetService 

func (x *Session) GetService() Session_Service

func (*Session) GetToken 

func (x *Session) GetToken() string

func (*Session) GetUid 

func (x *Session) GetUid() string

func (*Session) GetUpdateTime 

func (x *Session) GetUpdateTime() *timestamppb.Timestamp

func (*Session) GetUptime 

func (x *Session) GetUptime() int64

func (*Session) GetVersion 

func (x *Session) GetVersion() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionReport 

type SessionReport struct {

	// Session uid
	SessionUid string `protobuf:"bytes,1,opt,name=session_uid,json=sessionUid,proto3" json:"session_uid,omitempty"`
	// Session token
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// Proof-of-work See https://en.wikipedia.org/wiki/Proof_of_work
	Pow string `protobuf:"bytes,3,opt,name=pow,proto3" json:"pow,omitempty"`
	// Session
	Session *Session `protobuf:"bytes,4,opt,name=session,proto3" json:"session,omitempty"`
	// Service usage data
	//
	// Types that are assignable to UsageData:
	//
	//	*SessionReport_MgmtUsageData
	//	*SessionReport_ConnectorUsageData
	//	*SessionReport_ModelUsageData
	//	*SessionReport_PipelineUsageData
	//	*SessionReport_ArtifactUsageData
	UsageData isSessionReport_UsageData `protobuf_oneof:"usage_data"`
	// contains filtered or unexported fields
}

SessionReport represents a report to be sent to the server that includes the usage data of a session

func (*SessionReport) Descriptor deprecated 

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

Deprecated: Use SessionReport.ProtoReflect.Descriptor instead.

func (*SessionReport) GetArtifactUsageData 

func (x *SessionReport) GetArtifactUsageData() *ArtifactUsageData

func (*SessionReport) GetConnectorUsageData 

func (x *SessionReport) GetConnectorUsageData() *ConnectorUsageData

func (*SessionReport) GetMgmtUsageData 

func (x *SessionReport) GetMgmtUsageData() *MgmtUsageData

func (*SessionReport) GetModelUsageData 

func (x *SessionReport) GetModelUsageData() *ModelUsageData

func (*SessionReport) GetPipelineUsageData 

func (x *SessionReport) GetPipelineUsageData() *PipelineUsageData

func (*SessionReport) GetPow 

func (x *SessionReport) GetPow() string

func (*SessionReport) GetSession 

func (x *SessionReport) GetSession() *Session

func (*SessionReport) GetSessionUid 

func (x *SessionReport) GetSessionUid() string

func (*SessionReport) GetToken 

func (x *SessionReport) GetToken() string

func (*SessionReport) GetUsageData 

func (m *SessionReport) GetUsageData() isSessionReport_UsageData

func (*SessionReport) ProtoMessage 

func (*SessionReport) ProtoMessage()

func (*SessionReport) ProtoReflect 

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

func (*SessionReport) Reset 

func (x *SessionReport) Reset()

func (*SessionReport) String 

func (x *SessionReport) String() string

type SessionReport_ArtifactUsageData 

type SessionReport_ArtifactUsageData struct {
	// Artifact service usage data
	ArtifactUsageData *ArtifactUsageData `protobuf:"bytes,9,opt,name=artifact_usage_data,json=artifactUsageData,proto3,oneof"`
}

type SessionReport_ConnectorUsageData 

type SessionReport_ConnectorUsageData struct {
	// Connector service usage data
	ConnectorUsageData *ConnectorUsageData `protobuf:"bytes,6,opt,name=connector_usage_data,json=connectorUsageData,proto3,oneof"`
}

type SessionReport_MgmtUsageData 

type SessionReport_MgmtUsageData struct {
	// Management service usage data
	MgmtUsageData *MgmtUsageData `protobuf:"bytes,5,opt,name=mgmt_usage_data,json=mgmtUsageData,proto3,oneof"`
}

type SessionReport_ModelUsageData 

type SessionReport_ModelUsageData struct {
	// Model service usage data
	ModelUsageData *ModelUsageData `protobuf:"bytes,7,opt,name=model_usage_data,json=modelUsageData,proto3,oneof"`
}

type SessionReport_PipelineUsageData 

type SessionReport_PipelineUsageData struct {
	// Pipeline service usage data
	PipelineUsageData *PipelineUsageData `protobuf:"bytes,8,opt,name=pipeline_usage_data,json=pipelineUsageData,proto3,oneof"`
}

type Session_Service 

type Session_Service int32

Service enumerates the services to collect data from 

const (
	// Service: UNSPECIFIED
	Session_SERVICE_UNSPECIFIED Session_Service = 0
	// Service: MGMT
	Session_SERVICE_MGMT Session_Service = 1
	// Service: CONNECTOR
	Session_SERVICE_CONNECTOR Session_Service = 2
	// Service: MODEL
	Session_SERVICE_MODEL Session_Service = 3
	// Service: PIPELINE
	Session_SERVICE_PIPELINE Session_Service = 4
	// Service: ARTIFACT
	Session_SERVICE_ARTIFACT Session_Service = 5
)

func (Session_Service) Descriptor 

func (Session_Service) Descriptor() protoreflect.EnumDescriptor

func (Session_Service) Enum 

func (x Session_Service) Enum() *Session_Service

func (Session_Service) EnumDescriptor deprecated 

func (Session_Service) EnumDescriptor() ([]byte, []int)

Deprecated: Use Session_Service.Descriptor instead.

func (Session_Service) Number 

func (x Session_Service) Number() protoreflect.EnumNumber

func (Session_Service) String 

func (x Session_Service) String() string

func (Session_Service) Type 

func (Session_Service) Type() protoreflect.EnumType

type UnimplementedUsageServiceServer 

type UnimplementedUsageServiceServer struct {
}

UnimplementedUsageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUsageServiceServer) CreateSession 

func (UnimplementedUsageServiceServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)

func (UnimplementedUsageServiceServer) Liveness 

func (UnimplementedUsageServiceServer) Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)

func (UnimplementedUsageServiceServer) Readiness 

func (UnimplementedUsageServiceServer) Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)

func (UnimplementedUsageServiceServer) SendSessionReport 

func (UnimplementedUsageServiceServer) SendSessionReport(context.Context, *SendSessionReportRequest) (*SendSessionReportResponse, 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 {
	// Liveness method receives a LivenessRequest message and returns a
	// LivenessResponse message.
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Liveness(ctx context.Context, in *LivenessRequest, opts ...grpc.CallOption) (*LivenessResponse, error)
	// Readiness method receives a ReadinessRequest message and returns a
	// ReadinessResponse message.
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*ReadinessResponse, error)
	// CreateSession method receives a CreateSessionRequest message and returns
	// a CreateSessionResponse message.
	CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)
	// SendSessionReport method receives a SendSessionReportRequest message and
	// returns a SendSessionReportResponse message.
	SendSessionReport(ctx context.Context, in *SendSessionReportRequest, opts ...grpc.CallOption) (*SendSessionReportResponse, 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 {
	// Liveness method receives a LivenessRequest message and returns a
	// LivenessResponse message.
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Liveness(context.Context, *LivenessRequest) (*LivenessResponse, error)
	// Readiness method receives a ReadinessRequest message and returns a
	// ReadinessResponse message.
	// See https://github.com/grpc/grpc/blob/master/doc/health-checking.md
	Readiness(context.Context, *ReadinessRequest) (*ReadinessResponse, error)
	// CreateSession method receives a CreateSessionRequest message and returns
	// a CreateSessionResponse message.
	CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
	// SendSessionReport method receives a SendSessionReportRequest message and
	// returns a SendSessionReportResponse message.
	SendSessionReport(context.Context, *SendSessionReportRequest) (*SendSessionReportResponse, 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.