runner

package
v1.20.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_runner_proto_runner_proto protoreflect.FileDescriptor
View Source 
var ServerProto_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "runner.ServerProto",
	HandlerType: (*ServerProtoServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SendServer",
			Handler:       _ServerProto_SendServer_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "runner/proto/runner.proto",
}

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

Functions

func RegisterServerProtoServer 

func RegisterServerProtoServer(s grpc.ServiceRegistrar, srv ServerProtoServer)

Types

type File added in v1.20.0 

type File struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Gzip    bool   `protobuf:"varint,2,opt,name=gzip,proto3" json:"gzip,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated added in v1.20.0 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetContent added in v1.20.0 

func (x *File) GetContent() []byte

func (*File) GetGzip added in v1.20.0 

func (x *File) GetGzip() bool

func (*File) ProtoMessage added in v1.20.0 

func (*File) ProtoMessage()

func (*File) ProtoReflect added in v1.20.0 

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

func (*File) Reset added in v1.20.0 

func (x *File) Reset()

func (*File) String added in v1.20.0 

func (x *File) String() string

type Metadata 

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

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetName 

func (x *Metadata) GetName() string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type Output added in v1.12.0 

type Output struct {
	Pos     int64  `protobuf:"varint,1,opt,name=pos,proto3" json:"pos,omitempty"`
	Time    int64  `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Output) Descriptor deprecated added in v1.12.0 

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

Deprecated: Use Output.ProtoReflect.Descriptor instead.

func (*Output) GetMessage added in v1.12.0 

func (x *Output) GetMessage() string

func (*Output) GetPos added in v1.12.0 

func (x *Output) GetPos() int64

func (*Output) GetTime added in v1.12.0 

func (x *Output) GetTime() int64

func (*Output) ProtoMessage added in v1.12.0 

func (*Output) ProtoMessage()

func (*Output) ProtoReflect added in v1.12.0 

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

func (*Output) Reset added in v1.12.0 

func (x *Output) Reset()

func (*Output) String added in v1.12.0 

func (x *Output) String() string

type ServerProtoClient 

type ServerProtoClient interface {
	SendServer(ctx context.Context, in *ServerRequest, opts ...grpc.CallOption) (ServerProto_SendServerClient, error)
}

ServerProtoClient is the client API for ServerProto 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 NewServerProtoClient 

func NewServerProtoClient(cc grpc.ClientConnInterface) ServerProtoClient

type ServerProtoServer 

type ServerProtoServer interface {
	SendServer(*ServerRequest, ServerProto_SendServerServer) error
	// contains filtered or unexported methods
}

ServerProtoServer is the server API for ServerProto service. All implementations must embed UnimplementedServerProtoServer for forward compatibility

type ServerProto_SendServerClient added in v1.11.0 

type ServerProto_SendServerClient interface {
	Recv() (*ServerReply, error)
	grpc.ClientStream
}

type ServerProto_SendServerServer added in v1.11.0 

type ServerProto_SendServerServer interface {
	Send(*ServerReply) error
	grpc.ServerStream
}

type ServerReply 

type ServerReply struct {
	Output *Output `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Error  string  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

The response message.

func (*ServerReply) Descriptor deprecated 

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

Deprecated: Use ServerReply.ProtoReflect.Descriptor instead.

func (*ServerReply) GetError 

func (x *ServerReply) GetError() string

func (*ServerReply) GetOutput added in v1.11.0 

func (x *ServerReply) GetOutput() *Output

func (*ServerReply) ProtoMessage 

func (*ServerReply) ProtoMessage()

func (*ServerReply) ProtoReflect 

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

func (*ServerReply) Reset 

func (x *ServerReply) Reset()

func (*ServerReply) String 

func (x *ServerReply) String() string

type ServerRequest 

type ServerRequest struct {
	ApiVersion string    `protobuf:"bytes,1,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Kind       string    `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Metadata   *Metadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec       *Spec     `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

The request message.

func (*ServerRequest) Descriptor deprecated 

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

Deprecated: Use ServerRequest.ProtoReflect.Descriptor instead.

func (*ServerRequest) GetApiVersion 

func (x *ServerRequest) GetApiVersion() string

func (*ServerRequest) GetKind 

func (x *ServerRequest) GetKind() string

func (*ServerRequest) GetMetadata 

func (x *ServerRequest) GetMetadata() *Metadata

func (*ServerRequest) GetSpec 

func (x *ServerRequest) GetSpec() *Spec

func (*ServerRequest) ProtoMessage 

func (*ServerRequest) ProtoMessage()

func (*ServerRequest) ProtoReflect 

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

func (*ServerRequest) Reset 

func (x *ServerRequest) Reset()

func (*ServerRequest) String 

func (x *ServerRequest) String() string

type Spec 

type Spec struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*Spec) Descriptor deprecated 

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

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetTask added in v1.13.0 

func (x *Spec) GetTask() *Task

func (*Spec) ProtoMessage 

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect 

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

func (*Spec) Reset 

func (x *Spec) Reset()

func (*Spec) String 

func (x *Spec) String() string

type Task 

type Task struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	File     *File    `protobuf:"bytes,2,opt,name=file,proto3" json:"file,omitempty"`
	Commands []string `protobuf:"bytes,3,rep,name=commands,proto3" json:"commands,omitempty"`
	Timeout  *Timeout `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCommands 

func (x *Task) GetCommands() []string

func (*Task) GetFile added in v1.20.0 

func (x *Task) GetFile() *File

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetTimeout added in v1.19.0 

func (x *Task) GetTimeout() *Timeout

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type Timeout added in v1.19.0 

type Timeout struct {
	Time int64  `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	Unit string `protobuf:"bytes,2,opt,name=unit,proto3" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeout) Descriptor deprecated added in v1.19.0 

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

Deprecated: Use Timeout.ProtoReflect.Descriptor instead.

func (*Timeout) GetTime added in v1.19.0 

func (x *Timeout) GetTime() int64

func (*Timeout) GetUnit added in v1.19.0 

func (x *Timeout) GetUnit() string

func (*Timeout) ProtoMessage added in v1.19.0 

func (*Timeout) ProtoMessage()

func (*Timeout) ProtoReflect added in v1.19.0 

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

func (*Timeout) Reset added in v1.19.0 

func (x *Timeout) Reset()

func (*Timeout) String added in v1.19.0 

func (x *Timeout) String() string

type UnimplementedServerProtoServer 

type UnimplementedServerProtoServer struct {
}

UnimplementedServerProtoServer must be embedded to have forward compatible implementations.

func (UnimplementedServerProtoServer) SendServer 

func (UnimplementedServerProtoServer) SendServer(*ServerRequest, ServerProto_SendServerServer) error

type UnsafeServerProtoServer 

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

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