usagev1alpha

package
v0.3.3-alpha Latest Latest
Warning

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

Go to latest
Published: Sep 14, 2022 License: Apache-2.0 Imports: 20 Imported by: 2

Documentation

Overview

Package usagev1alpha is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

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",
	}
	Session_Service_value = map[string]int32{
		"SERVICE_UNSPECIFIED": 0,
		"SERVICE_MGMT":        1,
		"SERVICE_CONNECTOR":   2,
		"SERVICE_MODEL":       3,
		"SERVICE_PIPELINE":    4,
	}
)

Enum value maps for Session_Service.

View Source
var File_vdp_usage_v1alpha_healthcheck_proto protoreflect.FileDescriptor
View Source
var File_vdp_usage_v1alpha_usage_proto protoreflect.FileDescriptor
View Source
var File_vdp_usage_v1alpha_usage_service_proto protoreflect.FileDescriptor
View Source
var UsageService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vdp.usage.v1alpha.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: "vdp/usage/v1alpha/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 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 (*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 {

	// User UUID
	UserUid string `protobuf:"bytes,1,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Number of source connectors with 'connected' state
	SourceConnectorConnectedStateNum int64 `` /* 164-byte string literal not displayed */
	// Number of source connectors with 'disconneceted' state
	SourceConnectorDisconnectedStateNum int64 `` /* 173-byte string literal not displayed */
	// Definition IDs of the source connectors. Element in the list
	// should not be duplicated.
	SourceConnectorDefinitionIds []string `` /* 149-byte string literal not displayed */
	// Number of destination connectors with 'connected' state
	DestinationConnectorConnectedStateNum int64 `` /* 179-byte string literal not displayed */
	// Number of destination connectors with 'disconnected' state
	DestinationConnectorDisconnectedStateNum int64 `` /* 188-byte string literal not displayed */
	// Definition IDs of the destination connectors. Element in the
	// list should not be duplicated.
	DestinationConnectorDefinitionIds []string `` /* 164-byte string literal not displayed */
	// 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) GetDestinationConnectorConnectedStateNum

func (x *ConnectorUsageData_UserUsageData) GetDestinationConnectorConnectedStateNum() int64

func (*ConnectorUsageData_UserUsageData) GetDestinationConnectorDefinitionIds

func (x *ConnectorUsageData_UserUsageData) GetDestinationConnectorDefinitionIds() []string

func (*ConnectorUsageData_UserUsageData) GetDestinationConnectorDisconnectedStateNum

func (x *ConnectorUsageData_UserUsageData) GetDestinationConnectorDisconnectedStateNum() int64

func (*ConnectorUsageData_UserUsageData) GetSourceConnectorConnectedStateNum

func (x *ConnectorUsageData_UserUsageData) GetSourceConnectorConnectedStateNum() int64

func (*ConnectorUsageData_UserUsageData) GetSourceConnectorDefinitionIds

func (x *ConnectorUsageData_UserUsageData) GetSourceConnectorDefinitionIds() []string

func (*ConnectorUsageData_UserUsageData) GetSourceConnectorDisconnectedStateNum

func (x *ConnectorUsageData_UserUsageData) GetSourceConnectorDisconnectedStateNum() int64

func (*ConnectorUsageData_UserUsageData) GetUserUid

func (x *ConnectorUsageData_UserUsageData) GetUserUid() string

func (*ConnectorUsageData_UserUsageData) ProtoMessage

func (*ConnectorUsageData_UserUsageData) ProtoMessage()

func (*ConnectorUsageData_UserUsageData) ProtoReflect

func (*ConnectorUsageData_UserUsageData) Reset

func (*ConnectorUsageData_UserUsageData) 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 *v1alpha.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() *v1alpha.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 *v1alpha.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() *v1alpha.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
	Usages []*v1alpha.User `protobuf:"bytes,1,rep,name=usages,proto3" json:"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) GetUsages

func (x *MgmtUsageData) GetUsages() []*v1alpha.User

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 {

	// User UUID
	UserUid string `protobuf:"bytes,1,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Number of models that have at least one 'online' instance
	ModelOnlineStateNum int64 `protobuf:"varint,2,opt,name=model_online_state_num,json=modelOnlineStateNum,proto3" json:"model_online_state_num,omitempty"`
	// Number of models that have no 'online' instances
	ModelOfflineStateNum int64 `` /* 126-byte string literal not displayed */
	// Number of model instances with 'online' state
	InstanceOnlineStateNum int64 `` /* 132-byte string literal not displayed */
	// Number of model instances with 'offline' state
	InstanceOfflineStateNum int64 `` /* 135-byte string literal not displayed */
	// Definition IDs of the model instances. Element in the list
	// should not be duplicated.
	ModelDefinitionIds []string `protobuf:"bytes,6,rep,name=model_definition_ids,json=modelDefinitionIds,proto3" json:"model_definition_ids,omitempty"`
	// Tasks of the model instances. Element in the list should not be duplicated.
	Tasks []v1alpha1.ModelInstance_Task `protobuf:"varint,7,rep,packed,name=tasks,proto3,enum=vdp.model.v1alpha.ModelInstance_Task" json:"tasks,omitempty"`
	// Number of processed images via model instance testing operations
	TestImageNum int64 `protobuf:"varint,8,opt,name=test_image_num,json=testImageNum,proto3" json:"test_image_num,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) GetInstanceOfflineStateNum

func (x *ModelUsageData_UserUsageData) GetInstanceOfflineStateNum() int64

func (*ModelUsageData_UserUsageData) GetInstanceOnlineStateNum

func (x *ModelUsageData_UserUsageData) GetInstanceOnlineStateNum() int64

func (*ModelUsageData_UserUsageData) GetModelDefinitionIds

func (x *ModelUsageData_UserUsageData) GetModelDefinitionIds() []string

func (*ModelUsageData_UserUsageData) GetModelOfflineStateNum

func (x *ModelUsageData_UserUsageData) GetModelOfflineStateNum() int64

func (*ModelUsageData_UserUsageData) GetModelOnlineStateNum

func (x *ModelUsageData_UserUsageData) GetModelOnlineStateNum() int64

func (*ModelUsageData_UserUsageData) GetTasks

func (*ModelUsageData_UserUsageData) GetTestImageNum

func (x *ModelUsageData_UserUsageData) GetTestImageNum() int64

func (*ModelUsageData_UserUsageData) GetUserUid

func (x *ModelUsageData_UserUsageData) GetUserUid() string

func (*ModelUsageData_UserUsageData) ProtoMessage

func (*ModelUsageData_UserUsageData) ProtoMessage()

func (*ModelUsageData_UserUsageData) ProtoReflect

func (*ModelUsageData_UserUsageData) Reset

func (x *ModelUsageData_UserUsageData) Reset()

func (*ModelUsageData_UserUsageData) 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 (*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 {

	// User UUID
	UserUid string `protobuf:"bytes,1,opt,name=user_uid,json=userUid,proto3" json:"user_uid,omitempty"`
	// Number of pipelines with 'active' state
	PipelineActiveStateNum int64 `` /* 132-byte string literal not displayed */
	// Number of pipelines with 'inactive' state
	PipelineInactiveStateNum int64 `` /* 138-byte string literal not displayed */
	// Number of pipelines with 'async' mode
	PipelineAsyncModeNum int64 `` /* 126-byte string literal not displayed */
	// Number of pipelines with 'sync' mode
	PipelineSyncModeNum int64 `protobuf:"varint,5,opt,name=pipeline_sync_mode_num,json=pipelineSyncModeNum,proto3" json:"pipeline_sync_mode_num,omitempty"`
	// Number of processed images via pipeline triggering operations
	TriggerImageNum int64 `protobuf:"varint,6,opt,name=trigger_image_num,json=triggerImageNum,proto3" json:"trigger_image_num,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) GetPipelineActiveStateNum

func (x *PipelineUsageData_UserUsageData) GetPipelineActiveStateNum() int64

func (*PipelineUsageData_UserUsageData) GetPipelineAsyncModeNum

func (x *PipelineUsageData_UserUsageData) GetPipelineAsyncModeNum() int64

func (*PipelineUsageData_UserUsageData) GetPipelineInactiveStateNum

func (x *PipelineUsageData_UserUsageData) GetPipelineInactiveStateNum() int64

func (*PipelineUsageData_UserUsageData) GetPipelineSyncModeNum

func (x *PipelineUsageData_UserUsageData) GetPipelineSyncModeNum() int64

func (*PipelineUsageData_UserUsageData) GetTriggerImageNum

func (x *PipelineUsageData_UserUsageData) GetTriggerImageNum() int64

func (*PipelineUsageData_UserUsageData) GetUserUid

func (x *PipelineUsageData_UserUsageData) GetUserUid() string

func (*PipelineUsageData_UserUsageData) ProtoMessage

func (*PipelineUsageData_UserUsageData) ProtoMessage()

func (*PipelineUsageData_UserUsageData) ProtoReflect

func (*PipelineUsageData_UserUsageData) Reset

func (*PipelineUsageData_UserUsageData) String

type ReadinessRequest

type ReadinessRequest struct {

	// HealthCheckRequest message
	HealthCheckRequest *v1alpha.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() *v1alpha.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 *v1alpha.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() *v1alpha.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 (*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=vdp.usage.v1alpha.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"`
	// 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) 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
	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) 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_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
)

func (Session_Service) Descriptor

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 (Session_Service) String

func (x Session_Service) String() string

func (Session_Service) Type

type UnimplementedUsageServiceServer

type UnimplementedUsageServiceServer struct {
}

UnimplementedUsageServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUsageServiceServer) CreateSession

func (UnimplementedUsageServiceServer) Liveness

func (UnimplementedUsageServiceServer) Readiness

func (UnimplementedUsageServiceServer) SendSessionReport

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.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL