executor

Documentation

Index

• Variables
• func RegisterExecuteServer(s grpc.ServiceRegistrar, srv ExecuteServer)
• type ExecuteClient
  • func NewExecuteClient(cc grpc.ClientConnInterface) ExecuteClient
• type ExecuteMessage
  • func (*ExecuteMessage) Descriptor() ([]byte, []int)
  • func (x *ExecuteMessage) GetCondVal() bool
  • func (x *ExecuteMessage) GetExprVal() float64
  • func (x *ExecuteMessage) GetGroup() string
  • func (x *ExecuteMessage) GetKind() Kind
  • func (x *ExecuteMessage) GetNamespace() string
  • func (x *ExecuteMessage) GetParameters() map[string]string
  • func (x *ExecuteMessage) GetResourceName() string
  • func (x *ExecuteMessage) GetResources() string
  • func (x *ExecuteMessage) GetVersion() string
  • func (*ExecuteMessage) ProtoMessage()
  • func (x *ExecuteMessage) ProtoReflect() protoreflect.Message
  • func (x *ExecuteMessage) Reset()
  • func (x *ExecuteMessage) String() string
• type ExecuteResponse
  • func (*ExecuteResponse) Descriptor() ([]byte, []int)
  • func (x *ExecuteResponse) GetData() string
  • func (*ExecuteResponse) ProtoMessage()
  • func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
  • func (x *ExecuteResponse) Reset()
  • func (x *ExecuteResponse) String() string
• type ExecuteServer
• type Kind
  • func (Kind) Descriptor() protoreflect.EnumDescriptor
  • func (x Kind) Enum() *Kind
  • func (Kind) EnumDescriptor() ([]byte, []int)
  • func (x Kind) Number() protoreflect.EnumNumber
  • func (x Kind) String() string
  • func (Kind) Type() protoreflect.EnumType
• type UnimplementedExecuteServer
  • func (UnimplementedExecuteServer) Execute(context.Context, *ExecuteMessage) (*ExecuteResponse, error)
• type UnsafeExecuteServer

Variables

var (
	Kind_name = map[int32]string{
		0: "pod",
		1: "node",
	}
	Kind_value = map[string]int32{
		"pod":  0,
		"node": 1,
	}
)

Enum value maps for Kind.

var Execute_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "execute.Execute",
	HandlerType: (*ExecuteServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Execute",
			Handler:    _Execute_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "execute.proto",
}

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

var File_execute_proto protoreflect.FileDescriptor

Functions

func RegisterExecuteServer

func RegisterExecuteServer(s grpc.ServiceRegistrar, srv ExecuteServer)

Types

type ExecuteClient

type ExecuteClient interface {
	Execute(ctx context.Context, in *ExecuteMessage, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

ExecuteClient is the client API for Execute 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 NewExecuteClient

func NewExecuteClient(cc grpc.ClientConnInterface) ExecuteClient

type ExecuteMessage

type ExecuteMessage struct {
	ResourceName string            `protobuf:"bytes,1,opt,name=resourceName,proto3" json:"resourceName,omitempty"`
	Kind         Kind              `protobuf:"varint,2,opt,name=kind,proto3,enum=execute.Kind" json:"kind,omitempty"`
	Namespace    string            `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ExprVal      float64           `protobuf:"fixed64,4,opt,name=exprVal,proto3" json:"exprVal,omitempty"`
	CondVal      bool              `protobuf:"varint,5,opt,name=condVal,proto3" json:"condVal,omitempty"`
	Parameters   map[string]string `` /* 161-byte string literal not displayed */
	Group        string            `protobuf:"bytes,7,opt,name=group,proto3" json:"group,omitempty"`
	Version      string            `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	Resources    string            `protobuf:"bytes,9,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteMessage) Descriptor

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

Deprecated: Use ExecuteMessage.ProtoReflect.Descriptor instead.

func (*ExecuteMessage) GetCondVal

func (x *ExecuteMessage) GetCondVal() bool

func (*ExecuteMessage) GetExprVal

func (x *ExecuteMessage) GetExprVal() float64

func (*ExecuteMessage) GetGroup

func (x *ExecuteMessage) GetGroup() string

func (*ExecuteMessage) GetKind

func (x *ExecuteMessage) GetKind() Kind

func (*ExecuteMessage) GetNamespace

func (x *ExecuteMessage) GetNamespace() string

func (*ExecuteMessage) GetParameters

func (x *ExecuteMessage) GetParameters() map[string]string

func (*ExecuteMessage) GetResourceName

func (x *ExecuteMessage) GetResourceName() string

func (*ExecuteMessage) GetResources

func (x *ExecuteMessage) GetResources() string

func (*ExecuteMessage) GetVersion

func (x *ExecuteMessage) GetVersion() string

func (*ExecuteMessage) ProtoMessage

func (*ExecuteMessage) ProtoMessage()

func (*ExecuteMessage) ProtoReflect

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

func (*ExecuteMessage) Reset

func (x *ExecuteMessage) Reset()

func (*ExecuteMessage) String

func (x *ExecuteMessage) String() string

type ExecuteResponse

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

func (*ExecuteResponse) Descriptor

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetData

func (x *ExecuteResponse) GetData() string

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect

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

func (*ExecuteResponse) Reset

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (x *ExecuteResponse) String() string

type ExecuteServer

type ExecuteServer interface {
	Execute(context.Context, *ExecuteMessage) (*ExecuteResponse, error)
	// contains filtered or unexported methods
}

ExecuteServer is the server API for Execute service. All implementations must embed UnimplementedExecuteServer for forward compatibility

type Kind

type Kind int32

const (
	Kind_pod  Kind = 0
	Kind_node Kind = 1
)

func (Kind) Descriptor

func (Kind) Descriptor() protoreflect.EnumDescriptor

func (Kind) Enum

func (x Kind) Enum() *Kind

func (Kind) EnumDescriptor

func (Kind) EnumDescriptor() ([]byte, []int)

Deprecated: Use Kind.Descriptor instead.

func (Kind) Number

func (x Kind) Number() protoreflect.EnumNumber

func (Kind) String

func (x Kind) String() string

func (Kind) Type

func (Kind) Type() protoreflect.EnumType

type UnimplementedExecuteServer

type UnimplementedExecuteServer struct {
}

UnimplementedExecuteServer must be embedded to have forward compatible implementations.

func (UnimplementedExecuteServer) Execute

func (UnimplementedExecuteServer) Execute(context.Context, *ExecuteMessage) (*ExecuteResponse, error)

type UnsafeExecuteServer

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

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