cloud

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_gpu_ninja_cloud_proto protoreflect.FileDescriptor
View Source 
var GpuNinja_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gpu_ninja.cloud.v1alpha1.GpuNinja",
	HandlerType: (*GpuNinjaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Send",
			Handler:    _GpuNinja_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gpu_ninja_cloud.proto",
}

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

View Source 
var Token_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gpu_ninja.cloud.v1alpha1.Token",
	HandlerType: (*TokenServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exchange",
			Handler:    _Token_Exchange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gpu_ninja_cloud.proto",
}

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

Functions

func RegisterGpuNinjaServer 

func RegisterGpuNinjaServer(s grpc.ServiceRegistrar, srv GpuNinjaServer)

func RegisterTokenServer 

func RegisterTokenServer(s grpc.ServiceRegistrar, srv TokenServer)

Types

type ExchangeTokenRequest 

type ExchangeTokenRequest struct {
	RefreshToken string `protobuf:"bytes,1,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeTokenRequest) Descriptor deprecated 

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

Deprecated: Use ExchangeTokenRequest.ProtoReflect.Descriptor instead.

func (*ExchangeTokenRequest) GetRefreshToken 

func (x *ExchangeTokenRequest) GetRefreshToken() string

func (*ExchangeTokenRequest) ProtoMessage 

func (*ExchangeTokenRequest) ProtoMessage()

func (*ExchangeTokenRequest) ProtoReflect 

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

func (*ExchangeTokenRequest) Reset 

func (x *ExchangeTokenRequest) Reset()

func (*ExchangeTokenRequest) String 

func (x *ExchangeTokenRequest) String() string

type ExchangeTokenResponse 

type ExchangeTokenResponse struct {
	AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeTokenResponse) Descriptor deprecated 

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

Deprecated: Use ExchangeTokenResponse.ProtoReflect.Descriptor instead.

func (*ExchangeTokenResponse) GetAccessToken 

func (x *ExchangeTokenResponse) GetAccessToken() string

func (*ExchangeTokenResponse) ProtoMessage 

func (*ExchangeTokenResponse) ProtoMessage()

func (*ExchangeTokenResponse) ProtoReflect 

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

func (*ExchangeTokenResponse) Reset 

func (x *ExchangeTokenResponse) Reset()

func (*ExchangeTokenResponse) String 

func (x *ExchangeTokenResponse) String() string

type GpuNinjaClient 

type GpuNinjaClient interface {
	// Write reports a list of timeseries and events to the server.
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

GpuNinjaClient is the client API for GpuNinja 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 NewGpuNinjaClient 

func NewGpuNinjaClient(cc grpc.ClientConnInterface) GpuNinjaClient

type GpuNinjaServer 

type GpuNinjaServer interface {
	// Write reports a list of timeseries and events to the server.
	Send(context.Context, *SendRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

GpuNinjaServer is the server API for GpuNinja service. All implementations must embed UnimplementedGpuNinjaServer for forward compatibility

type Process 

type Process struct {

	// The unique identifier for the process.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A list of timeseries to report.
	TimeSeriesFamilies []*pb.TimeSeriesFamily `protobuf:"bytes,2,rep,name=time_series_families,json=timeSeriesFamilies,proto3" json:"time_series_families,omitempty"`
	// A list of events to report.
	Events []*pb.Event `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetEvents 

func (x *Process) GetEvents() []*pb.Event

func (*Process) GetId 

func (x *Process) GetId() string

func (*Process) GetTimeSeriesFamilies 

func (x *Process) GetTimeSeriesFamilies() []*pb.TimeSeriesFamily

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type SendRequest 

type SendRequest struct {

	// The unique identifier for this aggregator.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The list of processes for reporting.
	Processes []*Process `protobuf:"bytes,2,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*SendRequest) Descriptor deprecated 

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

Deprecated: Use SendRequest.ProtoReflect.Descriptor instead.

func (*SendRequest) GetId 

func (x *SendRequest) GetId() string

func (*SendRequest) GetProcesses 

func (x *SendRequest) GetProcesses() []*Process

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) ProtoReflect 

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

func (*SendRequest) Reset 

func (x *SendRequest) Reset()

func (*SendRequest) String 

func (x *SendRequest) String() string

type TokenClient 

type TokenClient interface {
	// Exchange returns an ephemeral access token for the given refresh token.
	Exchange(ctx context.Context, in *ExchangeTokenRequest, opts ...grpc.CallOption) (*ExchangeTokenResponse, error)
}

TokenClient is the client API for Token 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 NewTokenClient 

func NewTokenClient(cc grpc.ClientConnInterface) TokenClient

type TokenServer 

type TokenServer interface {
	// Exchange returns an ephemeral access token for the given refresh token.
	Exchange(context.Context, *ExchangeTokenRequest) (*ExchangeTokenResponse, error)
	// contains filtered or unexported methods
}

TokenServer is the server API for Token service. All implementations must embed UnimplementedTokenServer for forward compatibility

type UnimplementedGpuNinjaServer 

type UnimplementedGpuNinjaServer struct {
}

UnimplementedGpuNinjaServer must be embedded to have forward compatible implementations.

func (UnimplementedGpuNinjaServer) Send 

func (UnimplementedGpuNinjaServer) Send(context.Context, *SendRequest) (*emptypb.Empty, error)

type UnimplementedTokenServer 

type UnimplementedTokenServer struct {
}

UnimplementedTokenServer must be embedded to have forward compatible implementations.

func (UnimplementedTokenServer) Exchange 

func (UnimplementedTokenServer) Exchange(context.Context, *ExchangeTokenRequest) (*ExchangeTokenResponse, error)

type UnsafeGpuNinjaServer 

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

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

type UnsafeTokenServer 

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

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

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.