cloud

package
v0.2.2 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: 1

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 added in v0.2.1 

func RegisterTokenServer(s grpc.ServiceRegistrar, srv TokenServer)

Types

type ExchangeTokenRequest added in v0.2.0 

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 added in v0.2.0 

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

Deprecated: Use ExchangeTokenRequest.ProtoReflect.Descriptor instead.

func (*ExchangeTokenRequest) GetRefreshToken added in v0.2.0 

func (x *ExchangeTokenRequest) GetRefreshToken() string

func (*ExchangeTokenRequest) ProtoMessage added in v0.2.0 

func (*ExchangeTokenRequest) ProtoMessage()

func (*ExchangeTokenRequest) ProtoReflect added in v0.2.0 

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

func (*ExchangeTokenRequest) Reset added in v0.2.0 

func (x *ExchangeTokenRequest) Reset()

func (*ExchangeTokenRequest) String added in v0.2.0 

func (x *ExchangeTokenRequest) String() string

type ExchangeTokenResponse added in v0.2.0 

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 added in v0.2.0 

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

Deprecated: Use ExchangeTokenResponse.ProtoReflect.Descriptor instead.

func (*ExchangeTokenResponse) GetAccessToken added in v0.2.0 

func (x *ExchangeTokenResponse) GetAccessToken() string

func (*ExchangeTokenResponse) ProtoMessage added in v0.2.0 

func (*ExchangeTokenResponse) ProtoMessage()

func (*ExchangeTokenResponse) ProtoReflect added in v0.2.0 

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

func (*ExchangeTokenResponse) Reset added in v0.2.0 

func (x *ExchangeTokenResponse) Reset()

func (*ExchangeTokenResponse) String added in v0.2.0 

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 added in v0.2.1 

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 added in v0.2.1 

func NewTokenClient(cc grpc.ClientConnInterface) TokenClient

type TokenServer added in v0.2.1 

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 added in v0.2.1 

type UnimplementedTokenServer struct {
}

UnimplementedTokenServer must be embedded to have forward compatible implementations.

func (UnimplementedTokenServer) Exchange added in v0.2.2 

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 added in v0.2.1 

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.