runtime

package
v0.0.0-...-9fce2f1 Latest Latest
Warning

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

 Go to latest Published: May 2, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_runtime_runtime_proto protoreflect.FileDescriptor
View Source 
var Runtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runtime.Runtime",
	HandlerType: (*RuntimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Runtime_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Runtime_Delete_Handler,
		},
		{
			MethodName: "Stat",
			Handler:    _Runtime_Stat_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _Runtime_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/runtime/runtime.proto",
}

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

Functions

func RegisterRuntimeServer 

func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)

Types

type CreateRequest 

type CreateRequest struct {
	Source  string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Options *Options `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetOptions 

func (x *CreateRequest) GetOptions() *Options

func (*CreateRequest) GetSource 

func (x *CreateRequest) GetSource() string

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId 

func (x *CreateResponse) GetId() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetOptions 

func (x *DeleteRequest) GetOptions() *Options

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

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

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type LogsRequest 

type LogsRequest struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsRequest) Descriptor deprecated 

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

Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.

func (*LogsRequest) GetId 

func (x *LogsRequest) GetId() string

func (*LogsRequest) GetOptions 

func (x *LogsRequest) GetOptions() *Options

func (*LogsRequest) ProtoMessage 

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) ProtoReflect 

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

func (*LogsRequest) Reset 

func (x *LogsRequest) Reset()

func (*LogsRequest) String 

func (x *LogsRequest) String() string

type LogsResponse 

type LogsResponse struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsResponse) Descriptor deprecated 

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

Deprecated: Use LogsResponse.ProtoReflect.Descriptor instead.

func (*LogsResponse) GetChunk 

func (x *LogsResponse) GetChunk() []byte

func (*LogsResponse) ProtoMessage 

func (*LogsResponse) ProtoMessage()

func (*LogsResponse) ProtoReflect 

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

func (*LogsResponse) Reset 

func (x *LogsResponse) Reset()

func (*LogsResponse) String 

func (x *LogsResponse) String() string

type Options 

type Options struct {
	Namespace string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Runner    string   `protobuf:"bytes,3,opt,name=runner,proto3" json:"runner,omitempty"`
	Args      []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	Env       []string `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	Deps      []string `protobuf:"bytes,6,rep,name=deps,proto3" json:"deps,omitempty"`
	// contains filtered or unexported fields
}

func (*Options) Descriptor deprecated 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetArgs 

func (x *Options) GetArgs() []string

func (*Options) GetDeps 

func (x *Options) GetDeps() []string

func (*Options) GetEnv 

func (x *Options) GetEnv() []string

func (*Options) GetNamespace 

func (x *Options) GetNamespace() string

func (*Options) GetRunner 

func (x *Options) GetRunner() string

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect 

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

func (*Options) Reset 

func (x *Options) Reset()

func (*Options) String 

func (x *Options) String() string

type RuntimeClient 

type RuntimeClient interface {
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Runtime_LogsClient, error)
}

RuntimeClient is the client API for Runtime 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 NewRuntimeClient 

func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient

type RuntimeServer 

type RuntimeServer interface {
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Stat(context.Context, *StatRequest) (*StatResponse, error)
	Logs(*LogsRequest, Runtime_LogsServer) error
	// contains filtered or unexported methods
}

RuntimeServer is the server API for Runtime service. All implementations must embed UnimplementedRuntimeServer for forward compatibility

type Runtime_LogsClient 

type Runtime_LogsClient interface {
	Recv() (*LogsResponse, error)
	grpc.ClientStream
}

type Runtime_LogsServer 

type Runtime_LogsServer interface {
	Send(*LogsResponse) error
	grpc.ServerStream
}

type Stat 

type Stat struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State  string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	Label  string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	Env    string `protobuf:"bytes,4,opt,name=env,proto3" json:"env,omitempty"`
	Path   string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	Model  string `protobuf:"bytes,6,opt,name=model,proto3" json:"model,omitempty"`
	Uptime int64  `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

func (*Stat) Descriptor deprecated 

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

Deprecated: Use Stat.ProtoReflect.Descriptor instead.

func (*Stat) GetEnv 

func (x *Stat) GetEnv() string

func (*Stat) GetId 

func (x *Stat) GetId() string

func (*Stat) GetLabel 

func (x *Stat) GetLabel() string

func (*Stat) GetModel 

func (x *Stat) GetModel() string

func (*Stat) GetPath 

func (x *Stat) GetPath() string

func (*Stat) GetState 

func (x *Stat) GetState() string

func (*Stat) GetUptime 

func (x *Stat) GetUptime() int64

func (*Stat) ProtoMessage 

func (*Stat) ProtoMessage()

func (*Stat) ProtoReflect 

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

func (*Stat) Reset 

func (x *Stat) Reset()

func (*Stat) String 

func (x *Stat) String() string

type StatRequest 

type StatRequest struct {
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*StatRequest) Descriptor deprecated 

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

Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.

func (*StatRequest) GetOptions 

func (x *StatRequest) GetOptions() *Options

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) ProtoReflect 

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

func (*StatRequest) Reset 

func (x *StatRequest) Reset()

func (*StatRequest) String 

func (x *StatRequest) String() string

type StatResponse 

type StatResponse struct {
	Stats []*Stat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*StatResponse) Descriptor deprecated 

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

Deprecated: Use StatResponse.ProtoReflect.Descriptor instead.

func (*StatResponse) GetStats 

func (x *StatResponse) GetStats() []*Stat

func (*StatResponse) ProtoMessage 

func (*StatResponse) ProtoMessage()

func (*StatResponse) ProtoReflect 

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

func (*StatResponse) Reset 

func (x *StatResponse) Reset()

func (*StatResponse) String 

func (x *StatResponse) String() string

type UnimplementedRuntimeServer 

type UnimplementedRuntimeServer struct {
}

UnimplementedRuntimeServer must be embedded to have forward compatible implementations.

func (UnimplementedRuntimeServer) Create 

func (UnimplementedRuntimeServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedRuntimeServer) Delete 

func (UnimplementedRuntimeServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedRuntimeServer) Logs 

func (UnimplementedRuntimeServer) Logs(*LogsRequest, Runtime_LogsServer) error

func (UnimplementedRuntimeServer) Stat 

func (UnimplementedRuntimeServer) Stat(context.Context, *StatRequest) (*StatResponse, error)

type UnsafeRuntimeServer 

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

UnsafeRuntimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServer 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.