protos

package
v0.0.162 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2022 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterForemanClientServer added in v0.0.154 

func RegisterForemanClientServer(s *grpc.Server, srv ForemanClientServer)

func RegisterForemanServerServer added in v0.0.154 

func RegisterForemanServerServer(s *grpc.Server, srv ForemanServerServer)

func RegisterPlumberServerServer 

func RegisterPlumberServerServer(s *grpc.Server, srv PlumberServerServer)

Types

type CreateConnectionRequest 

type CreateConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*CreateConnectionRequest) Descriptor 

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

func (*CreateConnectionRequest) GetAuth 

func (m *CreateConnectionRequest) GetAuth() *common.Auth

func (*CreateConnectionRequest) GetOptions added in v0.0.49 

func (m *CreateConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*CreateConnectionRequest) ProtoMessage 

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) Reset 

func (m *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String 

func (m *CreateConnectionRequest) String() string

func (*CreateConnectionRequest) XXX_DiscardUnknown 

func (m *CreateConnectionRequest) XXX_DiscardUnknown()

func (*CreateConnectionRequest) XXX_Marshal 

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

func (*CreateConnectionRequest) XXX_Merge 

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

func (*CreateConnectionRequest) XXX_Size 

func (m *CreateConnectionRequest) XXX_Size() int

func (*CreateConnectionRequest) XXX_Unmarshal 

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

type CreateConnectionResponse 

type CreateConnectionResponse struct {
	// Set with uuid that represents connection if create is successful
	ConnectionId         string   `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateConnectionResponse) Descriptor 

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

func (*CreateConnectionResponse) GetConnectionId 

func (m *CreateConnectionResponse) GetConnectionId() string

func (*CreateConnectionResponse) ProtoMessage 

func (*CreateConnectionResponse) ProtoMessage()

func (*CreateConnectionResponse) Reset 

func (m *CreateConnectionResponse) Reset()

func (*CreateConnectionResponse) String 

func (m *CreateConnectionResponse) String() string

func (*CreateConnectionResponse) XXX_DiscardUnknown 

func (m *CreateConnectionResponse) XXX_DiscardUnknown()

func (*CreateConnectionResponse) XXX_Marshal 

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

func (*CreateConnectionResponse) XXX_Merge 

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

func (*CreateConnectionResponse) XXX_Size 

func (m *CreateConnectionResponse) XXX_Size() int

func (*CreateConnectionResponse) XXX_Unmarshal 

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

type CreateRelayRequest 

type CreateRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth       `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*CreateRelayRequest) Descriptor 

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

func (*CreateRelayRequest) GetAuth 

func (m *CreateRelayRequest) GetAuth() *common.Auth

func (*CreateRelayRequest) GetOpts added in v0.0.49 

func (m *CreateRelayRequest) GetOpts() *opts.RelayOptions

func (*CreateRelayRequest) ProtoMessage 

func (*CreateRelayRequest) ProtoMessage()

func (*CreateRelayRequest) Reset 

func (m *CreateRelayRequest) Reset()

func (*CreateRelayRequest) String 

func (m *CreateRelayRequest) String() string

func (*CreateRelayRequest) XXX_DiscardUnknown 

func (m *CreateRelayRequest) XXX_DiscardUnknown()

func (*CreateRelayRequest) XXX_Marshal 

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

func (*CreateRelayRequest) XXX_Merge 

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

func (*CreateRelayRequest) XXX_Size 

func (m *CreateRelayRequest) XXX_Size() int

func (*CreateRelayRequest) XXX_Unmarshal 

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

type CreateRelayResponse 

type CreateRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// ID of the created relay entry
	RelayId              string   `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRelayResponse) Descriptor 

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

func (*CreateRelayResponse) GetRelayId 

func (m *CreateRelayResponse) GetRelayId() string

func (*CreateRelayResponse) GetStatus 

func (m *CreateRelayResponse) GetStatus() *common.Status

func (*CreateRelayResponse) ProtoMessage 

func (*CreateRelayResponse) ProtoMessage()

func (*CreateRelayResponse) Reset 

func (m *CreateRelayResponse) Reset()

func (*CreateRelayResponse) String 

func (m *CreateRelayResponse) String() string

func (*CreateRelayResponse) XXX_DiscardUnknown 

func (m *CreateRelayResponse) XXX_DiscardUnknown()

func (*CreateRelayResponse) XXX_Marshal 

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

func (*CreateRelayResponse) XXX_Merge 

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

func (*CreateRelayResponse) XXX_Size 

func (m *CreateRelayResponse) XXX_Size() int

func (*CreateRelayResponse) XXX_Unmarshal 

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

type CreateTunnelRequest added in v0.0.142 

type CreateTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth        `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Opts                 *opts.TunnelOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CreateTunnelRequest) Descriptor added in v0.0.142 

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

func (*CreateTunnelRequest) GetAuth added in v0.0.142 

func (m *CreateTunnelRequest) GetAuth() *common.Auth

func (*CreateTunnelRequest) GetOpts added in v0.0.142 

func (m *CreateTunnelRequest) GetOpts() *opts.TunnelOptions

func (*CreateTunnelRequest) ProtoMessage added in v0.0.142 

func (*CreateTunnelRequest) ProtoMessage()

func (*CreateTunnelRequest) Reset added in v0.0.142 

func (m *CreateTunnelRequest) Reset()

func (*CreateTunnelRequest) String added in v0.0.142 

func (m *CreateTunnelRequest) String() string

func (*CreateTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *CreateTunnelRequest) XXX_DiscardUnknown()

func (*CreateTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*CreateTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*CreateTunnelRequest) XXX_Size added in v0.0.142 

func (m *CreateTunnelRequest) XXX_Size() int

func (*CreateTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type CreateTunnelResponse added in v0.0.142 

type CreateTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// ID of the created tunnel entry
	TunnelId             string   `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTunnelResponse) Descriptor added in v0.0.142 

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

func (*CreateTunnelResponse) GetStatus added in v0.0.142 

func (m *CreateTunnelResponse) GetStatus() *common.Status

func (*CreateTunnelResponse) GetTunnelId added in v0.0.142 

func (m *CreateTunnelResponse) GetTunnelId() string

func (*CreateTunnelResponse) ProtoMessage added in v0.0.142 

func (*CreateTunnelResponse) ProtoMessage()

func (*CreateTunnelResponse) Reset added in v0.0.142 

func (m *CreateTunnelResponse) Reset()

func (*CreateTunnelResponse) String added in v0.0.142 

func (m *CreateTunnelResponse) String() string

func (*CreateTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *CreateTunnelResponse) XXX_DiscardUnknown()

func (*CreateTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*CreateTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*CreateTunnelResponse) XXX_Size added in v0.0.142 

func (m *CreateTunnelResponse) XXX_Size() int

func (*CreateTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

type DeleteConnectionRequest 

type DeleteConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteConnectionRequest) Descriptor 

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

func (*DeleteConnectionRequest) GetAuth 

func (m *DeleteConnectionRequest) GetAuth() *common.Auth

func (*DeleteConnectionRequest) GetConnectionId 

func (m *DeleteConnectionRequest) GetConnectionId() string

func (*DeleteConnectionRequest) ProtoMessage 

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) Reset 

func (m *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String 

func (m *DeleteConnectionRequest) String() string

func (*DeleteConnectionRequest) XXX_DiscardUnknown 

func (m *DeleteConnectionRequest) XXX_DiscardUnknown()

func (*DeleteConnectionRequest) XXX_Marshal 

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

func (*DeleteConnectionRequest) XXX_Merge 

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

func (*DeleteConnectionRequest) XXX_Size 

func (m *DeleteConnectionRequest) XXX_Size() int

func (*DeleteConnectionRequest) XXX_Unmarshal 

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

type DeleteConnectionResponse 

type DeleteConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteConnectionResponse) Descriptor 

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

func (*DeleteConnectionResponse) GetStatus 

func (m *DeleteConnectionResponse) GetStatus() *common.Status

func (*DeleteConnectionResponse) ProtoMessage 

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) Reset 

func (m *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String 

func (m *DeleteConnectionResponse) String() string

func (*DeleteConnectionResponse) XXX_DiscardUnknown 

func (m *DeleteConnectionResponse) XXX_DiscardUnknown()

func (*DeleteConnectionResponse) XXX_Marshal 

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

func (*DeleteConnectionResponse) XXX_Merge 

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

func (*DeleteConnectionResponse) XXX_Size 

func (m *DeleteConnectionResponse) XXX_Size() int

func (*DeleteConnectionResponse) XXX_Unmarshal 

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

type DeleteRelayRequest 

type DeleteRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteRelayRequest) Descriptor 

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

func (*DeleteRelayRequest) GetAuth 

func (m *DeleteRelayRequest) GetAuth() *common.Auth

func (*DeleteRelayRequest) GetRelayId 

func (m *DeleteRelayRequest) GetRelayId() string

func (*DeleteRelayRequest) ProtoMessage 

func (*DeleteRelayRequest) ProtoMessage()

func (*DeleteRelayRequest) Reset 

func (m *DeleteRelayRequest) Reset()

func (*DeleteRelayRequest) String 

func (m *DeleteRelayRequest) String() string

func (*DeleteRelayRequest) XXX_DiscardUnknown 

func (m *DeleteRelayRequest) XXX_DiscardUnknown()

func (*DeleteRelayRequest) XXX_Marshal 

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

func (*DeleteRelayRequest) XXX_Merge 

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

func (*DeleteRelayRequest) XXX_Size 

func (m *DeleteRelayRequest) XXX_Size() int

func (*DeleteRelayRequest) XXX_Unmarshal 

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

type DeleteRelayResponse 

type DeleteRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteRelayResponse) Descriptor 

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

func (*DeleteRelayResponse) GetStatus 

func (m *DeleteRelayResponse) GetStatus() *common.Status

func (*DeleteRelayResponse) ProtoMessage 

func (*DeleteRelayResponse) ProtoMessage()

func (*DeleteRelayResponse) Reset 

func (m *DeleteRelayResponse) Reset()

func (*DeleteRelayResponse) String 

func (m *DeleteRelayResponse) String() string

func (*DeleteRelayResponse) XXX_DiscardUnknown 

func (m *DeleteRelayResponse) XXX_DiscardUnknown()

func (*DeleteRelayResponse) XXX_Marshal 

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

func (*DeleteRelayResponse) XXX_Merge 

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

func (*DeleteRelayResponse) XXX_Size 

func (m *DeleteRelayResponse) XXX_Size() int

func (*DeleteRelayResponse) XXX_Unmarshal 

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

type DeleteTunnelRequest added in v0.0.142 

type DeleteTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	TunnelId             string       `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteTunnelRequest) Descriptor added in v0.0.142 

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

func (*DeleteTunnelRequest) GetAuth added in v0.0.142 

func (m *DeleteTunnelRequest) GetAuth() *common.Auth

func (*DeleteTunnelRequest) GetTunnelId added in v0.0.142 

func (m *DeleteTunnelRequest) GetTunnelId() string

func (*DeleteTunnelRequest) ProtoMessage added in v0.0.142 

func (*DeleteTunnelRequest) ProtoMessage()

func (*DeleteTunnelRequest) Reset added in v0.0.142 

func (m *DeleteTunnelRequest) Reset()

func (*DeleteTunnelRequest) String added in v0.0.142 

func (m *DeleteTunnelRequest) String() string

func (*DeleteTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *DeleteTunnelRequest) XXX_DiscardUnknown()

func (*DeleteTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*DeleteTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*DeleteTunnelRequest) XXX_Size added in v0.0.142 

func (m *DeleteTunnelRequest) XXX_Size() int

func (*DeleteTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type DeleteTunnelResponse added in v0.0.142 

type DeleteTunnelResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DeleteTunnelResponse) Descriptor added in v0.0.142 

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

func (*DeleteTunnelResponse) GetStatus added in v0.0.142 

func (m *DeleteTunnelResponse) GetStatus() *common.Status

func (*DeleteTunnelResponse) ProtoMessage added in v0.0.142 

func (*DeleteTunnelResponse) ProtoMessage()

func (*DeleteTunnelResponse) Reset added in v0.0.142 

func (m *DeleteTunnelResponse) Reset()

func (*DeleteTunnelResponse) String added in v0.0.142 

func (m *DeleteTunnelResponse) String() string

func (*DeleteTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *DeleteTunnelResponse) XXX_DiscardUnknown()

func (*DeleteTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*DeleteTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*DeleteTunnelResponse) XXX_Size added in v0.0.142 

func (m *DeleteTunnelResponse) XXX_Size() int

func (*DeleteTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

type ForemanClientClient added in v0.0.154 

type ForemanClientClient interface {
	// Used by plumber to connect to Foreman and announce its presence.
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
}

ForemanClientClient is the client API for ForemanClient service.

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

func NewForemanClientClient added in v0.0.154 

func NewForemanClientClient(cc *grpc.ClientConn) ForemanClientClient

type ForemanClientServer added in v0.0.154 

type ForemanClientServer interface {
	// Used by plumber to connect to Foreman and announce its presence.
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
}

ForemanClientServer is the server API for ForemanClient service.

type ForemanServerClient added in v0.0.154 

type ForemanServerClient interface {
	// ListPlumbers is called by ui-bff, received by Foreman
	// It returns all connected plumber instances for a given team
	ListPlumbers(ctx context.Context, in *ListPlumbersRequest, opts ...grpc.CallOption) (*ListPlumbersResponse, error)
	// List configured/known connections
	GetAllConnections(ctx context.Context, in *GetAllConnectionsRequest, opts ...grpc.CallOption) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(ctx context.Context, in *TestConnectionRequest, opts ...grpc.CallOption) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionResponse, error)
	GetAllRelays(ctx context.Context, in *GetAllRelaysRequest, opts ...grpc.CallOption) (*GetAllRelaysResponse, error)
	GetRelay(ctx context.Context, in *GetRelayRequest, opts ...grpc.CallOption) (*GetRelayResponse, error)
	CreateRelay(ctx context.Context, in *CreateRelayRequest, opts ...grpc.CallOption) (*CreateRelayResponse, error)
	UpdateRelay(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*UpdateRelayResponse, error)
	ResumeRelay(ctx context.Context, in *ResumeRelayRequest, opts ...grpc.CallOption) (*ResumeRelayResponse, error)
	StopRelay(ctx context.Context, in *StopRelayRequest, opts ...grpc.CallOption) (*StopRelayResponse, error)
	DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error)
	GetTunnel(ctx context.Context, in *GetTunnelRequest, opts ...grpc.CallOption) (*GetTunnelResponse, error)
	GetAllTunnels(ctx context.Context, in *GetAllTunnelsRequest, opts ...grpc.CallOption) (*GetAllTunnelsResponse, error)
	CreateTunnel(ctx context.Context, in *CreateTunnelRequest, opts ...grpc.CallOption) (*CreateTunnelResponse, error)
	StopTunnel(ctx context.Context, in *StopTunnelRequest, opts ...grpc.CallOption) (*StopTunnelResponse, error)
	ResumeTunnel(ctx context.Context, in *ResumeTunnelRequest, opts ...grpc.CallOption) (*ResumeTunnelResponse, error)
	UpdateTunnel(ctx context.Context, in *UpdateTunnelRequest, opts ...grpc.CallOption) (*UpdateTunnelResponse, error)
	DeleteTunnel(ctx context.Context, in *DeleteTunnelRequest, opts ...grpc.CallOption) (*DeleteTunnelResponse, error)
	GetServerOptions(ctx context.Context, in *GetServerOptionsRequest, opts ...grpc.CallOption) (*GetServerOptionsResponse, error)
}

ForemanServerClient is the client API for ForemanServer service.

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

func NewForemanServerClient added in v0.0.154 

func NewForemanServerClient(cc *grpc.ClientConn) ForemanServerClient

type ForemanServerServer added in v0.0.154 

type ForemanServerServer interface {
	// ListPlumbers is called by ui-bff, received by Foreman
	// It returns all connected plumber instances for a given team
	ListPlumbers(context.Context, *ListPlumbersRequest) (*ListPlumbersResponse, error)
	// List configured/known connections
	GetAllConnections(context.Context, *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(context.Context, *TestConnectionRequest) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
	GetAllRelays(context.Context, *GetAllRelaysRequest) (*GetAllRelaysResponse, error)
	GetRelay(context.Context, *GetRelayRequest) (*GetRelayResponse, error)
	CreateRelay(context.Context, *CreateRelayRequest) (*CreateRelayResponse, error)
	UpdateRelay(context.Context, *UpdateRelayRequest) (*UpdateRelayResponse, error)
	ResumeRelay(context.Context, *ResumeRelayRequest) (*ResumeRelayResponse, error)
	StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error)
	DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error)
	GetTunnel(context.Context, *GetTunnelRequest) (*GetTunnelResponse, error)
	GetAllTunnels(context.Context, *GetAllTunnelsRequest) (*GetAllTunnelsResponse, error)
	CreateTunnel(context.Context, *CreateTunnelRequest) (*CreateTunnelResponse, error)
	StopTunnel(context.Context, *StopTunnelRequest) (*StopTunnelResponse, error)
	ResumeTunnel(context.Context, *ResumeTunnelRequest) (*ResumeTunnelResponse, error)
	UpdateTunnel(context.Context, *UpdateTunnelRequest) (*UpdateTunnelResponse, error)
	DeleteTunnel(context.Context, *DeleteTunnelRequest) (*DeleteTunnelResponse, error)
	GetServerOptions(context.Context, *GetServerOptionsRequest) (*GetServerOptionsResponse, error)
}

ForemanServerServer is the server API for ForemanServer service.

type GetAllConnectionsRequest 

type GetAllConnectionsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllConnectionsRequest) Descriptor 

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

func (*GetAllConnectionsRequest) GetAuth 

func (m *GetAllConnectionsRequest) GetAuth() *common.Auth

func (*GetAllConnectionsRequest) ProtoMessage 

func (*GetAllConnectionsRequest) ProtoMessage()

func (*GetAllConnectionsRequest) Reset 

func (m *GetAllConnectionsRequest) Reset()

func (*GetAllConnectionsRequest) String 

func (m *GetAllConnectionsRequest) String() string

func (*GetAllConnectionsRequest) XXX_DiscardUnknown 

func (m *GetAllConnectionsRequest) XXX_DiscardUnknown()

func (*GetAllConnectionsRequest) XXX_Marshal 

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

func (*GetAllConnectionsRequest) XXX_Merge 

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

func (*GetAllConnectionsRequest) XXX_Size 

func (m *GetAllConnectionsRequest) XXX_Size() int

func (*GetAllConnectionsRequest) XXX_Unmarshal 

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

type GetAllConnectionsResponse 

type GetAllConnectionsResponse struct {
	Options              []*opts.ConnectionOptions `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*GetAllConnectionsResponse) Descriptor 

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

func (*GetAllConnectionsResponse) GetOptions added in v0.0.49 

func (m *GetAllConnectionsResponse) GetOptions() []*opts.ConnectionOptions

func (*GetAllConnectionsResponse) ProtoMessage 

func (*GetAllConnectionsResponse) ProtoMessage()

func (*GetAllConnectionsResponse) Reset 

func (m *GetAllConnectionsResponse) Reset()

func (*GetAllConnectionsResponse) String 

func (m *GetAllConnectionsResponse) String() string

func (*GetAllConnectionsResponse) XXX_DiscardUnknown 

func (m *GetAllConnectionsResponse) XXX_DiscardUnknown()

func (*GetAllConnectionsResponse) XXX_Marshal 

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

func (*GetAllConnectionsResponse) XXX_Merge 

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

func (*GetAllConnectionsResponse) XXX_Size 

func (m *GetAllConnectionsResponse) XXX_Size() int

func (*GetAllConnectionsResponse) XXX_Unmarshal 

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

type GetAllRelaysRequest 

type GetAllRelaysRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllRelaysRequest) Descriptor 

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

func (*GetAllRelaysRequest) GetAuth 

func (m *GetAllRelaysRequest) GetAuth() *common.Auth

func (*GetAllRelaysRequest) ProtoMessage 

func (*GetAllRelaysRequest) ProtoMessage()

func (*GetAllRelaysRequest) Reset 

func (m *GetAllRelaysRequest) Reset()

func (*GetAllRelaysRequest) String 

func (m *GetAllRelaysRequest) String() string

func (*GetAllRelaysRequest) XXX_DiscardUnknown 

func (m *GetAllRelaysRequest) XXX_DiscardUnknown()

func (*GetAllRelaysRequest) XXX_Marshal 

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

func (*GetAllRelaysRequest) XXX_Merge 

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

func (*GetAllRelaysRequest) XXX_Size 

func (m *GetAllRelaysRequest) XXX_Size() int

func (*GetAllRelaysRequest) XXX_Unmarshal 

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

type GetAllRelaysResponse 

type GetAllRelaysResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Will be set as empty []Relay if no relays are configured
	Opts                 []*opts.RelayOptions `protobuf:"bytes,1,rep,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*GetAllRelaysResponse) Descriptor 

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

func (*GetAllRelaysResponse) GetOpts added in v0.0.49 

func (m *GetAllRelaysResponse) GetOpts() []*opts.RelayOptions

func (*GetAllRelaysResponse) GetStatus 

func (m *GetAllRelaysResponse) GetStatus() *common.Status

func (*GetAllRelaysResponse) ProtoMessage 

func (*GetAllRelaysResponse) ProtoMessage()

func (*GetAllRelaysResponse) Reset 

func (m *GetAllRelaysResponse) Reset()

func (*GetAllRelaysResponse) String 

func (m *GetAllRelaysResponse) String() string

func (*GetAllRelaysResponse) XXX_DiscardUnknown 

func (m *GetAllRelaysResponse) XXX_DiscardUnknown()

func (*GetAllRelaysResponse) XXX_Marshal 

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

func (*GetAllRelaysResponse) XXX_Merge 

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

func (*GetAllRelaysResponse) XXX_Size 

func (m *GetAllRelaysResponse) XXX_Size() int

func (*GetAllRelaysResponse) XXX_Unmarshal 

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

type GetAllTunnelsRequest added in v0.0.142 

type GetAllTunnelsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetAllTunnelsRequest) Descriptor added in v0.0.142 

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

func (*GetAllTunnelsRequest) GetAuth added in v0.0.142 

func (m *GetAllTunnelsRequest) GetAuth() *common.Auth

func (*GetAllTunnelsRequest) ProtoMessage added in v0.0.142 

func (*GetAllTunnelsRequest) ProtoMessage()

func (*GetAllTunnelsRequest) Reset added in v0.0.142 

func (m *GetAllTunnelsRequest) Reset()

func (*GetAllTunnelsRequest) String added in v0.0.142 

func (m *GetAllTunnelsRequest) String() string

func (*GetAllTunnelsRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *GetAllTunnelsRequest) XXX_DiscardUnknown()

func (*GetAllTunnelsRequest) XXX_Marshal added in v0.0.142 

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

func (*GetAllTunnelsRequest) XXX_Merge added in v0.0.142 

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

func (*GetAllTunnelsRequest) XXX_Size added in v0.0.142 

func (m *GetAllTunnelsRequest) XXX_Size() int

func (*GetAllTunnelsRequest) XXX_Unmarshal added in v0.0.142 

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

type GetAllTunnelsResponse added in v0.0.142 

type GetAllTunnelsResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Will be set as empty []Tunnel if no tunnels are configured
	Opts                 []*opts.TunnelOptions `protobuf:"bytes,1,rep,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*GetAllTunnelsResponse) Descriptor added in v0.0.142 

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

func (*GetAllTunnelsResponse) GetOpts added in v0.0.142 

func (m *GetAllTunnelsResponse) GetOpts() []*opts.TunnelOptions

func (*GetAllTunnelsResponse) GetStatus added in v0.0.142 

func (m *GetAllTunnelsResponse) GetStatus() *common.Status

func (*GetAllTunnelsResponse) ProtoMessage added in v0.0.142 

func (*GetAllTunnelsResponse) ProtoMessage()

func (*GetAllTunnelsResponse) Reset added in v0.0.142 

func (m *GetAllTunnelsResponse) Reset()

func (*GetAllTunnelsResponse) String added in v0.0.142 

func (m *GetAllTunnelsResponse) String() string

func (*GetAllTunnelsResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *GetAllTunnelsResponse) XXX_DiscardUnknown()

func (*GetAllTunnelsResponse) XXX_Marshal added in v0.0.142 

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

func (*GetAllTunnelsResponse) XXX_Merge added in v0.0.142 

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

func (*GetAllTunnelsResponse) XXX_Size added in v0.0.142 

func (m *GetAllTunnelsResponse) XXX_Size() int

func (*GetAllTunnelsResponse) XXX_Unmarshal added in v0.0.142 

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

type GetConnectionRequest 

type GetConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string       `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetConnectionRequest) Descriptor 

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

func (*GetConnectionRequest) GetAuth 

func (m *GetConnectionRequest) GetAuth() *common.Auth

func (*GetConnectionRequest) GetConnectionId 

func (m *GetConnectionRequest) GetConnectionId() string

func (*GetConnectionRequest) ProtoMessage 

func (*GetConnectionRequest) ProtoMessage()

func (*GetConnectionRequest) Reset 

func (m *GetConnectionRequest) Reset()

func (*GetConnectionRequest) String 

func (m *GetConnectionRequest) String() string

func (*GetConnectionRequest) XXX_DiscardUnknown 

func (m *GetConnectionRequest) XXX_DiscardUnknown()

func (*GetConnectionRequest) XXX_Marshal 

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

func (*GetConnectionRequest) XXX_Merge 

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

func (*GetConnectionRequest) XXX_Size 

func (m *GetConnectionRequest) XXX_Size() int

func (*GetConnectionRequest) XXX_Unmarshal 

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

type GetConnectionResponse 

type GetConnectionResponse struct {
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*GetConnectionResponse) Descriptor 

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

func (*GetConnectionResponse) GetOptions added in v0.0.49 

func (m *GetConnectionResponse) GetOptions() *opts.ConnectionOptions

func (*GetConnectionResponse) ProtoMessage 

func (*GetConnectionResponse) ProtoMessage()

func (*GetConnectionResponse) Reset 

func (m *GetConnectionResponse) Reset()

func (*GetConnectionResponse) String 

func (m *GetConnectionResponse) String() string

func (*GetConnectionResponse) XXX_DiscardUnknown 

func (m *GetConnectionResponse) XXX_DiscardUnknown()

func (*GetConnectionResponse) XXX_Marshal 

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

func (*GetConnectionResponse) XXX_Merge 

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

func (*GetConnectionResponse) XXX_Size 

func (m *GetConnectionResponse) XXX_Size() int

func (*GetConnectionResponse) XXX_Unmarshal 

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

type GetRelayRequest 

type GetRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetRelayRequest) Descriptor 

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

func (*GetRelayRequest) GetAuth 

func (m *GetRelayRequest) GetAuth() *common.Auth

func (*GetRelayRequest) GetRelayId 

func (m *GetRelayRequest) GetRelayId() string

func (*GetRelayRequest) ProtoMessage 

func (*GetRelayRequest) ProtoMessage()

func (*GetRelayRequest) Reset 

func (m *GetRelayRequest) Reset()

func (*GetRelayRequest) String 

func (m *GetRelayRequest) String() string

func (*GetRelayRequest) XXX_DiscardUnknown 

func (m *GetRelayRequest) XXX_DiscardUnknown()

func (*GetRelayRequest) XXX_Marshal 

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

func (*GetRelayRequest) XXX_Merge 

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

func (*GetRelayRequest) XXX_Size 

func (m *GetRelayRequest) XXX_Size() int

func (*GetRelayRequest) XXX_Unmarshal 

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

type GetRelayResponse 

type GetRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Set only if status is OK
	Opts                 *opts.RelayOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetRelayResponse) Descriptor 

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

func (*GetRelayResponse) GetOpts added in v0.0.49 

func (m *GetRelayResponse) GetOpts() *opts.RelayOptions

func (*GetRelayResponse) GetStatus 

func (m *GetRelayResponse) GetStatus() *common.Status

func (*GetRelayResponse) ProtoMessage 

func (*GetRelayResponse) ProtoMessage()

func (*GetRelayResponse) Reset 

func (m *GetRelayResponse) Reset()

func (*GetRelayResponse) String 

func (m *GetRelayResponse) String() string

func (*GetRelayResponse) XXX_DiscardUnknown 

func (m *GetRelayResponse) XXX_DiscardUnknown()

func (*GetRelayResponse) XXX_Marshal 

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

func (*GetRelayResponse) XXX_Merge 

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

func (*GetRelayResponse) XXX_Size 

func (m *GetRelayResponse) XXX_Size() int

func (*GetRelayResponse) XXX_Unmarshal 

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

type GetServerOptionsRequest added in v0.0.49 

type GetServerOptionsRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetServerOptionsRequest) Descriptor added in v0.0.49 

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

func (*GetServerOptionsRequest) GetAuth added in v0.0.49 

func (m *GetServerOptionsRequest) GetAuth() *common.Auth

func (*GetServerOptionsRequest) ProtoMessage added in v0.0.49 

func (*GetServerOptionsRequest) ProtoMessage()

func (*GetServerOptionsRequest) Reset added in v0.0.49 

func (m *GetServerOptionsRequest) Reset()

func (*GetServerOptionsRequest) String added in v0.0.49 

func (m *GetServerOptionsRequest) String() string

func (*GetServerOptionsRequest) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_DiscardUnknown()

func (*GetServerOptionsRequest) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsRequest) XXX_Size added in v0.0.49 

func (m *GetServerOptionsRequest) XXX_Size() int

func (*GetServerOptionsRequest) XXX_Unmarshal added in v0.0.49 

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

type GetServerOptionsResponse added in v0.0.49 

type GetServerOptionsResponse struct {
	ServerOptions        *opts.ServerOptions `protobuf:"bytes,1,opt,name=server_options,json=serverOptions,proto3" json:"server_options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetServerOptionsResponse) Descriptor added in v0.0.49 

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

func (*GetServerOptionsResponse) GetServerOptions added in v0.0.49 

func (m *GetServerOptionsResponse) GetServerOptions() *opts.ServerOptions

func (*GetServerOptionsResponse) ProtoMessage added in v0.0.49 

func (*GetServerOptionsResponse) ProtoMessage()

func (*GetServerOptionsResponse) Reset added in v0.0.49 

func (m *GetServerOptionsResponse) Reset()

func (*GetServerOptionsResponse) String added in v0.0.49 

func (m *GetServerOptionsResponse) String() string

func (*GetServerOptionsResponse) XXX_DiscardUnknown added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_DiscardUnknown()

func (*GetServerOptionsResponse) XXX_Marshal added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Merge added in v0.0.49 

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

func (*GetServerOptionsResponse) XXX_Size added in v0.0.49 

func (m *GetServerOptionsResponse) XXX_Size() int

func (*GetServerOptionsResponse) XXX_Unmarshal added in v0.0.49 

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

type GetTunnelRequest added in v0.0.142 

type GetTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	TunnelId             string       `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetTunnelRequest) Descriptor added in v0.0.142 

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

func (*GetTunnelRequest) GetAuth added in v0.0.142 

func (m *GetTunnelRequest) GetAuth() *common.Auth

func (*GetTunnelRequest) GetTunnelId added in v0.0.142 

func (m *GetTunnelRequest) GetTunnelId() string

func (*GetTunnelRequest) ProtoMessage added in v0.0.142 

func (*GetTunnelRequest) ProtoMessage()

func (*GetTunnelRequest) Reset added in v0.0.142 

func (m *GetTunnelRequest) Reset()

func (*GetTunnelRequest) String added in v0.0.142 

func (m *GetTunnelRequest) String() string

func (*GetTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *GetTunnelRequest) XXX_DiscardUnknown()

func (*GetTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*GetTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*GetTunnelRequest) XXX_Size added in v0.0.142 

func (m *GetTunnelRequest) XXX_Size() int

func (*GetTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type GetTunnelResponse added in v0.0.142 

type GetTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// Set only if status is OK
	Opts                 *opts.TunnelOptions `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GetTunnelResponse) Descriptor added in v0.0.142 

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

func (*GetTunnelResponse) GetOpts added in v0.0.142 

func (m *GetTunnelResponse) GetOpts() *opts.TunnelOptions

func (*GetTunnelResponse) GetStatus added in v0.0.142 

func (m *GetTunnelResponse) GetStatus() *common.Status

func (*GetTunnelResponse) ProtoMessage added in v0.0.142 

func (*GetTunnelResponse) ProtoMessage()

func (*GetTunnelResponse) Reset added in v0.0.142 

func (m *GetTunnelResponse) Reset()

func (*GetTunnelResponse) String added in v0.0.142 

func (m *GetTunnelResponse) String() string

func (*GetTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *GetTunnelResponse) XXX_DiscardUnknown()

func (*GetTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*GetTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*GetTunnelResponse) XXX_Size added in v0.0.142 

func (m *GetTunnelResponse) XXX_Size() int

func (*GetTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

type ListPlumbersRequest added in v0.0.154 

type ListPlumbersRequest struct {
	// Authenticate between ui-bff and Foreman
	AuthToken string `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// Team ID to list connected plumbers for
	TeamId               string   `protobuf:"bytes,2,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListPlumbersRequest) Descriptor added in v0.0.154 

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

func (*ListPlumbersRequest) GetAuthToken added in v0.0.154 

func (m *ListPlumbersRequest) GetAuthToken() string

func (*ListPlumbersRequest) GetTeamId added in v0.0.154 

func (m *ListPlumbersRequest) GetTeamId() string

func (*ListPlumbersRequest) ProtoMessage added in v0.0.154 

func (*ListPlumbersRequest) ProtoMessage()

func (*ListPlumbersRequest) Reset added in v0.0.154 

func (m *ListPlumbersRequest) Reset()

func (*ListPlumbersRequest) String added in v0.0.154 

func (m *ListPlumbersRequest) String() string

func (*ListPlumbersRequest) XXX_DiscardUnknown added in v0.0.154 

func (m *ListPlumbersRequest) XXX_DiscardUnknown()

func (*ListPlumbersRequest) XXX_Marshal added in v0.0.154 

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

func (*ListPlumbersRequest) XXX_Merge added in v0.0.154 

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

func (*ListPlumbersRequest) XXX_Size added in v0.0.154 

func (m *ListPlumbersRequest) XXX_Size() int

func (*ListPlumbersRequest) XXX_Unmarshal added in v0.0.154 

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

type ListPlumbersResponse added in v0.0.154 

type ListPlumbersResponse struct {
	// List of plumbers
	Plumbers             []*PlumberInfo `protobuf:"bytes,1,rep,name=plumbers,proto3" json:"plumbers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ListPlumbersResponse) Descriptor added in v0.0.154 

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

func (*ListPlumbersResponse) GetPlumbers added in v0.0.154 

func (m *ListPlumbersResponse) GetPlumbers() []*PlumberInfo

func (*ListPlumbersResponse) ProtoMessage added in v0.0.154 

func (*ListPlumbersResponse) ProtoMessage()

func (*ListPlumbersResponse) Reset added in v0.0.154 

func (m *ListPlumbersResponse) Reset()

func (*ListPlumbersResponse) String added in v0.0.154 

func (m *ListPlumbersResponse) String() string

func (*ListPlumbersResponse) XXX_DiscardUnknown added in v0.0.154 

func (m *ListPlumbersResponse) XXX_DiscardUnknown()

func (*ListPlumbersResponse) XXX_Marshal added in v0.0.154 

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

func (*ListPlumbersResponse) XXX_Merge added in v0.0.154 

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

func (*ListPlumbersResponse) XXX_Size added in v0.0.154 

func (m *ListPlumbersResponse) XXX_Size() int

func (*ListPlumbersResponse) XXX_Unmarshal added in v0.0.154 

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

type PlumberInfo added in v0.0.154 

type PlumberInfo struct {
	TeamId               string   `protobuf:"bytes,1,opt,name=team_id,json=teamId,proto3" json:"team_id,omitempty"`
	ClusterId            string   `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PlumberInfo) Descriptor added in v0.0.154 

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

func (*PlumberInfo) GetClusterId added in v0.0.154 

func (m *PlumberInfo) GetClusterId() string

func (*PlumberInfo) GetTeamId added in v0.0.154 

func (m *PlumberInfo) GetTeamId() string

func (*PlumberInfo) ProtoMessage added in v0.0.154 

func (*PlumberInfo) ProtoMessage()

func (*PlumberInfo) Reset added in v0.0.154 

func (m *PlumberInfo) Reset()

func (*PlumberInfo) String added in v0.0.154 

func (m *PlumberInfo) String() string

func (*PlumberInfo) XXX_DiscardUnknown added in v0.0.154 

func (m *PlumberInfo) XXX_DiscardUnknown()

func (*PlumberInfo) XXX_Marshal added in v0.0.154 

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

func (*PlumberInfo) XXX_Merge added in v0.0.154 

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

func (*PlumberInfo) XXX_Size added in v0.0.154 

func (m *PlumberInfo) XXX_Size() int

func (*PlumberInfo) XXX_Unmarshal added in v0.0.154 

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

type PlumberServerClient 

type PlumberServerClient interface {
	// List configured/known connections
	GetAllConnections(ctx context.Context, in *GetAllConnectionsRequest, opts ...grpc.CallOption) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(ctx context.Context, in *CreateConnectionRequest, opts ...grpc.CallOption) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(ctx context.Context, in *TestConnectionRequest, opts ...grpc.CallOption) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(ctx context.Context, in *UpdateConnectionRequest, opts ...grpc.CallOption) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionResponse, error)
	GetAllRelays(ctx context.Context, in *GetAllRelaysRequest, opts ...grpc.CallOption) (*GetAllRelaysResponse, error)
	GetRelay(ctx context.Context, in *GetRelayRequest, opts ...grpc.CallOption) (*GetRelayResponse, error)
	CreateRelay(ctx context.Context, in *CreateRelayRequest, opts ...grpc.CallOption) (*CreateRelayResponse, error)
	UpdateRelay(ctx context.Context, in *UpdateRelayRequest, opts ...grpc.CallOption) (*UpdateRelayResponse, error)
	ResumeRelay(ctx context.Context, in *ResumeRelayRequest, opts ...grpc.CallOption) (*ResumeRelayResponse, error)
	StopRelay(ctx context.Context, in *StopRelayRequest, opts ...grpc.CallOption) (*StopRelayResponse, error)
	DeleteRelay(ctx context.Context, in *DeleteRelayRequest, opts ...grpc.CallOption) (*DeleteRelayResponse, error)
	GetTunnel(ctx context.Context, in *GetTunnelRequest, opts ...grpc.CallOption) (*GetTunnelResponse, error)
	GetAllTunnels(ctx context.Context, in *GetAllTunnelsRequest, opts ...grpc.CallOption) (*GetAllTunnelsResponse, error)
	CreateTunnel(ctx context.Context, in *CreateTunnelRequest, opts ...grpc.CallOption) (*CreateTunnelResponse, error)
	StopTunnel(ctx context.Context, in *StopTunnelRequest, opts ...grpc.CallOption) (*StopTunnelResponse, error)
	ResumeTunnel(ctx context.Context, in *ResumeTunnelRequest, opts ...grpc.CallOption) (*ResumeTunnelResponse, error)
	UpdateTunnel(ctx context.Context, in *UpdateTunnelRequest, opts ...grpc.CallOption) (*UpdateTunnelResponse, error)
	DeleteTunnel(ctx context.Context, in *DeleteTunnelRequest, opts ...grpc.CallOption) (*DeleteTunnelResponse, error)
	GetServerOptions(ctx context.Context, in *GetServerOptionsRequest, opts ...grpc.CallOption) (*GetServerOptionsResponse, error)
}

PlumberServerClient is the client API for PlumberServer service.

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

func NewPlumberServerClient 

func NewPlumberServerClient(cc *grpc.ClientConn) PlumberServerClient

type PlumberServerServer 

type PlumberServerServer interface {
	// List configured/known connections
	GetAllConnections(context.Context, *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)
	// Fetch a specific connection by ID
	GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
	// Create a connection in plumber
	CreateConnection(context.Context, *CreateConnectionRequest) (*CreateConnectionResponse, error)
	// Test a connection before saving its configuration
	TestConnection(context.Context, *TestConnectionRequest) (*TestConnectionResponse, error)
	// Any active connections will be restarted
	UpdateConnection(context.Context, *UpdateConnectionRequest) (*UpdateConnectionResponse, error)
	// If there are any active connections, delete will cause them to get closed
	DeleteConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionResponse, error)
	GetAllRelays(context.Context, *GetAllRelaysRequest) (*GetAllRelaysResponse, error)
	GetRelay(context.Context, *GetRelayRequest) (*GetRelayResponse, error)
	CreateRelay(context.Context, *CreateRelayRequest) (*CreateRelayResponse, error)
	UpdateRelay(context.Context, *UpdateRelayRequest) (*UpdateRelayResponse, error)
	ResumeRelay(context.Context, *ResumeRelayRequest) (*ResumeRelayResponse, error)
	StopRelay(context.Context, *StopRelayRequest) (*StopRelayResponse, error)
	DeleteRelay(context.Context, *DeleteRelayRequest) (*DeleteRelayResponse, error)
	GetTunnel(context.Context, *GetTunnelRequest) (*GetTunnelResponse, error)
	GetAllTunnels(context.Context, *GetAllTunnelsRequest) (*GetAllTunnelsResponse, error)
	CreateTunnel(context.Context, *CreateTunnelRequest) (*CreateTunnelResponse, error)
	StopTunnel(context.Context, *StopTunnelRequest) (*StopTunnelResponse, error)
	ResumeTunnel(context.Context, *ResumeTunnelRequest) (*ResumeTunnelResponse, error)
	UpdateTunnel(context.Context, *UpdateTunnelRequest) (*UpdateTunnelResponse, error)
	DeleteTunnel(context.Context, *DeleteTunnelRequest) (*DeleteTunnelResponse, error)
	GetServerOptions(context.Context, *GetServerOptionsRequest) (*GetServerOptionsResponse, error)
}

PlumberServerServer is the server API for PlumberServer service.

type RegisterRequest added in v0.0.154 

type RegisterRequest struct {
	// API token obtained from https://console.batch.sh/account/security
	ApiToken string `protobuf:"bytes,1,opt,name=api_token,json=apiToken,proto3" json:"api_token,omitempty"`
	// Plumber cluster ID
	ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Token used to authenticate calls to this plumber instance
	// This is filled out by plumber, and then stored in memory while it is connected
	// All requests back to plumber need to provide this token
	PlumberToken string `protobuf:"bytes,3,opt,name=plumber_token,json=plumberToken,proto3" json:"plumber_token,omitempty"`
	// Individual plumber instance ID
	NodeId               string   `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterRequest) Descriptor added in v0.0.154 

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

func (*RegisterRequest) GetApiToken added in v0.0.154 

func (m *RegisterRequest) GetApiToken() string

func (*RegisterRequest) GetClusterId added in v0.0.154 

func (m *RegisterRequest) GetClusterId() string

func (*RegisterRequest) GetNodeId added in v0.0.154 

func (m *RegisterRequest) GetNodeId() string

func (*RegisterRequest) GetPlumberToken added in v0.0.154 

func (m *RegisterRequest) GetPlumberToken() string

func (*RegisterRequest) ProtoMessage added in v0.0.154 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset added in v0.0.154 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String added in v0.0.154 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown added in v0.0.154 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal added in v0.0.154 

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

func (*RegisterRequest) XXX_Merge added in v0.0.154 

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

func (*RegisterRequest) XXX_Size added in v0.0.154 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal added in v0.0.154 

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

type RegisterResponse added in v0.0.154 

type RegisterResponse struct {
	// Authorized or not
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// Error message if any
	// Will be empty on success
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterResponse) Descriptor added in v0.0.154 

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

func (*RegisterResponse) GetMessage added in v0.0.154 

func (m *RegisterResponse) GetMessage() string

func (*RegisterResponse) GetSuccess added in v0.0.154 

func (m *RegisterResponse) GetSuccess() bool

func (*RegisterResponse) ProtoMessage added in v0.0.154 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset added in v0.0.154 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String added in v0.0.154 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown added in v0.0.154 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal added in v0.0.154 

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

func (*RegisterResponse) XXX_Merge added in v0.0.154 

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

func (*RegisterResponse) XXX_Size added in v0.0.154 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal added in v0.0.154 

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

type ResumeRelayRequest added in v0.0.16 

type ResumeRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Resume a paused relay

func (*ResumeRelayRequest) Descriptor added in v0.0.16 

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

func (*ResumeRelayRequest) GetAuth added in v0.0.16 

func (m *ResumeRelayRequest) GetAuth() *common.Auth

func (*ResumeRelayRequest) GetRelayId added in v0.0.16 

func (m *ResumeRelayRequest) GetRelayId() string

func (*ResumeRelayRequest) ProtoMessage added in v0.0.16 

func (*ResumeRelayRequest) ProtoMessage()

func (*ResumeRelayRequest) Reset added in v0.0.16 

func (m *ResumeRelayRequest) Reset()

func (*ResumeRelayRequest) String added in v0.0.16 

func (m *ResumeRelayRequest) String() string

func (*ResumeRelayRequest) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayRequest) XXX_DiscardUnknown()

func (*ResumeRelayRequest) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayRequest) XXX_Size added in v0.0.16 

func (m *ResumeRelayRequest) XXX_Size() int

func (*ResumeRelayRequest) XXX_Unmarshal added in v0.0.16 

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

type ResumeRelayResponse added in v0.0.16 

type ResumeRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ResumeRelayResponse) Descriptor added in v0.0.16 

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

func (*ResumeRelayResponse) GetStatus added in v0.0.16 

func (m *ResumeRelayResponse) GetStatus() *common.Status

func (*ResumeRelayResponse) ProtoMessage added in v0.0.16 

func (*ResumeRelayResponse) ProtoMessage()

func (*ResumeRelayResponse) Reset added in v0.0.16 

func (m *ResumeRelayResponse) Reset()

func (*ResumeRelayResponse) String added in v0.0.16 

func (m *ResumeRelayResponse) String() string

func (*ResumeRelayResponse) XXX_DiscardUnknown added in v0.0.16 

func (m *ResumeRelayResponse) XXX_DiscardUnknown()

func (*ResumeRelayResponse) XXX_Marshal added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Merge added in v0.0.16 

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

func (*ResumeRelayResponse) XXX_Size added in v0.0.16 

func (m *ResumeRelayResponse) XXX_Size() int

func (*ResumeRelayResponse) XXX_Unmarshal added in v0.0.16 

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

type ResumeTunnelRequest added in v0.0.142 

type ResumeTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	TunnelId             string       `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Resume a paused relay

func (*ResumeTunnelRequest) Descriptor added in v0.0.142 

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

func (*ResumeTunnelRequest) GetAuth added in v0.0.142 

func (m *ResumeTunnelRequest) GetAuth() *common.Auth

func (*ResumeTunnelRequest) GetTunnelId added in v0.0.142 

func (m *ResumeTunnelRequest) GetTunnelId() string

func (*ResumeTunnelRequest) ProtoMessage added in v0.0.142 

func (*ResumeTunnelRequest) ProtoMessage()

func (*ResumeTunnelRequest) Reset added in v0.0.142 

func (m *ResumeTunnelRequest) Reset()

func (*ResumeTunnelRequest) String added in v0.0.142 

func (m *ResumeTunnelRequest) String() string

func (*ResumeTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *ResumeTunnelRequest) XXX_DiscardUnknown()

func (*ResumeTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*ResumeTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*ResumeTunnelRequest) XXX_Size added in v0.0.142 

func (m *ResumeTunnelRequest) XXX_Size() int

func (*ResumeTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type ResumeTunnelResponse added in v0.0.142 

type ResumeTunnelResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ResumeTunnelResponse) Descriptor added in v0.0.142 

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

func (*ResumeTunnelResponse) GetStatus added in v0.0.142 

func (m *ResumeTunnelResponse) GetStatus() *common.Status

func (*ResumeTunnelResponse) ProtoMessage added in v0.0.142 

func (*ResumeTunnelResponse) ProtoMessage()

func (*ResumeTunnelResponse) Reset added in v0.0.142 

func (m *ResumeTunnelResponse) Reset()

func (*ResumeTunnelResponse) String added in v0.0.142 

func (m *ResumeTunnelResponse) String() string

func (*ResumeTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *ResumeTunnelResponse) XXX_DiscardUnknown()

func (*ResumeTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*ResumeTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*ResumeTunnelResponse) XXX_Size added in v0.0.142 

func (m *ResumeTunnelResponse) XXX_Size() int

func (*ResumeTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

type StopRelayRequest 

type StopRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string       `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Temporarily stop/pause a relay

func (*StopRelayRequest) Descriptor 

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

func (*StopRelayRequest) GetAuth 

func (m *StopRelayRequest) GetAuth() *common.Auth

func (*StopRelayRequest) GetRelayId 

func (m *StopRelayRequest) GetRelayId() string

func (*StopRelayRequest) ProtoMessage 

func (*StopRelayRequest) ProtoMessage()

func (*StopRelayRequest) Reset 

func (m *StopRelayRequest) Reset()

func (*StopRelayRequest) String 

func (m *StopRelayRequest) String() string

func (*StopRelayRequest) XXX_DiscardUnknown 

func (m *StopRelayRequest) XXX_DiscardUnknown()

func (*StopRelayRequest) XXX_Marshal 

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

func (*StopRelayRequest) XXX_Merge 

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

func (*StopRelayRequest) XXX_Size 

func (m *StopRelayRequest) XXX_Size() int

func (*StopRelayRequest) XXX_Unmarshal 

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

type StopRelayResponse 

type StopRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StopRelayResponse) Descriptor 

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

func (*StopRelayResponse) GetStatus 

func (m *StopRelayResponse) GetStatus() *common.Status

func (*StopRelayResponse) ProtoMessage 

func (*StopRelayResponse) ProtoMessage()

func (*StopRelayResponse) Reset 

func (m *StopRelayResponse) Reset()

func (*StopRelayResponse) String 

func (m *StopRelayResponse) String() string

func (*StopRelayResponse) XXX_DiscardUnknown 

func (m *StopRelayResponse) XXX_DiscardUnknown()

func (*StopRelayResponse) XXX_Marshal 

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

func (*StopRelayResponse) XXX_Merge 

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

func (*StopRelayResponse) XXX_Size 

func (m *StopRelayResponse) XXX_Size() int

func (*StopRelayResponse) XXX_Unmarshal 

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

type StopTunnelRequest added in v0.0.142 

type StopTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	TunnelId             string       `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Temporarily stop/pause a relay

func (*StopTunnelRequest) Descriptor added in v0.0.142 

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

func (*StopTunnelRequest) GetAuth added in v0.0.142 

func (m *StopTunnelRequest) GetAuth() *common.Auth

func (*StopTunnelRequest) GetTunnelId added in v0.0.142 

func (m *StopTunnelRequest) GetTunnelId() string

func (*StopTunnelRequest) ProtoMessage added in v0.0.142 

func (*StopTunnelRequest) ProtoMessage()

func (*StopTunnelRequest) Reset added in v0.0.142 

func (m *StopTunnelRequest) Reset()

func (*StopTunnelRequest) String added in v0.0.142 

func (m *StopTunnelRequest) String() string

func (*StopTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *StopTunnelRequest) XXX_DiscardUnknown()

func (*StopTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*StopTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*StopTunnelRequest) XXX_Size added in v0.0.142 

func (m *StopTunnelRequest) XXX_Size() int

func (*StopTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type StopTunnelResponse added in v0.0.142 

type StopTunnelResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StopTunnelResponse) Descriptor added in v0.0.142 

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

func (*StopTunnelResponse) GetStatus added in v0.0.142 

func (m *StopTunnelResponse) GetStatus() *common.Status

func (*StopTunnelResponse) ProtoMessage added in v0.0.142 

func (*StopTunnelResponse) ProtoMessage()

func (*StopTunnelResponse) Reset added in v0.0.142 

func (m *StopTunnelResponse) Reset()

func (*StopTunnelResponse) String added in v0.0.142 

func (m *StopTunnelResponse) String() string

func (*StopTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *StopTunnelResponse) XXX_DiscardUnknown()

func (*StopTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*StopTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*StopTunnelResponse) XXX_Size added in v0.0.142 

func (m *StopTunnelResponse) XXX_Size() int

func (*StopTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

type TestConnectionRequest 

type TestConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*TestConnectionRequest) Descriptor 

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

func (*TestConnectionRequest) GetAuth 

func (m *TestConnectionRequest) GetAuth() *common.Auth

func (*TestConnectionRequest) GetOptions added in v0.0.49 

func (m *TestConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*TestConnectionRequest) ProtoMessage 

func (*TestConnectionRequest) ProtoMessage()

func (*TestConnectionRequest) Reset 

func (m *TestConnectionRequest) Reset()

func (*TestConnectionRequest) String 

func (m *TestConnectionRequest) String() string

func (*TestConnectionRequest) XXX_DiscardUnknown 

func (m *TestConnectionRequest) XXX_DiscardUnknown()

func (*TestConnectionRequest) XXX_Marshal 

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

func (*TestConnectionRequest) XXX_Merge 

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

func (*TestConnectionRequest) XXX_Size 

func (m *TestConnectionRequest) XXX_Size() int

func (*TestConnectionRequest) XXX_Unmarshal 

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

type TestConnectionResponse 

type TestConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TestConnectionResponse) Descriptor 

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

func (*TestConnectionResponse) GetStatus 

func (m *TestConnectionResponse) GetStatus() *common.Status

func (*TestConnectionResponse) ProtoMessage 

func (*TestConnectionResponse) ProtoMessage()

func (*TestConnectionResponse) Reset 

func (m *TestConnectionResponse) Reset()

func (*TestConnectionResponse) String 

func (m *TestConnectionResponse) String() string

func (*TestConnectionResponse) XXX_DiscardUnknown 

func (m *TestConnectionResponse) XXX_DiscardUnknown()

func (*TestConnectionResponse) XXX_Marshal 

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

func (*TestConnectionResponse) XXX_Merge 

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

func (*TestConnectionResponse) XXX_Size 

func (m *TestConnectionResponse) XXX_Size() int

func (*TestConnectionResponse) XXX_Unmarshal 

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

type UnimplementedForemanClientServer added in v0.0.154 

type UnimplementedForemanClientServer struct {
}

UnimplementedForemanClientServer can be embedded to have forward compatible implementations.

func (*UnimplementedForemanClientServer) Register added in v0.0.154 

func (*UnimplementedForemanClientServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)

type UnimplementedForemanServerServer added in v0.0.154 

type UnimplementedForemanServerServer struct {
}

UnimplementedForemanServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedForemanServerServer) CreateConnection added in v0.0.154 

func (*UnimplementedForemanServerServer) CreateConnection(ctx context.Context, req *CreateConnectionRequest) (*CreateConnectionResponse, error)

func (*UnimplementedForemanServerServer) CreateRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)

func (*UnimplementedForemanServerServer) CreateTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) CreateTunnel(ctx context.Context, req *CreateTunnelRequest) (*CreateTunnelResponse, error)

func (*UnimplementedForemanServerServer) DeleteConnection added in v0.0.154 

func (*UnimplementedForemanServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)

func (*UnimplementedForemanServerServer) DeleteRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)

func (*UnimplementedForemanServerServer) DeleteTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) DeleteTunnel(ctx context.Context, req *DeleteTunnelRequest) (*DeleteTunnelResponse, error)

func (*UnimplementedForemanServerServer) GetAllConnections added in v0.0.154 

func (*UnimplementedForemanServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)

func (*UnimplementedForemanServerServer) GetAllRelays added in v0.0.154 

func (*UnimplementedForemanServerServer) GetAllRelays(ctx context.Context, req *GetAllRelaysRequest) (*GetAllRelaysResponse, error)

func (*UnimplementedForemanServerServer) GetAllTunnels added in v0.0.154 

func (*UnimplementedForemanServerServer) GetAllTunnels(ctx context.Context, req *GetAllTunnelsRequest) (*GetAllTunnelsResponse, error)

func (*UnimplementedForemanServerServer) GetConnection added in v0.0.154 

func (*UnimplementedForemanServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)

func (*UnimplementedForemanServerServer) GetRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) GetRelay(ctx context.Context, req *GetRelayRequest) (*GetRelayResponse, error)

func (*UnimplementedForemanServerServer) GetServerOptions added in v0.0.154 

func (*UnimplementedForemanServerServer) GetServerOptions(ctx context.Context, req *GetServerOptionsRequest) (*GetServerOptionsResponse, error)

func (*UnimplementedForemanServerServer) GetTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) GetTunnel(ctx context.Context, req *GetTunnelRequest) (*GetTunnelResponse, error)

func (*UnimplementedForemanServerServer) ListPlumbers added in v0.0.154 

func (*UnimplementedForemanServerServer) ListPlumbers(ctx context.Context, req *ListPlumbersRequest) (*ListPlumbersResponse, error)

func (*UnimplementedForemanServerServer) ResumeRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) ResumeRelay(ctx context.Context, req *ResumeRelayRequest) (*ResumeRelayResponse, error)

func (*UnimplementedForemanServerServer) ResumeTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) ResumeTunnel(ctx context.Context, req *ResumeTunnelRequest) (*ResumeTunnelResponse, error)

func (*UnimplementedForemanServerServer) StopRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) StopRelay(ctx context.Context, req *StopRelayRequest) (*StopRelayResponse, error)

func (*UnimplementedForemanServerServer) StopTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) StopTunnel(ctx context.Context, req *StopTunnelRequest) (*StopTunnelResponse, error)

func (*UnimplementedForemanServerServer) TestConnection added in v0.0.154 

func (*UnimplementedForemanServerServer) TestConnection(ctx context.Context, req *TestConnectionRequest) (*TestConnectionResponse, error)

func (*UnimplementedForemanServerServer) UpdateConnection added in v0.0.154 

func (*UnimplementedForemanServerServer) UpdateConnection(ctx context.Context, req *UpdateConnectionRequest) (*UpdateConnectionResponse, error)

func (*UnimplementedForemanServerServer) UpdateRelay added in v0.0.154 

func (*UnimplementedForemanServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, error)

func (*UnimplementedForemanServerServer) UpdateTunnel added in v0.0.154 

func (*UnimplementedForemanServerServer) UpdateTunnel(ctx context.Context, req *UpdateTunnelRequest) (*UpdateTunnelResponse, error)

type UnimplementedPlumberServerServer 

type UnimplementedPlumberServerServer struct {
}

UnimplementedPlumberServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlumberServerServer) CreateConnection 

func (*UnimplementedPlumberServerServer) CreateConnection(ctx context.Context, req *CreateConnectionRequest) (*CreateConnectionResponse, error)

func (*UnimplementedPlumberServerServer) CreateRelay 

func (*UnimplementedPlumberServerServer) CreateRelay(ctx context.Context, req *CreateRelayRequest) (*CreateRelayResponse, error)

func (*UnimplementedPlumberServerServer) CreateTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) CreateTunnel(ctx context.Context, req *CreateTunnelRequest) (*CreateTunnelResponse, error)

func (*UnimplementedPlumberServerServer) DeleteConnection 

func (*UnimplementedPlumberServerServer) DeleteConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionResponse, error)

func (*UnimplementedPlumberServerServer) DeleteRelay 

func (*UnimplementedPlumberServerServer) DeleteRelay(ctx context.Context, req *DeleteRelayRequest) (*DeleteRelayResponse, error)

func (*UnimplementedPlumberServerServer) DeleteTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) DeleteTunnel(ctx context.Context, req *DeleteTunnelRequest) (*DeleteTunnelResponse, error)

func (*UnimplementedPlumberServerServer) GetAllConnections 

func (*UnimplementedPlumberServerServer) GetAllConnections(ctx context.Context, req *GetAllConnectionsRequest) (*GetAllConnectionsResponse, error)

func (*UnimplementedPlumberServerServer) GetAllRelays added in v0.0.17 

func (*UnimplementedPlumberServerServer) GetAllRelays(ctx context.Context, req *GetAllRelaysRequest) (*GetAllRelaysResponse, error)

func (*UnimplementedPlumberServerServer) GetAllTunnels added in v0.0.142 

func (*UnimplementedPlumberServerServer) GetAllTunnels(ctx context.Context, req *GetAllTunnelsRequest) (*GetAllTunnelsResponse, error)

func (*UnimplementedPlumberServerServer) GetConnection added in v0.0.3 

func (*UnimplementedPlumberServerServer) GetConnection(ctx context.Context, req *GetConnectionRequest) (*GetConnectionResponse, error)

func (*UnimplementedPlumberServerServer) GetRelay added in v0.0.130 

func (*UnimplementedPlumberServerServer) GetRelay(ctx context.Context, req *GetRelayRequest) (*GetRelayResponse, error)

func (*UnimplementedPlumberServerServer) GetServerOptions added in v0.0.49 

func (*UnimplementedPlumberServerServer) GetServerOptions(ctx context.Context, req *GetServerOptionsRequest) (*GetServerOptionsResponse, error)

func (*UnimplementedPlumberServerServer) GetTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) GetTunnel(ctx context.Context, req *GetTunnelRequest) (*GetTunnelResponse, error)

func (*UnimplementedPlumberServerServer) ResumeRelay added in v0.0.16 

func (*UnimplementedPlumberServerServer) ResumeRelay(ctx context.Context, req *ResumeRelayRequest) (*ResumeRelayResponse, error)

func (*UnimplementedPlumberServerServer) ResumeTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) ResumeTunnel(ctx context.Context, req *ResumeTunnelRequest) (*ResumeTunnelResponse, error)

func (*UnimplementedPlumberServerServer) StopRelay 

func (*UnimplementedPlumberServerServer) StopRelay(ctx context.Context, req *StopRelayRequest) (*StopRelayResponse, error)

func (*UnimplementedPlumberServerServer) StopTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) StopTunnel(ctx context.Context, req *StopTunnelRequest) (*StopTunnelResponse, error)

func (*UnimplementedPlumberServerServer) TestConnection 

func (*UnimplementedPlumberServerServer) TestConnection(ctx context.Context, req *TestConnectionRequest) (*TestConnectionResponse, error)

func (*UnimplementedPlumberServerServer) UpdateConnection 

func (*UnimplementedPlumberServerServer) UpdateConnection(ctx context.Context, req *UpdateConnectionRequest) (*UpdateConnectionResponse, error)

func (*UnimplementedPlumberServerServer) UpdateRelay 

func (*UnimplementedPlumberServerServer) UpdateRelay(ctx context.Context, req *UpdateRelayRequest) (*UpdateRelayResponse, error)

func (*UnimplementedPlumberServerServer) UpdateTunnel added in v0.0.142 

func (*UnimplementedPlumberServerServer) UpdateTunnel(ctx context.Context, req *UpdateTunnelRequest) (*UpdateTunnelResponse, error)

type UpdateConnectionRequest 

type UpdateConnectionRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth            `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	ConnectionId         string                  `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Options              *opts.ConnectionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*UpdateConnectionRequest) Descriptor 

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

func (*UpdateConnectionRequest) GetAuth 

func (m *UpdateConnectionRequest) GetAuth() *common.Auth

func (*UpdateConnectionRequest) GetConnectionId 

func (m *UpdateConnectionRequest) GetConnectionId() string

func (*UpdateConnectionRequest) GetOptions added in v0.0.49 

func (m *UpdateConnectionRequest) GetOptions() *opts.ConnectionOptions

func (*UpdateConnectionRequest) ProtoMessage 

func (*UpdateConnectionRequest) ProtoMessage()

func (*UpdateConnectionRequest) Reset 

func (m *UpdateConnectionRequest) Reset()

func (*UpdateConnectionRequest) String 

func (m *UpdateConnectionRequest) String() string

func (*UpdateConnectionRequest) XXX_DiscardUnknown 

func (m *UpdateConnectionRequest) XXX_DiscardUnknown()

func (*UpdateConnectionRequest) XXX_Marshal 

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

func (*UpdateConnectionRequest) XXX_Merge 

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

func (*UpdateConnectionRequest) XXX_Size 

func (m *UpdateConnectionRequest) XXX_Size() int

func (*UpdateConnectionRequest) XXX_Unmarshal 

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

type UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateConnectionResponse) Descriptor 

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

func (*UpdateConnectionResponse) GetStatus 

func (m *UpdateConnectionResponse) GetStatus() *common.Status

func (*UpdateConnectionResponse) ProtoMessage 

func (*UpdateConnectionResponse) ProtoMessage()

func (*UpdateConnectionResponse) Reset 

func (m *UpdateConnectionResponse) Reset()

func (*UpdateConnectionResponse) String 

func (m *UpdateConnectionResponse) String() string

func (*UpdateConnectionResponse) XXX_DiscardUnknown 

func (m *UpdateConnectionResponse) XXX_DiscardUnknown()

func (*UpdateConnectionResponse) XXX_Marshal 

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

func (*UpdateConnectionResponse) XXX_Merge 

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

func (*UpdateConnectionResponse) XXX_Size 

func (m *UpdateConnectionResponse) XXX_Size() int

func (*UpdateConnectionResponse) XXX_Unmarshal 

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

type UpdateRelayRequest 

type UpdateRelayRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth       `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	RelayId              string             `protobuf:"bytes,1,opt,name=relay_id,json=relayId,proto3" json:"relay_id,omitempty"`
	Opts                 *opts.RelayOptions `protobuf:"bytes,2,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

WARNING: Any in-progress relay will be interrupted/restarted

func (*UpdateRelayRequest) Descriptor 

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

func (*UpdateRelayRequest) GetAuth 

func (m *UpdateRelayRequest) GetAuth() *common.Auth

func (*UpdateRelayRequest) GetOpts added in v0.0.49 

func (m *UpdateRelayRequest) GetOpts() *opts.RelayOptions

func (*UpdateRelayRequest) GetRelayId 

func (m *UpdateRelayRequest) GetRelayId() string

func (*UpdateRelayRequest) ProtoMessage 

func (*UpdateRelayRequest) ProtoMessage()

func (*UpdateRelayRequest) Reset 

func (m *UpdateRelayRequest) Reset()

func (*UpdateRelayRequest) String 

func (m *UpdateRelayRequest) String() string

func (*UpdateRelayRequest) XXX_DiscardUnknown 

func (m *UpdateRelayRequest) XXX_DiscardUnknown()

func (*UpdateRelayRequest) XXX_Marshal 

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

func (*UpdateRelayRequest) XXX_Merge 

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

func (*UpdateRelayRequest) XXX_Size 

func (m *UpdateRelayRequest) XXX_Size() int

func (*UpdateRelayRequest) XXX_Unmarshal 

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

type UpdateRelayResponse 

type UpdateRelayResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateRelayResponse) Descriptor 

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

func (*UpdateRelayResponse) GetStatus 

func (m *UpdateRelayResponse) GetStatus() *common.Status

func (*UpdateRelayResponse) ProtoMessage 

func (*UpdateRelayResponse) ProtoMessage()

func (*UpdateRelayResponse) Reset 

func (m *UpdateRelayResponse) Reset()

func (*UpdateRelayResponse) String 

func (m *UpdateRelayResponse) String() string

func (*UpdateRelayResponse) XXX_DiscardUnknown 

func (m *UpdateRelayResponse) XXX_DiscardUnknown()

func (*UpdateRelayResponse) XXX_Marshal 

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

func (*UpdateRelayResponse) XXX_Merge 

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

func (*UpdateRelayResponse) XXX_Size 

func (m *UpdateRelayResponse) XXX_Size() int

func (*UpdateRelayResponse) XXX_Unmarshal 

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

type UpdateTunnelRequest added in v0.0.142 

type UpdateTunnelRequest struct {
	// Every gRPC request must have a valid auth config
	Auth                 *common.Auth        `protobuf:"bytes,9999,opt,name=auth,proto3" json:"auth,omitempty"`
	TunnelId             string              `protobuf:"bytes,1,opt,name=tunnel_id,json=tunnelId,proto3" json:"tunnel_id,omitempty"`
	Opts                 *opts.TunnelOptions `protobuf:"bytes,2,opt,name=opts,proto3" json:"opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

WARNING: Updating a destination that is in-use can result in missing data during replay

func (*UpdateTunnelRequest) Descriptor added in v0.0.142 

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

func (*UpdateTunnelRequest) GetAuth added in v0.0.142 

func (m *UpdateTunnelRequest) GetAuth() *common.Auth

func (*UpdateTunnelRequest) GetOpts added in v0.0.142 

func (m *UpdateTunnelRequest) GetOpts() *opts.TunnelOptions

func (*UpdateTunnelRequest) GetTunnelId added in v0.0.142 

func (m *UpdateTunnelRequest) GetTunnelId() string

func (*UpdateTunnelRequest) ProtoMessage added in v0.0.142 

func (*UpdateTunnelRequest) ProtoMessage()

func (*UpdateTunnelRequest) Reset added in v0.0.142 

func (m *UpdateTunnelRequest) Reset()

func (*UpdateTunnelRequest) String added in v0.0.142 

func (m *UpdateTunnelRequest) String() string

func (*UpdateTunnelRequest) XXX_DiscardUnknown added in v0.0.142 

func (m *UpdateTunnelRequest) XXX_DiscardUnknown()

func (*UpdateTunnelRequest) XXX_Marshal added in v0.0.142 

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

func (*UpdateTunnelRequest) XXX_Merge added in v0.0.142 

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

func (*UpdateTunnelRequest) XXX_Size added in v0.0.142 

func (m *UpdateTunnelRequest) XXX_Size() int

func (*UpdateTunnelRequest) XXX_Unmarshal added in v0.0.142 

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

type UpdateTunnelResponse added in v0.0.142 

type UpdateTunnelResponse struct {
	Status               *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateTunnelResponse) Descriptor added in v0.0.142 

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

func (*UpdateTunnelResponse) GetStatus added in v0.0.142 

func (m *UpdateTunnelResponse) GetStatus() *common.Status

func (*UpdateTunnelResponse) ProtoMessage added in v0.0.142 

func (*UpdateTunnelResponse) ProtoMessage()

func (*UpdateTunnelResponse) Reset added in v0.0.142 

func (m *UpdateTunnelResponse) Reset()

func (*UpdateTunnelResponse) String added in v0.0.142 

func (m *UpdateTunnelResponse) String() string

func (*UpdateTunnelResponse) XXX_DiscardUnknown added in v0.0.142 

func (m *UpdateTunnelResponse) XXX_DiscardUnknown()

func (*UpdateTunnelResponse) XXX_Marshal added in v0.0.142 

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

func (*UpdateTunnelResponse) XXX_Merge added in v0.0.142 

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

func (*UpdateTunnelResponse) XXX_Size added in v0.0.142 

func (m *UpdateTunnelResponse) XXX_Size() int

func (*UpdateTunnelResponse) XXX_Unmarshal added in v0.0.142 

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

Source Files

View all Source files

Directories

Path Synopsis

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.