tunneling

package
v0.11.8 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2020 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTunnelingServer 

func RegisterTunnelingServer(s *grpc.Server, srv TunnelingServer)

Types

type CreateRequest 

type CreateRequest struct {
	Specification        *CreationSpecification `protobuf:"bytes,1,opt,name=specification,proto3" json:"specification,omitempty"`
	Response             string                 `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetResponse 

func (m *CreateRequest) GetResponse() string

func (*CreateRequest) GetSpecification 

func (m *CreateRequest) GetSpecification() *CreationSpecification

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

type CreateResponse 

type CreateResponse struct {
	HostCredentials      *tunneling.TunnelHostCredentials `protobuf:"bytes,1,opt,name=hostCredentials,proto3" json:"hostCredentials,omitempty"`
	Message              string                           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Prompt               string                           `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) EnsureValid 

func (r *CreateResponse) EnsureValid() error

EnsureValid verifies that a CreateResponse is valid.

func (*CreateResponse) GetHostCredentials 

func (m *CreateResponse) GetHostCredentials() *tunneling.TunnelHostCredentials

func (*CreateResponse) GetMessage 

func (m *CreateResponse) GetMessage() string

func (*CreateResponse) GetPrompt 

func (m *CreateResponse) GetPrompt() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateResponse) XXX_Merge 

func (m *CreateResponse) XXX_Merge(src proto.Message)

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

func (m *CreateResponse) XXX_Unmarshal(b []byte) error

type CreationSpecification 

type CreationSpecification struct {
	// Configuration is the base tunnel configuration. It is the result of
	// merging the global configuration (unless disabled), any manually
	// specified configuration file, and any command line configuration
	// parameters.
	Configuration *tunneling.Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// Name is the name for the tunnel object.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Labels are the labels for the tunnel object.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Paused indicates whether or not to create the tunnel pre-paused.
	Paused               bool     `protobuf:"varint,4,opt,name=paused,proto3" json:"paused,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreationSpecification) Descriptor 

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

func (*CreationSpecification) GetConfiguration 

func (m *CreationSpecification) GetConfiguration() *tunneling.Configuration

func (*CreationSpecification) GetLabels 

func (m *CreationSpecification) GetLabels() map[string]string

func (*CreationSpecification) GetName 

func (m *CreationSpecification) GetName() string

func (*CreationSpecification) GetPaused 

func (m *CreationSpecification) GetPaused() bool

func (*CreationSpecification) ProtoMessage 

func (*CreationSpecification) ProtoMessage()

func (*CreationSpecification) Reset 

func (m *CreationSpecification) Reset()

func (*CreationSpecification) String 

func (m *CreationSpecification) String() string

func (*CreationSpecification) XXX_DiscardUnknown 

func (m *CreationSpecification) XXX_DiscardUnknown()

func (*CreationSpecification) XXX_Marshal 

func (m *CreationSpecification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreationSpecification) XXX_Merge 

func (m *CreationSpecification) XXX_Merge(src proto.Message)

func (*CreationSpecification) XXX_Size 

func (m *CreationSpecification) XXX_Size() int

func (*CreationSpecification) XXX_Unmarshal 

func (m *CreationSpecification) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	PreviousStateIndex   uint64               `protobuf:"varint,2,opt,name=previousStateIndex,proto3" json:"previousStateIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetPreviousStateIndex 

func (m *ListRequest) GetPreviousStateIndex() uint64

func (*ListRequest) GetSelection 

func (m *ListRequest) GetSelection() *selection.Selection

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListResponse 

type ListResponse struct {
	StateIndex           uint64             `protobuf:"varint,1,opt,name=stateIndex,proto3" json:"stateIndex,omitempty"`
	TunnelStates         []*tunneling.State `protobuf:"bytes,2,rep,name=tunnelStates,proto3" json:"tunnelStates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) EnsureValid 

func (r *ListResponse) EnsureValid() error

ensureValid verifies that a ListResponse is valid.

func (*ListResponse) GetStateIndex 

func (m *ListResponse) GetStateIndex() uint64

func (*ListResponse) GetTunnelStates 

func (m *ListResponse) GetTunnelStates() []*tunneling.State

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListResponse) XXX_Merge 

func (m *ListResponse) XXX_Merge(src proto.Message)

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

func (m *ListResponse) XXX_Unmarshal(b []byte) error

type PauseRequest 

type PauseRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PauseRequest) Descriptor 

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

func (*PauseRequest) GetSelection 

func (m *PauseRequest) GetSelection() *selection.Selection

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset 

func (m *PauseRequest) Reset()

func (*PauseRequest) String 

func (m *PauseRequest) String() string

func (*PauseRequest) XXX_DiscardUnknown 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type PauseResponse 

type PauseResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseResponse) Descriptor 

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

func (*PauseResponse) EnsureValid 

func (r *PauseResponse) EnsureValid() error

EnsureValid verifies that a PauseResponse is valid.

func (*PauseResponse) GetMessage 

func (m *PauseResponse) GetMessage() string

func (*PauseResponse) ProtoMessage 

func (*PauseResponse) ProtoMessage()

func (*PauseResponse) Reset 

func (m *PauseResponse) Reset()

func (*PauseResponse) String 

func (m *PauseResponse) String() string

func (*PauseResponse) XXX_DiscardUnknown 

func (m *PauseResponse) XXX_DiscardUnknown()

func (*PauseResponse) XXX_Marshal 

func (m *PauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseResponse) XXX_Merge 

func (m *PauseResponse) XXX_Merge(src proto.Message)

func (*PauseResponse) XXX_Size 

func (m *PauseResponse) XXX_Size() int

func (*PauseResponse) XXX_Unmarshal 

func (m *PauseResponse) XXX_Unmarshal(b []byte) error

type ResumeRequest 

type ResumeRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	Response             string               `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResumeRequest) Descriptor 

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

func (*ResumeRequest) GetResponse 

func (m *ResumeRequest) GetResponse() string

func (*ResumeRequest) GetSelection 

func (m *ResumeRequest) GetSelection() *selection.Selection

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) Reset 

func (m *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (m *ResumeRequest) String() string

func (*ResumeRequest) XXX_DiscardUnknown 

func (m *ResumeRequest) XXX_DiscardUnknown()

func (*ResumeRequest) XXX_Marshal 

func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeRequest) XXX_Merge 

func (m *ResumeRequest) XXX_Merge(src proto.Message)

func (*ResumeRequest) XXX_Size 

func (m *ResumeRequest) XXX_Size() int

func (*ResumeRequest) XXX_Unmarshal 

func (m *ResumeRequest) XXX_Unmarshal(b []byte) error

type ResumeResponse 

type ResumeResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Prompt               string   `protobuf:"bytes,2,opt,name=prompt,proto3" json:"prompt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResumeResponse) Descriptor 

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

func (*ResumeResponse) EnsureValid 

func (r *ResumeResponse) EnsureValid() error

EnsureValid verifies that a ResumeResponse is valid.

func (*ResumeResponse) GetMessage 

func (m *ResumeResponse) GetMessage() string

func (*ResumeResponse) GetPrompt 

func (m *ResumeResponse) GetPrompt() string

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) Reset 

func (m *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (m *ResumeResponse) String() string

func (*ResumeResponse) XXX_DiscardUnknown 

func (m *ResumeResponse) XXX_DiscardUnknown()

func (*ResumeResponse) XXX_Marshal 

func (m *ResumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeResponse) XXX_Merge 

func (m *ResumeResponse) XXX_Merge(src proto.Message)

func (*ResumeResponse) XXX_Size 

func (m *ResumeResponse) XXX_Size() int

func (*ResumeResponse) XXX_Unmarshal 

func (m *ResumeResponse) XXX_Unmarshal(b []byte) error

type Server 

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

Server provides an implementation of the Tunneling service.

func NewServer 

func NewServer(manager *tunneling.Manager) *Server

NewServer creates a new tunnel server.

func (*Server) Create 

func (s *Server) Create(stream Tunneling_CreateServer) error

Create creates a new tunnel.

func (*Server) List 

func (s *Server) List(ctx context.Context, request *ListRequest) (*ListResponse, error)

List lists existing tunnels.

func (*Server) Pause 

func (s *Server) Pause(stream Tunneling_PauseServer) error

Pause pauses existing tunnels.

func (*Server) Resume 

func (s *Server) Resume(stream Tunneling_ResumeServer) error

Resume resumes existing tunnels.

func (*Server) Terminate 

func (s *Server) Terminate(stream Tunneling_TerminateServer) error

Terminate terminates existing tunnels.

type TerminateRequest 

type TerminateRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TerminateRequest) Descriptor 

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

func (*TerminateRequest) GetSelection 

func (m *TerminateRequest) GetSelection() *selection.Selection

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) Reset 

func (m *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (m *TerminateRequest) String() string

func (*TerminateRequest) XXX_DiscardUnknown 

func (m *TerminateRequest) XXX_DiscardUnknown()

func (*TerminateRequest) XXX_Marshal 

func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateRequest) XXX_Merge 

func (m *TerminateRequest) XXX_Merge(src proto.Message)

func (*TerminateRequest) XXX_Size 

func (m *TerminateRequest) XXX_Size() int

func (*TerminateRequest) XXX_Unmarshal 

func (m *TerminateRequest) XXX_Unmarshal(b []byte) error

type TerminateResponse 

type TerminateResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TerminateResponse) Descriptor 

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

func (*TerminateResponse) EnsureValid 

func (r *TerminateResponse) EnsureValid() error

EnsureValid verifies that a TerminateResponse is valid.

func (*TerminateResponse) GetMessage 

func (m *TerminateResponse) GetMessage() string

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) Reset 

func (m *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (m *TerminateResponse) String() string

func (*TerminateResponse) XXX_DiscardUnknown 

func (m *TerminateResponse) XXX_DiscardUnknown()

func (*TerminateResponse) XXX_Marshal 

func (m *TerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateResponse) XXX_Merge 

func (m *TerminateResponse) XXX_Merge(src proto.Message)

func (*TerminateResponse) XXX_Size 

func (m *TerminateResponse) XXX_Size() int

func (*TerminateResponse) XXX_Unmarshal 

func (m *TerminateResponse) XXX_Unmarshal(b []byte) error

type TunnelingClient 

type TunnelingClient interface {
	Create(ctx context.Context, opts ...grpc.CallOption) (Tunneling_CreateClient, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Pause(ctx context.Context, opts ...grpc.CallOption) (Tunneling_PauseClient, error)
	Resume(ctx context.Context, opts ...grpc.CallOption) (Tunneling_ResumeClient, error)
	Terminate(ctx context.Context, opts ...grpc.CallOption) (Tunneling_TerminateClient, error)
}

TunnelingClient is the client API for Tunneling service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTunnelingClient 

func NewTunnelingClient(cc grpc.ClientConnInterface) TunnelingClient

type TunnelingServer 

type TunnelingServer interface {
	Create(Tunneling_CreateServer) error
	List(context.Context, *ListRequest) (*ListResponse, error)
	Pause(Tunneling_PauseServer) error
	Resume(Tunneling_ResumeServer) error
	Terminate(Tunneling_TerminateServer) error
}

TunnelingServer is the server API for Tunneling service.

type Tunneling_CreateClient 

type Tunneling_CreateClient interface {
	Send(*CreateRequest) error
	Recv() (*CreateResponse, error)
	grpc.ClientStream
}

type Tunneling_CreateServer 

type Tunneling_CreateServer interface {
	Send(*CreateResponse) error
	Recv() (*CreateRequest, error)
	grpc.ServerStream
}

type Tunneling_PauseClient 

type Tunneling_PauseClient interface {
	Send(*PauseRequest) error
	Recv() (*PauseResponse, error)
	grpc.ClientStream
}

type Tunneling_PauseServer 

type Tunneling_PauseServer interface {
	Send(*PauseResponse) error
	Recv() (*PauseRequest, error)
	grpc.ServerStream
}

type Tunneling_ResumeClient 

type Tunneling_ResumeClient interface {
	Send(*ResumeRequest) error
	Recv() (*ResumeResponse, error)
	grpc.ClientStream
}

type Tunneling_ResumeServer 

type Tunneling_ResumeServer interface {
	Send(*ResumeResponse) error
	Recv() (*ResumeRequest, error)
	grpc.ServerStream
}

type Tunneling_TerminateClient 

type Tunneling_TerminateClient interface {
	Send(*TerminateRequest) error
	Recv() (*TerminateResponse, error)
	grpc.ClientStream
}

type Tunneling_TerminateServer 

type Tunneling_TerminateServer interface {
	Send(*TerminateResponse) error
	Recv() (*TerminateRequest, error)
	grpc.ServerStream
}

type UnimplementedTunnelingServer 

type UnimplementedTunnelingServer struct {
}

UnimplementedTunnelingServer can be embedded to have forward compatible implementations.

func (*UnimplementedTunnelingServer) Create 

func (*UnimplementedTunnelingServer) Create(srv Tunneling_CreateServer) error

func (*UnimplementedTunnelingServer) List 

func (*UnimplementedTunnelingServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

func (*UnimplementedTunnelingServer) Pause 

func (*UnimplementedTunnelingServer) Pause(srv Tunneling_PauseServer) error

func (*UnimplementedTunnelingServer) Resume 

func (*UnimplementedTunnelingServer) Resume(srv Tunneling_ResumeServer) error

func (*UnimplementedTunnelingServer) Terminate 

func (*UnimplementedTunnelingServer) Terminate(srv Tunneling_TerminateServer) error

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.