network

package
v0.0.0-...-b787a1b Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Bunker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Bunker",
	HandlerType: (*BunkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Connect",
			Handler:    _Bunker_Connect_Handler,
		},
		{
			MethodName: "KeepAlive",
			Handler:    _Bunker_KeepAlive_Handler,
		},
		{
			MethodName: "RunShell",
			Handler:    _Bunker_RunShell_Handler,
		},
		{
			MethodName: "ShellResize",
			Handler:    _Bunker_ShellResize_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ShellForward",
			Handler:       _Bunker_ShellForward_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "bunker.proto",
}

Bunker_ServiceDesc is the grpc.ServiceDesc for Bunker 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_bunker_proto protoreflect.FileDescriptor
View Source 
var File_ctrl_proto protoreflect.FileDescriptor
View Source 
var File_shell_proto protoreflect.FileDescriptor

Functions

func RegisterBunkerServer 

func RegisterBunkerServer(s grpc.ServiceRegistrar, srv BunkerServer)

Types

type BunkerClient 

type BunkerClient interface {
	// ctrl
	Connect(ctx context.Context, in *ConnectArgs, opts ...grpc.CallOption) (*ConnectResponse, error)
	KeepAlive(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// shell
	RunShell(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RunShellArguments, error)
	ShellResize(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ShellResizeArguments, error)
	ShellForward(ctx context.Context, opts ...grpc.CallOption) (Bunker_ShellForwardClient, error)
}

BunkerClient is the client API for Bunker 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 NewBunkerClient 

func NewBunkerClient(cc grpc.ClientConnInterface) BunkerClient

type BunkerServer 

type BunkerServer interface {
	// ctrl
	Connect(context.Context, *ConnectArgs) (*ConnectResponse, error)
	KeepAlive(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// shell
	RunShell(context.Context, *emptypb.Empty) (*RunShellArguments, error)
	ShellResize(context.Context, *emptypb.Empty) (*ShellResizeArguments, error)
	ShellForward(Bunker_ShellForwardServer) error
	// contains filtered or unexported methods
}

BunkerServer is the server API for Bunker service. All implementations must embed UnimplementedBunkerServer for forward compatibility

type Bunker_ShellForwardClient 

type Bunker_ShellForwardClient interface {
	Send(*wrapperspb.BytesValue) error
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ClientStream
}

type Bunker_ShellForwardServer 

type Bunker_ShellForwardServer interface {
	Send(*wrapperspb.BytesValue) error
	Recv() (*wrapperspb.BytesValue, error)
	grpc.ServerStream
}

type ConnectArgs 

type ConnectArgs struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Version  string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Os       string `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty"`
	Platform string `protobuf:"bytes,5,opt,name=platform,proto3" json:"platform,omitempty"`
	Arch     string `protobuf:"bytes,6,opt,name=arch,proto3" json:"arch,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectArgs) Descriptor deprecated 

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

Deprecated: Use ConnectArgs.ProtoReflect.Descriptor instead.

func (*ConnectArgs) GetArch 

func (x *ConnectArgs) GetArch() string

func (*ConnectArgs) GetHostname 

func (x *ConnectArgs) GetHostname() string

func (*ConnectArgs) GetId 

func (x *ConnectArgs) GetId() string

func (*ConnectArgs) GetOs 

func (x *ConnectArgs) GetOs() string

func (*ConnectArgs) GetPlatform 

func (x *ConnectArgs) GetPlatform() string

func (*ConnectArgs) GetVersion 

func (x *ConnectArgs) GetVersion() string

func (*ConnectArgs) ProtoMessage 

func (*ConnectArgs) ProtoMessage()

func (*ConnectArgs) ProtoReflect 

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

func (*ConnectArgs) Reset 

func (x *ConnectArgs) Reset()

func (*ConnectArgs) String 

func (x *ConnectArgs) String() string

type ConnectResponse 

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

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetId 

func (x *ConnectResponse) GetId() string

func (*ConnectResponse) GetVersion 

func (x *ConnectResponse) GetVersion() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type RunShellArguments 

type RunShellArguments struct {
	Id      string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	User    string   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Exec    string   `protobuf:"bytes,3,opt,name=exec,proto3" json:"exec,omitempty"`
	Workdir string   `protobuf:"bytes,4,opt,name=workdir,proto3" json:"workdir,omitempty"`
	Env     []string `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	// contains filtered or unexported fields
}

func (*RunShellArguments) Descriptor deprecated 

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

Deprecated: Use RunShellArguments.ProtoReflect.Descriptor instead.

func (*RunShellArguments) GetEnv 

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

func (*RunShellArguments) GetExec 

func (x *RunShellArguments) GetExec() string

func (*RunShellArguments) GetId 

func (x *RunShellArguments) GetId() string

func (*RunShellArguments) GetUser 

func (x *RunShellArguments) GetUser() string

func (*RunShellArguments) GetWorkdir 

func (x *RunShellArguments) GetWorkdir() string

func (*RunShellArguments) ProtoMessage 

func (*RunShellArguments) ProtoMessage()

func (*RunShellArguments) ProtoReflect 

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

func (*RunShellArguments) Reset 

func (x *RunShellArguments) Reset()

func (*RunShellArguments) String 

func (x *RunShellArguments) String() string

type ShellResizeArguments 

type ShellResizeArguments struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Rows uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols uint32 `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

func (*ShellResizeArguments) Descriptor deprecated 

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

Deprecated: Use ShellResizeArguments.ProtoReflect.Descriptor instead.

func (*ShellResizeArguments) GetCols 

func (x *ShellResizeArguments) GetCols() uint32

func (*ShellResizeArguments) GetId 

func (x *ShellResizeArguments) GetId() string

func (*ShellResizeArguments) GetRows 

func (x *ShellResizeArguments) GetRows() uint32

func (*ShellResizeArguments) ProtoMessage 

func (*ShellResizeArguments) ProtoMessage()

func (*ShellResizeArguments) ProtoReflect 

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

func (*ShellResizeArguments) Reset 

func (x *ShellResizeArguments) Reset()

func (*ShellResizeArguments) String 

func (x *ShellResizeArguments) String() string

type UnimplementedBunkerServer 

type UnimplementedBunkerServer struct {
}

UnimplementedBunkerServer must be embedded to have forward compatible implementations.

func (UnimplementedBunkerServer) Connect 

func (UnimplementedBunkerServer) Connect(context.Context, *ConnectArgs) (*ConnectResponse, error)

func (UnimplementedBunkerServer) KeepAlive 

func (UnimplementedBunkerServer) KeepAlive(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedBunkerServer) RunShell 

func (UnimplementedBunkerServer) RunShell(context.Context, *emptypb.Empty) (*RunShellArguments, error)

func (UnimplementedBunkerServer) ShellForward 

func (UnimplementedBunkerServer) ShellForward(Bunker_ShellForwardServer) error

func (UnimplementedBunkerServer) ShellResize 

func (UnimplementedBunkerServer) ShellResize(context.Context, *emptypb.Empty) (*ShellResizeArguments, error)

type UnsafeBunkerServer 

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

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