agent

package
v0.5.2 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Agent_Exec_FullMethodName     = "/agent.Agent/Exec"
	Agent_CopyFrom_FullMethodName = "/agent.Agent/CopyFrom"
	Agent_CopyTo_FullMethodName   = "/agent.Agent/CopyTo"
	Agent_Finish_FullMethodName   = "/agent.Agent/Finish"
)

Variables

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agent.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exec",
			Handler:    _Agent_Exec_Handler,
		},
		{
			MethodName: "Finish",
			Handler:    _Agent_Finish_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CopyFrom",
			Handler:       _Agent_CopyFrom_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CopyTo",
			Handler:       _Agent_CopyTo_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "agent.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent 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 File_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

Types

type AgentClient 

type AgentClient interface {
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
	CopyFrom(ctx context.Context, in *CopyFromRequest, opts ...grpc.CallOption) (Agent_CopyFromClient, error)
	CopyTo(ctx context.Context, opts ...grpc.CallOption) (Agent_CopyToClient, error)
	Finish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*FinishResponse, error)
}

AgentClient is the client API for Agent 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 NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

type AgentServer interface {
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	CopyFrom(*CopyFromRequest, Agent_CopyFromServer) error
	CopyTo(Agent_CopyToServer) error
	Finish(context.Context, *FinishRequest) (*FinishResponse, error)
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_CopyFromClient 

type Agent_CopyFromClient interface {
	Recv() (*CopyFromResponse, error)
	grpc.ClientStream
}

type Agent_CopyFromServer 

type Agent_CopyFromServer interface {
	Send(*CopyFromResponse) error
	grpc.ServerStream
}

type Agent_CopyToClient 

type Agent_CopyToClient interface {
	Send(*CopyToRequest) error
	Recv() (*CopyToResponse, error)
	grpc.ClientStream
}

type Agent_CopyToServer 

type Agent_CopyToServer interface {
	Send(*CopyToResponse) error
	Recv() (*CopyToRequest, error)
	grpc.ServerStream
}

type CopyFromRequest 

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

func (*CopyFromRequest) Descriptor deprecated 

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

Deprecated: Use CopyFromRequest.ProtoReflect.Descriptor instead.

func (*CopyFromRequest) GetPath 

func (x *CopyFromRequest) GetPath() string

func (*CopyFromRequest) ProtoMessage 

func (*CopyFromRequest) ProtoMessage()

func (*CopyFromRequest) ProtoReflect 

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

func (*CopyFromRequest) Reset 

func (x *CopyFromRequest) Reset()

func (*CopyFromRequest) String 

func (x *CopyFromRequest) String() string

type CopyFromResponse 

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

func (*CopyFromResponse) Descriptor deprecated 

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

Deprecated: Use CopyFromResponse.ProtoReflect.Descriptor instead.

func (*CopyFromResponse) GetData 

func (x *CopyFromResponse) GetData() []byte

func (*CopyFromResponse) ProtoMessage 

func (*CopyFromResponse) ProtoMessage()

func (*CopyFromResponse) ProtoReflect 

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

func (*CopyFromResponse) Reset 

func (x *CopyFromResponse) Reset()

func (*CopyFromResponse) String 

func (x *CopyFromResponse) String() string

type CopyToRequest 

type CopyToRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyToRequest) Descriptor deprecated 

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

Deprecated: Use CopyToRequest.ProtoReflect.Descriptor instead.

func (*CopyToRequest) GetData 

func (x *CopyToRequest) GetData() []byte

func (*CopyToRequest) GetPath 

func (x *CopyToRequest) GetPath() string

func (*CopyToRequest) ProtoMessage 

func (*CopyToRequest) ProtoMessage()

func (*CopyToRequest) ProtoReflect 

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

func (*CopyToRequest) Reset 

func (x *CopyToRequest) Reset()

func (*CopyToRequest) String 

func (x *CopyToRequest) String() string

type CopyToResponse 

type CopyToResponse struct {
	CopiedLength int64 `protobuf:"varint,1,opt,name=copied_length,json=copiedLength,proto3" json:"copied_length,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyToResponse) Descriptor deprecated 

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

Deprecated: Use CopyToResponse.ProtoReflect.Descriptor instead.

func (*CopyToResponse) GetCopiedLength 

func (x *CopyToResponse) GetCopiedLength() int64

func (*CopyToResponse) ProtoMessage 

func (*CopyToResponse) ProtoMessage()

func (*CopyToResponse) ProtoReflect 

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

func (*CopyToResponse) Reset 

func (x *CopyToResponse) Reset()

func (*CopyToResponse) String 

func (x *CopyToResponse) String() string

type Env 

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

func (*Env) Descriptor deprecated 

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

Deprecated: Use Env.ProtoReflect.Descriptor instead.

func (*Env) GetName 

func (x *Env) GetName() string

func (*Env) GetValue 

func (x *Env) GetValue() string

func (*Env) ProtoMessage 

func (*Env) ProtoMessage()

func (*Env) ProtoReflect 

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

func (*Env) Reset 

func (x *Env) Reset()

func (*Env) String 

func (x *Env) String() string

type ExecRequest 

type ExecRequest struct {
	Command    []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"`
	Env        []*Env   `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	WorkingDir string   `protobuf:"bytes,3,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecRequest) Descriptor deprecated 

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetCommand 

func (x *ExecRequest) GetCommand() []string

func (*ExecRequest) GetEnv 

func (x *ExecRequest) GetEnv() []*Env

func (*ExecRequest) GetWorkingDir 

func (x *ExecRequest) GetWorkingDir() string

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect 

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

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) String 

func (x *ExecRequest) String() string

type ExecResponse 

type ExecResponse struct {
	Output         string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Success        bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	ExitCode       int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	ErrorMessage   string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	ElapsedTimeSec int64  `protobuf:"varint,5,opt,name=elapsed_time_sec,json=elapsedTimeSec,proto3" json:"elapsed_time_sec,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecResponse) Descriptor deprecated 

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

Deprecated: Use ExecResponse.ProtoReflect.Descriptor instead.

func (*ExecResponse) GetElapsedTimeSec 

func (x *ExecResponse) GetElapsedTimeSec() int64

func (*ExecResponse) GetErrorMessage 

func (x *ExecResponse) GetErrorMessage() string

func (*ExecResponse) GetExitCode 

func (x *ExecResponse) GetExitCode() int32

func (*ExecResponse) GetOutput 

func (x *ExecResponse) GetOutput() string

func (*ExecResponse) GetSuccess 

func (x *ExecResponse) GetSuccess() bool

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) ProtoReflect 

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

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) String 

func (x *ExecResponse) String() string

type FinishRequest 

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

func (*FinishRequest) Descriptor deprecated 

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

Deprecated: Use FinishRequest.ProtoReflect.Descriptor instead.

func (*FinishRequest) ProtoMessage 

func (*FinishRequest) ProtoMessage()

func (*FinishRequest) ProtoReflect 

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

func (*FinishRequest) Reset 

func (x *FinishRequest) Reset()

func (*FinishRequest) String 

func (x *FinishRequest) String() string

type FinishResponse 

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

func (*FinishResponse) Descriptor deprecated 

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

Deprecated: Use FinishResponse.ProtoReflect.Descriptor instead.

func (*FinishResponse) ProtoMessage 

func (*FinishResponse) ProtoMessage()

func (*FinishResponse) ProtoReflect 

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

func (*FinishResponse) Reset 

func (x *FinishResponse) Reset()

func (*FinishResponse) String 

func (x *FinishResponse) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) CopyFrom 

func (UnimplementedAgentServer) CopyFrom(*CopyFromRequest, Agent_CopyFromServer) error

func (UnimplementedAgentServer) CopyTo 

func (UnimplementedAgentServer) CopyTo(Agent_CopyToServer) error

func (UnimplementedAgentServer) Exec 

func (UnimplementedAgentServer) Exec(context.Context, *ExecRequest) (*ExecResponse, error)

func (UnimplementedAgentServer) Finish 

func (UnimplementedAgentServer) Finish(context.Context, *FinishRequest) (*FinishResponse, error)

type UnsafeAgentServer added in v0.4.0 

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

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