agent

Documentation

Index

• Constants
• Variables
• func RegisterKubeAgentServer(s grpc.ServiceRegistrar, srv KubeAgentServer)
• type KubeAgentClient
  • func NewKubeAgentClient(cc grpc.ClientConnInterface) KubeAgentClient
• type KubeAgentServer
• type PayloadIn
  • func (*PayloadIn) Descriptor() ([]byte, []int)
  • func (x *PayloadIn) GetAccountId() string
  • func (x *PayloadIn) GetAction() string
  • func (x *PayloadIn) GetPayload() map[string]*anypb.Any
  • func (x *PayloadIn) GetResourceRef() string
  • func (*PayloadIn) ProtoMessage()
  • func (x *PayloadIn) ProtoReflect() protoreflect.Message
  • func (x *PayloadIn) Reset()
  • func (x *PayloadIn) String() string
• type PayloadOut
  • func (*PayloadOut) Descriptor() ([]byte, []int)
  • func (x *PayloadOut) GetExecErr() string
  • func (x *PayloadOut) GetStderr() string
  • func (x *PayloadOut) GetStdout() string
  • func (x *PayloadOut) GetSuccess() bool
  • func (*PayloadOut) ProtoMessage()
  • func (x *PayloadOut) ProtoReflect() protoreflect.Message
  • func (x *PayloadOut) Reset()
  • func (x *PayloadOut) String() string
• type UnimplementedKubeAgentServer
  • func (UnimplementedKubeAgentServer) KubeApply(context.Context, *PayloadIn) (*PayloadOut, error)
• type UnsafeKubeAgentServer

Constants

const (
	KubeAgent_KubeApply_FullMethodName = "/KubeAgent/KubeApply"
)

Variables

var File_kubeagent_proto protoreflect.FileDescriptor

var KubeAgent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "KubeAgent",
	HandlerType: (*KubeAgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "KubeApply",
			Handler:    _KubeAgent_KubeApply_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "kubeagent.proto",
}

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

Functions

func RegisterKubeAgentServer

func RegisterKubeAgentServer(s grpc.ServiceRegistrar, srv KubeAgentServer)

Types

type KubeAgentClient

type KubeAgentClient interface {
	KubeApply(ctx context.Context, in *PayloadIn, opts ...grpc.CallOption) (*PayloadOut, error)
}

KubeAgentClient is the client API for KubeAgent 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 NewKubeAgentClient

func NewKubeAgentClient(cc grpc.ClientConnInterface) KubeAgentClient

type KubeAgentServer

type KubeAgentServer interface {
	KubeApply(context.Context, *PayloadIn) (*PayloadOut, error)
	// contains filtered or unexported methods
}

KubeAgentServer is the server API for KubeAgent service. All implementations must embed UnimplementedKubeAgentServer for forward compatibility

type PayloadIn

type PayloadIn struct {
	Action      string                `protobuf:"bytes,1,opt,name=Action,proto3" json:"Action,omitempty"`
	Payload     map[string]*anypb.Any `` /* 155-byte string literal not displayed */
	AccountId   string                `protobuf:"bytes,3,opt,name=accountId,proto3" json:"accountId,omitempty"`
	ResourceRef string                `protobuf:"bytes,4,opt,name=ResourceRef,proto3" json:"ResourceRef,omitempty"`
	// contains filtered or unexported fields
}

func (*PayloadIn) Descriptor

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

Deprecated: Use PayloadIn.ProtoReflect.Descriptor instead.

func (*PayloadIn) GetAccountId

func (x *PayloadIn) GetAccountId() string

func (*PayloadIn) GetAction

func (x *PayloadIn) GetAction() string

func (*PayloadIn) GetPayload

func (x *PayloadIn) GetPayload() map[string]*anypb.Any

func (*PayloadIn) GetResourceRef

func (x *PayloadIn) GetResourceRef() string

func (*PayloadIn) ProtoMessage

func (*PayloadIn) ProtoMessage()

func (*PayloadIn) ProtoReflect

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

func (*PayloadIn) Reset

func (x *PayloadIn) Reset()

func (*PayloadIn) String

func (x *PayloadIn) String() string

type PayloadOut

type PayloadOut struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Stdout  string `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr  string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	ExecErr string `protobuf:"bytes,4,opt,name=execErr,proto3" json:"execErr,omitempty"`
	// contains filtered or unexported fields
}

func (*PayloadOut) Descriptor

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

Deprecated: Use PayloadOut.ProtoReflect.Descriptor instead.

func (*PayloadOut) GetExecErr

func (x *PayloadOut) GetExecErr() string

func (*PayloadOut) GetStderr

func (x *PayloadOut) GetStderr() string

func (*PayloadOut) GetStdout

func (x *PayloadOut) GetStdout() string

func (*PayloadOut) GetSuccess

func (x *PayloadOut) GetSuccess() bool

func (*PayloadOut) ProtoMessage

func (*PayloadOut) ProtoMessage()

func (*PayloadOut) ProtoReflect

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

func (*PayloadOut) Reset

func (x *PayloadOut) Reset()

func (*PayloadOut) String

func (x *PayloadOut) String() string

type UnimplementedKubeAgentServer

type UnimplementedKubeAgentServer struct {
}

UnimplementedKubeAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedKubeAgentServer) KubeApply

func (UnimplementedKubeAgentServer) KubeApply(context.Context, *PayloadIn) (*PayloadOut, error)

type UnsafeKubeAgentServer

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

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