protos

package
v0.0.185 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_ps_base_proto protoreflect.FileDescriptor
View Source 
var File_ps_connect_proto protoreflect.FileDescriptor
View Source 
var File_ps_foreman_client_proto protoreflect.FileDescriptor
View Source 
var File_ps_foreman_server_proto protoreflect.FileDescriptor
View Source 
var File_ps_relay_proto protoreflect.FileDescriptor
View Source 
var File_ps_server_proto protoreflect.FileDescriptor
View Source 
var File_ps_tunnel_proto protoreflect.FileDescriptor
View Source 
var ForemanClient_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protos.ForemanClient",
	HandlerType: (*ForemanClientServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _ForemanClient_Register_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ps_foreman_client.proto",
}

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

View Source 
var ForemanServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protos.ForemanServer",
	HandlerType: (*ForemanServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListPlumbers",
			Handler:    _ForemanServer_ListPlumbers_Handler,
		},
		{
			MethodName: "GetAllConnections",
			Handler:    _ForemanServer_GetAllConnections_Handler,
		},
		{
			MethodName: "GetConnection",
			Handler:    _ForemanServer_GetConnection_Handler,
		},
		{
			MethodName: "CreateConnection",
			Handler:    _ForemanServer_CreateConnection_Handler,
		},
		{
			MethodName: "TestConnection",
			Handler:    _ForemanServer_TestConnection_Handler,
		},
		{
			MethodName: "UpdateConnection",
			Handler:    _ForemanServer_UpdateConnection_Handler,
		},
		{
			MethodName: "DeleteConnection",
			Handler:    _ForemanServer_DeleteConnection_Handler,
		},
		{
			MethodName: "GetAllRelays",
			Handler:    _ForemanServer_GetAllRelays_Handler,
		},
		{
			MethodName: "GetRelay",
			Handler:    _ForemanServer_GetRelay_Handler,
		},
		{
			MethodName: "CreateRelay",
			Handler:    _ForemanServer_CreateRelay_Handler,
		},
		{
			MethodName: "UpdateRelay",
			Handler:    _ForemanServer_UpdateRelay_Handler,
		},
		{
			MethodName: "ResumeRelay",
			Handler:    _ForemanServer_ResumeRelay_Handler,
		},
		{
			MethodName: "StopRelay",
			Handler:    _ForemanServer_StopRelay_Handler,
		},
		{
			MethodName: "DeleteRelay",
			Handler:    _ForemanServer_DeleteRelay_Handler,
		},
		{
			MethodName: "GetTunnel",
			Handler:    _ForemanServer_GetTunnel_Handler,
		},
		{
			MethodName: "GetAllTunnels",
			Handler:    _ForemanServer_GetAllTunnels_Handler,
		},
		{
			MethodName: "CreateTunnel",
			Handler:    _ForemanServer_CreateTunnel_Handler,
		},
		{
			MethodName: "StopTunnel",
			Handler:    _ForemanServer_StopTunnel_Handler,
		},
		{
			MethodName: "ResumeTunnel",
			Handler:    _ForemanServer_ResumeTunnel_Handler,
		},
		{
			MethodName: "UpdateTunnel",
			Handler:    _ForemanServer_UpdateTunnel_Handler,
		},
		{
			MethodName: "DeleteTunnel",
			Handler:    _ForemanServer_DeleteTunnel_Handler,
		},
		{
			MethodName: "GetServerOptions",
			Handler:    _ForemanServer_GetServerOptions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ps_foreman_server.proto",
}

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

View Source 
var PlumberServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protos.PlumberServer",
	HandlerType: (*PlumberServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetAllConnections",
			Handler:    _PlumberServer_GetAllConnections_Handler,
		},
		{
			MethodName: "GetConnection",
			Handler:    _PlumberServer_GetConnection_Handler,
		},
		{
			MethodName: "CreateConnection",
			Handler:    _PlumberServer_CreateConnection_Handler,
		},
		{
			MethodName: "TestConnection",
			Handler:    _PlumberServer_TestConnection_Handler,
		},
		{
			MethodName: "UpdateConnection",
			Handler:    _PlumberServer_UpdateConnection_Handler,
		},
		{
			MethodName: "DeleteConnection",
			Handler:    _PlumberServer_DeleteConnection_Handler,
		},
		{
			MethodName: "GetAllRelays",
			Handler:    _PlumberServer_GetAllRelays_Handler,
		},
		{
			MethodName: "GetRelay",
			Handler:    _PlumberServer_GetRelay_Handler,
		},
		{
			MethodName: "CreateRelay",
			Handler:    _PlumberServer_CreateRelay_Handler,
		},
		{
			MethodName: "UpdateRelay",
			Handler:    _PlumberServer_UpdateRelay_Handler,
		},
		{
			MethodName: "ResumeRelay",
			Handler:    _PlumberServer_ResumeRelay_Handler,
		},
		{
			MethodName: "StopRelay",
			Handler:    _PlumberServer_StopRelay_Handler,
		},
		{
			MethodName: "DeleteRelay",
			Handler:    _PlumberServer_DeleteRelay_Handler,
		},
		{
			MethodName: "GetTunnel",
			Handler:    _PlumberServer_GetTunnel_Handler,
		},
		{
			MethodName: "GetAllTunnels",
			Handler:    _PlumberServer_GetAllTunnels_Handler,
		},
		{
			MethodName: "CreateTunnel",
			Handler:    _PlumberServer_CreateTunnel_Handler,
		},
		{
			MethodName: "StopTunnel",
			Handler:    _PlumberServer_StopTunnel_Handler,
		},
		{
			MethodName: "ResumeTunnel",
			Handler:    _PlumberServer_ResumeTunnel_Handler,
		},
		{
			MethodName: "UpdateTunnel",
			Handler:    _PlumberServer_UpdateTunnel_Handler,
		},
		{
			MethodName: "DeleteTunnel",
			Handler:    _PlumberServer_DeleteTunnel_Handler,
		},
		{
			MethodName: "GetServerOptions",
			Handler:    _PlumberServer_GetServerOptions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "ps_base.proto",
}

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

Functions

func RegisterForemanClientServer added in v0.0.154 

func RegisterForemanClientServer(s grpc.ServiceRegistrar, srv ForemanClientServer)

func RegisterForemanServerServer added in v0.0.154 

func RegisterForemanServerServer(s grpc.ServiceRegistrar, srv ForemanServerServer)

func RegisterPlumberServerServer 

func RegisterPlumberServerServer(s grpc.ServiceRegistrar, 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"`
	// contains filtered or unexported fields
}

func (*CreateConnectionRequest) Descriptor deprecated 

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

Deprecated: Use CreateConnectionRequest.ProtoReflect.Descriptor instead.

func (*CreateConnectionRequest) GetAuth 

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

func (*CreateConnectionRequest) GetOptions added in v0.0.49 

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

func (*CreateConnectionRequest) ProtoMessage 

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) ProtoReflect added in v0.0.181 

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

func (*CreateConnectionRequest) Reset 

func (x *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String 

func (x *CreateConnectionRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateConnectionResponse) Descriptor deprecated 

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

Deprecated: Use CreateConnectionResponse.ProtoReflect.Descriptor instead.

func (*CreateConnectionResponse) GetConnectionId 

func (x *CreateConnectionResponse) GetConnectionId() string

func (*CreateConnectionResponse) ProtoMessage 

func (*CreateConnectionResponse) ProtoMessage()

func (*CreateConnectionResponse) ProtoReflect added in v0.0.181 

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

func (*CreateConnectionResponse) Reset 

func (x *CreateConnectionResponse) Reset()

func (*CreateConnectionResponse) String 

func (x *CreateConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateRelayRequest) Descriptor deprecated 

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

Deprecated: Use CreateRelayRequest.ProtoReflect.Descriptor instead.

func (*CreateRelayRequest) GetAuth 

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

func (*CreateRelayRequest) GetOpts added in v0.0.49 

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

func (*CreateRelayRequest) ProtoMessage 

func (*CreateRelayRequest) ProtoMessage()

func (*CreateRelayRequest) ProtoReflect added in v0.0.181 

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

func (*CreateRelayRequest) Reset 

func (x *CreateRelayRequest) Reset()

func (*CreateRelayRequest) String 

func (x *CreateRelayRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateRelayResponse) Descriptor deprecated 

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

Deprecated: Use CreateRelayResponse.ProtoReflect.Descriptor instead.

func (*CreateRelayResponse) GetRelayId 

func (x *CreateRelayResponse) GetRelayId() string

func (*CreateRelayResponse) GetStatus 

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

func (*CreateRelayResponse) ProtoMessage 

func (*CreateRelayResponse) ProtoMessage()

func (*CreateRelayResponse) ProtoReflect added in v0.0.181 

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

func (*CreateRelayResponse) Reset 

func (x *CreateRelayResponse) Reset()

func (*CreateRelayResponse) String 

func (x *CreateRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use CreateTunnelRequest.ProtoReflect.Descriptor instead.

func (*CreateTunnelRequest) GetAuth added in v0.0.142 

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

func (*CreateTunnelRequest) GetOpts added in v0.0.142 

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

func (*CreateTunnelRequest) ProtoMessage added in v0.0.142 

func (*CreateTunnelRequest) ProtoMessage()

func (*CreateTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*CreateTunnelRequest) Reset added in v0.0.142 

func (x *CreateTunnelRequest) Reset()

func (*CreateTunnelRequest) String added in v0.0.142 

func (x *CreateTunnelRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use CreateTunnelResponse.ProtoReflect.Descriptor instead.

func (*CreateTunnelResponse) GetStatus added in v0.0.142 

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

func (*CreateTunnelResponse) GetTunnelId added in v0.0.142 

func (x *CreateTunnelResponse) GetTunnelId() string

func (*CreateTunnelResponse) ProtoMessage added in v0.0.142 

func (*CreateTunnelResponse) ProtoMessage()

func (*CreateTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*CreateTunnelResponse) Reset added in v0.0.142 

func (x *CreateTunnelResponse) Reset()

func (*CreateTunnelResponse) String added in v0.0.142 

func (x *CreateTunnelResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteConnectionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteConnectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteConnectionRequest) GetAuth 

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

func (*DeleteConnectionRequest) GetConnectionId 

func (x *DeleteConnectionRequest) GetConnectionId() string

func (*DeleteConnectionRequest) ProtoMessage 

func (*DeleteConnectionRequest) ProtoMessage()

func (*DeleteConnectionRequest) ProtoReflect added in v0.0.181 

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

func (*DeleteConnectionRequest) Reset 

func (x *DeleteConnectionRequest) Reset()

func (*DeleteConnectionRequest) String 

func (x *DeleteConnectionRequest) String() string

type DeleteConnectionResponse 

type DeleteConnectionResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteConnectionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteConnectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteConnectionResponse) GetStatus 

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

func (*DeleteConnectionResponse) ProtoMessage 

func (*DeleteConnectionResponse) ProtoMessage()

func (*DeleteConnectionResponse) ProtoReflect added in v0.0.181 

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

func (*DeleteConnectionResponse) Reset 

func (x *DeleteConnectionResponse) Reset()

func (*DeleteConnectionResponse) String 

func (x *DeleteConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteRelayRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRelayRequest.ProtoReflect.Descriptor instead.

func (*DeleteRelayRequest) GetAuth 

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

func (*DeleteRelayRequest) GetRelayId 

func (x *DeleteRelayRequest) GetRelayId() string

func (*DeleteRelayRequest) ProtoMessage 

func (*DeleteRelayRequest) ProtoMessage()

func (*DeleteRelayRequest) ProtoReflect added in v0.0.181 

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

func (*DeleteRelayRequest) Reset 

func (x *DeleteRelayRequest) Reset()

func (*DeleteRelayRequest) String 

func (x *DeleteRelayRequest) String() string

type DeleteRelayResponse 

type DeleteRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRelayResponse) Descriptor deprecated 

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

Deprecated: Use DeleteRelayResponse.ProtoReflect.Descriptor instead.

func (*DeleteRelayResponse) GetStatus 

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

func (*DeleteRelayResponse) ProtoMessage 

func (*DeleteRelayResponse) ProtoMessage()

func (*DeleteRelayResponse) ProtoReflect added in v0.0.181 

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

func (*DeleteRelayResponse) Reset 

func (x *DeleteRelayResponse) Reset()

func (*DeleteRelayResponse) String 

func (x *DeleteRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use DeleteTunnelRequest.ProtoReflect.Descriptor instead.

func (*DeleteTunnelRequest) GetAuth added in v0.0.142 

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

func (*DeleteTunnelRequest) GetTunnelId added in v0.0.142 

func (x *DeleteTunnelRequest) GetTunnelId() string

func (*DeleteTunnelRequest) ProtoMessage added in v0.0.142 

func (*DeleteTunnelRequest) ProtoMessage()

func (*DeleteTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*DeleteTunnelRequest) Reset added in v0.0.142 

func (x *DeleteTunnelRequest) Reset()

func (*DeleteTunnelRequest) String added in v0.0.142 

func (x *DeleteTunnelRequest) String() string

type DeleteTunnelResponse added in v0.0.142 

type DeleteTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use DeleteTunnelResponse.ProtoReflect.Descriptor instead.

func (*DeleteTunnelResponse) GetStatus added in v0.0.142 

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

func (*DeleteTunnelResponse) ProtoMessage added in v0.0.142 

func (*DeleteTunnelResponse) ProtoMessage()

func (*DeleteTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*DeleteTunnelResponse) Reset added in v0.0.142 

func (x *DeleteTunnelResponse) Reset()

func (*DeleteTunnelResponse) String added in v0.0.142 

func (x *DeleteTunnelResponse) String() string

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 *ForemanRegisterRequest, opts ...grpc.CallOption) (*ForemanRegisterResponse, error)
}

ForemanClientClient is the client API for ForemanClient service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewForemanClientClient added in v0.0.154 

func NewForemanClientClient(cc grpc.ClientConnInterface) 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, *ForemanRegisterRequest) (*ForemanRegisterResponse, error)
}

ForemanClientServer is the server API for ForemanClient service. All implementations should embed UnimplementedForemanClientServer for forward compatibility

type ForemanRegisterRequest added in v0.0.183 

type ForemanRegisterRequest struct {

	// API token obtained from https://console.streamdal.com/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"`
	// contains filtered or unexported fields
}

func (*ForemanRegisterRequest) Descriptor deprecated added in v0.0.183 

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

Deprecated: Use ForemanRegisterRequest.ProtoReflect.Descriptor instead.

func (*ForemanRegisterRequest) GetApiToken added in v0.0.183 

func (x *ForemanRegisterRequest) GetApiToken() string

func (*ForemanRegisterRequest) GetClusterId added in v0.0.183 

func (x *ForemanRegisterRequest) GetClusterId() string

func (*ForemanRegisterRequest) GetNodeId added in v0.0.183 

func (x *ForemanRegisterRequest) GetNodeId() string

func (*ForemanRegisterRequest) GetPlumberToken added in v0.0.183 

func (x *ForemanRegisterRequest) GetPlumberToken() string

func (*ForemanRegisterRequest) ProtoMessage added in v0.0.183 

func (*ForemanRegisterRequest) ProtoMessage()

func (*ForemanRegisterRequest) ProtoReflect added in v0.0.183 

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

func (*ForemanRegisterRequest) Reset added in v0.0.183 

func (x *ForemanRegisterRequest) Reset()

func (*ForemanRegisterRequest) String added in v0.0.183 

func (x *ForemanRegisterRequest) String() string

type ForemanRegisterResponse added in v0.0.183 

type ForemanRegisterResponse 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"`
	// contains filtered or unexported fields
}

func (*ForemanRegisterResponse) Descriptor deprecated added in v0.0.183 

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

Deprecated: Use ForemanRegisterResponse.ProtoReflect.Descriptor instead.

func (*ForemanRegisterResponse) GetMessage added in v0.0.183 

func (x *ForemanRegisterResponse) GetMessage() string

func (*ForemanRegisterResponse) GetSuccess added in v0.0.183 

func (x *ForemanRegisterResponse) GetSuccess() bool

func (*ForemanRegisterResponse) ProtoMessage added in v0.0.183 

func (*ForemanRegisterResponse) ProtoMessage()

func (*ForemanRegisterResponse) ProtoReflect added in v0.0.183 

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

func (*ForemanRegisterResponse) Reset added in v0.0.183 

func (x *ForemanRegisterResponse) Reset()

func (*ForemanRegisterResponse) String added in v0.0.183 

func (x *ForemanRegisterResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewForemanServerClient added in v0.0.154 

func NewForemanServerClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedForemanServerServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*GetAllConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use GetAllConnectionsRequest.ProtoReflect.Descriptor instead.

func (*GetAllConnectionsRequest) GetAuth 

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

func (*GetAllConnectionsRequest) ProtoMessage 

func (*GetAllConnectionsRequest) ProtoMessage()

func (*GetAllConnectionsRequest) ProtoReflect added in v0.0.181 

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

func (*GetAllConnectionsRequest) Reset 

func (x *GetAllConnectionsRequest) Reset()

func (*GetAllConnectionsRequest) String 

func (x *GetAllConnectionsRequest) String() string

type GetAllConnectionsResponse 

type GetAllConnectionsResponse struct {
	Options []*opts.ConnectionOptions `protobuf:"bytes,1,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAllConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use GetAllConnectionsResponse.ProtoReflect.Descriptor instead.

func (*GetAllConnectionsResponse) GetOptions added in v0.0.49 

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

func (*GetAllConnectionsResponse) ProtoMessage 

func (*GetAllConnectionsResponse) ProtoMessage()

func (*GetAllConnectionsResponse) ProtoReflect added in v0.0.181 

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

func (*GetAllConnectionsResponse) Reset 

func (x *GetAllConnectionsResponse) Reset()

func (*GetAllConnectionsResponse) String 

func (x *GetAllConnectionsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetAllRelaysRequest) Descriptor deprecated 

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

Deprecated: Use GetAllRelaysRequest.ProtoReflect.Descriptor instead.

func (*GetAllRelaysRequest) GetAuth 

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

func (*GetAllRelaysRequest) ProtoMessage 

func (*GetAllRelaysRequest) ProtoMessage()

func (*GetAllRelaysRequest) ProtoReflect added in v0.0.181 

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

func (*GetAllRelaysRequest) Reset 

func (x *GetAllRelaysRequest) Reset()

func (*GetAllRelaysRequest) String 

func (x *GetAllRelaysRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetAllRelaysResponse) Descriptor deprecated 

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

Deprecated: Use GetAllRelaysResponse.ProtoReflect.Descriptor instead.

func (*GetAllRelaysResponse) GetOpts added in v0.0.49 

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

func (*GetAllRelaysResponse) GetStatus 

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

func (*GetAllRelaysResponse) ProtoMessage 

func (*GetAllRelaysResponse) ProtoMessage()

func (*GetAllRelaysResponse) ProtoReflect added in v0.0.181 

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

func (*GetAllRelaysResponse) Reset 

func (x *GetAllRelaysResponse) Reset()

func (*GetAllRelaysResponse) String 

func (x *GetAllRelaysResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetAllTunnelsRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use GetAllTunnelsRequest.ProtoReflect.Descriptor instead.

func (*GetAllTunnelsRequest) GetAuth added in v0.0.142 

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

func (*GetAllTunnelsRequest) ProtoMessage added in v0.0.142 

func (*GetAllTunnelsRequest) ProtoMessage()

func (*GetAllTunnelsRequest) ProtoReflect added in v0.0.181 

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

func (*GetAllTunnelsRequest) Reset added in v0.0.142 

func (x *GetAllTunnelsRequest) Reset()

func (*GetAllTunnelsRequest) String added in v0.0.142 

func (x *GetAllTunnelsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetAllTunnelsResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use GetAllTunnelsResponse.ProtoReflect.Descriptor instead.

func (*GetAllTunnelsResponse) GetOpts added in v0.0.142 

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

func (*GetAllTunnelsResponse) GetStatus added in v0.0.142 

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

func (*GetAllTunnelsResponse) ProtoMessage added in v0.0.142 

func (*GetAllTunnelsResponse) ProtoMessage()

func (*GetAllTunnelsResponse) ProtoReflect added in v0.0.181 

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

func (*GetAllTunnelsResponse) Reset added in v0.0.142 

func (x *GetAllTunnelsResponse) Reset()

func (*GetAllTunnelsResponse) String added in v0.0.142 

func (x *GetAllTunnelsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetConnectionRequest) Descriptor deprecated 

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

Deprecated: Use GetConnectionRequest.ProtoReflect.Descriptor instead.

func (*GetConnectionRequest) GetAuth 

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

func (*GetConnectionRequest) GetConnectionId 

func (x *GetConnectionRequest) GetConnectionId() string

func (*GetConnectionRequest) ProtoMessage 

func (*GetConnectionRequest) ProtoMessage()

func (*GetConnectionRequest) ProtoReflect added in v0.0.181 

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

func (*GetConnectionRequest) Reset 

func (x *GetConnectionRequest) Reset()

func (*GetConnectionRequest) String 

func (x *GetConnectionRequest) String() string

type GetConnectionResponse 

type GetConnectionResponse struct {
	Options *opts.ConnectionOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConnectionResponse) Descriptor deprecated 

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

Deprecated: Use GetConnectionResponse.ProtoReflect.Descriptor instead.

func (*GetConnectionResponse) GetOptions added in v0.0.49 

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

func (*GetConnectionResponse) ProtoMessage 

func (*GetConnectionResponse) ProtoMessage()

func (*GetConnectionResponse) ProtoReflect added in v0.0.181 

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

func (*GetConnectionResponse) Reset 

func (x *GetConnectionResponse) Reset()

func (*GetConnectionResponse) String 

func (x *GetConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetRelayRequest) Descriptor deprecated 

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

Deprecated: Use GetRelayRequest.ProtoReflect.Descriptor instead.

func (*GetRelayRequest) GetAuth 

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

func (*GetRelayRequest) GetRelayId 

func (x *GetRelayRequest) GetRelayId() string

func (*GetRelayRequest) ProtoMessage 

func (*GetRelayRequest) ProtoMessage()

func (*GetRelayRequest) ProtoReflect added in v0.0.181 

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

func (*GetRelayRequest) Reset 

func (x *GetRelayRequest) Reset()

func (*GetRelayRequest) String 

func (x *GetRelayRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetRelayResponse) Descriptor deprecated 

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

Deprecated: Use GetRelayResponse.ProtoReflect.Descriptor instead.

func (*GetRelayResponse) GetOpts added in v0.0.49 

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

func (*GetRelayResponse) GetStatus 

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

func (*GetRelayResponse) ProtoMessage 

func (*GetRelayResponse) ProtoMessage()

func (*GetRelayResponse) ProtoReflect added in v0.0.181 

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

func (*GetRelayResponse) Reset 

func (x *GetRelayResponse) Reset()

func (*GetRelayResponse) String 

func (x *GetRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetServerOptionsRequest) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use GetServerOptionsRequest.ProtoReflect.Descriptor instead.

func (*GetServerOptionsRequest) GetAuth added in v0.0.49 

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

func (*GetServerOptionsRequest) ProtoMessage added in v0.0.49 

func (*GetServerOptionsRequest) ProtoMessage()

func (*GetServerOptionsRequest) ProtoReflect added in v0.0.181 

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

func (*GetServerOptionsRequest) Reset added in v0.0.49 

func (x *GetServerOptionsRequest) Reset()

func (*GetServerOptionsRequest) String added in v0.0.49 

func (x *GetServerOptionsRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetServerOptionsResponse) Descriptor deprecated added in v0.0.49 

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

Deprecated: Use GetServerOptionsResponse.ProtoReflect.Descriptor instead.

func (*GetServerOptionsResponse) GetServerOptions added in v0.0.49 

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

func (*GetServerOptionsResponse) ProtoMessage added in v0.0.49 

func (*GetServerOptionsResponse) ProtoMessage()

func (*GetServerOptionsResponse) ProtoReflect added in v0.0.181 

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

func (*GetServerOptionsResponse) Reset added in v0.0.49 

func (x *GetServerOptionsResponse) Reset()

func (*GetServerOptionsResponse) String added in v0.0.49 

func (x *GetServerOptionsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use GetTunnelRequest.ProtoReflect.Descriptor instead.

func (*GetTunnelRequest) GetAuth added in v0.0.142 

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

func (*GetTunnelRequest) GetTunnelId added in v0.0.142 

func (x *GetTunnelRequest) GetTunnelId() string

func (*GetTunnelRequest) ProtoMessage added in v0.0.142 

func (*GetTunnelRequest) ProtoMessage()

func (*GetTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*GetTunnelRequest) Reset added in v0.0.142 

func (x *GetTunnelRequest) Reset()

func (*GetTunnelRequest) String added in v0.0.142 

func (x *GetTunnelRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use GetTunnelResponse.ProtoReflect.Descriptor instead.

func (*GetTunnelResponse) GetOpts added in v0.0.142 

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

func (*GetTunnelResponse) GetStatus added in v0.0.142 

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

func (*GetTunnelResponse) ProtoMessage added in v0.0.142 

func (*GetTunnelResponse) ProtoMessage()

func (*GetTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*GetTunnelResponse) Reset added in v0.0.142 

func (x *GetTunnelResponse) Reset()

func (*GetTunnelResponse) String added in v0.0.142 

func (x *GetTunnelResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListPlumbersRequest) Descriptor deprecated added in v0.0.154 

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

Deprecated: Use ListPlumbersRequest.ProtoReflect.Descriptor instead.

func (*ListPlumbersRequest) GetAuthToken added in v0.0.154 

func (x *ListPlumbersRequest) GetAuthToken() string

func (*ListPlumbersRequest) GetTeamId added in v0.0.154 

func (x *ListPlumbersRequest) GetTeamId() string

func (*ListPlumbersRequest) ProtoMessage added in v0.0.154 

func (*ListPlumbersRequest) ProtoMessage()

func (*ListPlumbersRequest) ProtoReflect added in v0.0.181 

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

func (*ListPlumbersRequest) Reset added in v0.0.154 

func (x *ListPlumbersRequest) Reset()

func (*ListPlumbersRequest) String added in v0.0.154 

func (x *ListPlumbersRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListPlumbersResponse) Descriptor deprecated added in v0.0.154 

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

Deprecated: Use ListPlumbersResponse.ProtoReflect.Descriptor instead.

func (*ListPlumbersResponse) GetPlumbers added in v0.0.154 

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

func (*ListPlumbersResponse) ProtoMessage added in v0.0.154 

func (*ListPlumbersResponse) ProtoMessage()

func (*ListPlumbersResponse) ProtoReflect added in v0.0.181 

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

func (*ListPlumbersResponse) Reset added in v0.0.154 

func (x *ListPlumbersResponse) Reset()

func (*ListPlumbersResponse) String added in v0.0.154 

func (x *ListPlumbersResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*PlumberInfo) Descriptor deprecated added in v0.0.154 

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

Deprecated: Use PlumberInfo.ProtoReflect.Descriptor instead.

func (*PlumberInfo) GetClusterId added in v0.0.154 

func (x *PlumberInfo) GetClusterId() string

func (*PlumberInfo) GetTeamId added in v0.0.154 

func (x *PlumberInfo) GetTeamId() string

func (*PlumberInfo) ProtoMessage added in v0.0.154 

func (*PlumberInfo) ProtoMessage()

func (*PlumberInfo) ProtoReflect added in v0.0.181 

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

func (*PlumberInfo) Reset added in v0.0.154 

func (x *PlumberInfo) Reset()

func (*PlumberInfo) String added in v0.0.154 

func (x *PlumberInfo) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPlumberServerClient 

func NewPlumberServerClient(cc grpc.ClientConnInterface) 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. All implementations should embed UnimplementedPlumberServerServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

Resume a paused relay

func (*ResumeRelayRequest) Descriptor deprecated added in v0.0.16 

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

Deprecated: Use ResumeRelayRequest.ProtoReflect.Descriptor instead.

func (*ResumeRelayRequest) GetAuth added in v0.0.16 

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

func (*ResumeRelayRequest) GetRelayId added in v0.0.16 

func (x *ResumeRelayRequest) GetRelayId() string

func (*ResumeRelayRequest) ProtoMessage added in v0.0.16 

func (*ResumeRelayRequest) ProtoMessage()

func (*ResumeRelayRequest) ProtoReflect added in v0.0.181 

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

func (*ResumeRelayRequest) Reset added in v0.0.16 

func (x *ResumeRelayRequest) Reset()

func (*ResumeRelayRequest) String added in v0.0.16 

func (x *ResumeRelayRequest) String() string

type ResumeRelayResponse added in v0.0.16 

type ResumeRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeRelayResponse) Descriptor deprecated added in v0.0.16 

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

Deprecated: Use ResumeRelayResponse.ProtoReflect.Descriptor instead.

func (*ResumeRelayResponse) GetStatus added in v0.0.16 

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

func (*ResumeRelayResponse) ProtoMessage added in v0.0.16 

func (*ResumeRelayResponse) ProtoMessage()

func (*ResumeRelayResponse) ProtoReflect added in v0.0.181 

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

func (*ResumeRelayResponse) Reset added in v0.0.16 

func (x *ResumeRelayResponse) Reset()

func (*ResumeRelayResponse) String added in v0.0.16 

func (x *ResumeRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

Resume a paused relay

func (*ResumeTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use ResumeTunnelRequest.ProtoReflect.Descriptor instead.

func (*ResumeTunnelRequest) GetAuth added in v0.0.142 

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

func (*ResumeTunnelRequest) GetTunnelId added in v0.0.142 

func (x *ResumeTunnelRequest) GetTunnelId() string

func (*ResumeTunnelRequest) ProtoMessage added in v0.0.142 

func (*ResumeTunnelRequest) ProtoMessage()

func (*ResumeTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*ResumeTunnelRequest) Reset added in v0.0.142 

func (x *ResumeTunnelRequest) Reset()

func (*ResumeTunnelRequest) String added in v0.0.142 

func (x *ResumeTunnelRequest) String() string

type ResumeTunnelResponse added in v0.0.142 

type ResumeTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use ResumeTunnelResponse.ProtoReflect.Descriptor instead.

func (*ResumeTunnelResponse) GetStatus added in v0.0.142 

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

func (*ResumeTunnelResponse) ProtoMessage added in v0.0.142 

func (*ResumeTunnelResponse) ProtoMessage()

func (*ResumeTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*ResumeTunnelResponse) Reset added in v0.0.142 

func (x *ResumeTunnelResponse) Reset()

func (*ResumeTunnelResponse) String added in v0.0.142 

func (x *ResumeTunnelResponse) String() string

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"`
	// contains filtered or unexported fields
}

Temporarily stop/pause a relay

func (*StopRelayRequest) Descriptor deprecated 

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

Deprecated: Use StopRelayRequest.ProtoReflect.Descriptor instead.

func (*StopRelayRequest) GetAuth 

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

func (*StopRelayRequest) GetRelayId 

func (x *StopRelayRequest) GetRelayId() string

func (*StopRelayRequest) ProtoMessage 

func (*StopRelayRequest) ProtoMessage()

func (*StopRelayRequest) ProtoReflect added in v0.0.181 

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

func (*StopRelayRequest) Reset 

func (x *StopRelayRequest) Reset()

func (*StopRelayRequest) String 

func (x *StopRelayRequest) String() string

type StopRelayResponse 

type StopRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRelayResponse) Descriptor deprecated 

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

Deprecated: Use StopRelayResponse.ProtoReflect.Descriptor instead.

func (*StopRelayResponse) GetStatus 

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

func (*StopRelayResponse) ProtoMessage 

func (*StopRelayResponse) ProtoMessage()

func (*StopRelayResponse) ProtoReflect added in v0.0.181 

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

func (*StopRelayResponse) Reset 

func (x *StopRelayResponse) Reset()

func (*StopRelayResponse) String 

func (x *StopRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

Temporarily stop/pause a relay

func (*StopTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use StopTunnelRequest.ProtoReflect.Descriptor instead.

func (*StopTunnelRequest) GetAuth added in v0.0.142 

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

func (*StopTunnelRequest) GetTunnelId added in v0.0.142 

func (x *StopTunnelRequest) GetTunnelId() string

func (*StopTunnelRequest) ProtoMessage added in v0.0.142 

func (*StopTunnelRequest) ProtoMessage()

func (*StopTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*StopTunnelRequest) Reset added in v0.0.142 

func (x *StopTunnelRequest) Reset()

func (*StopTunnelRequest) String added in v0.0.142 

func (x *StopTunnelRequest) String() string

type StopTunnelResponse added in v0.0.142 

type StopTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use StopTunnelResponse.ProtoReflect.Descriptor instead.

func (*StopTunnelResponse) GetStatus added in v0.0.142 

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

func (*StopTunnelResponse) ProtoMessage added in v0.0.142 

func (*StopTunnelResponse) ProtoMessage()

func (*StopTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*StopTunnelResponse) Reset added in v0.0.142 

func (x *StopTunnelResponse) Reset()

func (*StopTunnelResponse) String added in v0.0.142 

func (x *StopTunnelResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*TestConnectionRequest) Descriptor deprecated 

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

Deprecated: Use TestConnectionRequest.ProtoReflect.Descriptor instead.

func (*TestConnectionRequest) GetAuth 

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

func (*TestConnectionRequest) GetOptions added in v0.0.49 

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

func (*TestConnectionRequest) ProtoMessage 

func (*TestConnectionRequest) ProtoMessage()

func (*TestConnectionRequest) ProtoReflect added in v0.0.181 

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

func (*TestConnectionRequest) Reset 

func (x *TestConnectionRequest) Reset()

func (*TestConnectionRequest) String 

func (x *TestConnectionRequest) String() string

type TestConnectionResponse 

type TestConnectionResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TestConnectionResponse) Descriptor deprecated 

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

Deprecated: Use TestConnectionResponse.ProtoReflect.Descriptor instead.

func (*TestConnectionResponse) GetStatus 

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

func (*TestConnectionResponse) ProtoMessage 

func (*TestConnectionResponse) ProtoMessage()

func (*TestConnectionResponse) ProtoReflect added in v0.0.181 

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

func (*TestConnectionResponse) Reset 

func (x *TestConnectionResponse) Reset()

func (*TestConnectionResponse) String 

func (x *TestConnectionResponse) String() string

type UnimplementedForemanClientServer added in v0.0.154 

type UnimplementedForemanClientServer struct {
}

UnimplementedForemanClientServer should be embedded to have forward compatible implementations.

func (UnimplementedForemanClientServer) Register added in v0.0.154 

func (UnimplementedForemanClientServer) Register(context.Context, *ForemanRegisterRequest) (*ForemanRegisterResponse, error)

type UnimplementedForemanServerServer added in v0.0.154 

type UnimplementedForemanServerServer struct {
}

UnimplementedForemanServerServer should be embedded to have forward compatible implementations.

func (UnimplementedForemanServerServer) CreateConnection added in v0.0.154 

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

func (UnimplementedForemanServerServer) CreateRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) CreateTunnel added in v0.0.154 

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

func (UnimplementedForemanServerServer) DeleteConnection added in v0.0.154 

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

func (UnimplementedForemanServerServer) DeleteRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) DeleteTunnel added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetAllConnections added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetAllRelays added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetAllTunnels added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetConnection added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetServerOptions added in v0.0.154 

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

func (UnimplementedForemanServerServer) GetTunnel added in v0.0.154 

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

func (UnimplementedForemanServerServer) ListPlumbers added in v0.0.154 

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

func (UnimplementedForemanServerServer) ResumeRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) ResumeTunnel added in v0.0.154 

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

func (UnimplementedForemanServerServer) StopRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) StopTunnel added in v0.0.154 

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

func (UnimplementedForemanServerServer) TestConnection added in v0.0.154 

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

func (UnimplementedForemanServerServer) UpdateConnection added in v0.0.154 

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

func (UnimplementedForemanServerServer) UpdateRelay added in v0.0.154 

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

func (UnimplementedForemanServerServer) UpdateTunnel added in v0.0.154 

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

type UnimplementedPlumberServerServer 

type UnimplementedPlumberServerServer struct {
}

UnimplementedPlumberServerServer should be embedded to have forward compatible implementations.

func (UnimplementedPlumberServerServer) CreateConnection 

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

func (UnimplementedPlumberServerServer) CreateRelay 

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

func (UnimplementedPlumberServerServer) CreateTunnel added in v0.0.142 

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

func (UnimplementedPlumberServerServer) DeleteConnection 

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

func (UnimplementedPlumberServerServer) DeleteRelay 

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

func (UnimplementedPlumberServerServer) DeleteTunnel added in v0.0.142 

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

func (UnimplementedPlumberServerServer) GetAllConnections 

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

func (UnimplementedPlumberServerServer) GetAllRelays added in v0.0.17 

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

func (UnimplementedPlumberServerServer) GetAllTunnels added in v0.0.142 

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

func (UnimplementedPlumberServerServer) GetConnection added in v0.0.3 

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

func (UnimplementedPlumberServerServer) GetRelay added in v0.0.130 

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

func (UnimplementedPlumberServerServer) GetServerOptions added in v0.0.49 

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

func (UnimplementedPlumberServerServer) GetTunnel added in v0.0.142 

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

func (UnimplementedPlumberServerServer) ResumeRelay added in v0.0.16 

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

func (UnimplementedPlumberServerServer) ResumeTunnel added in v0.0.142 

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

func (UnimplementedPlumberServerServer) StopRelay 

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

func (UnimplementedPlumberServerServer) StopTunnel added in v0.0.142 

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

func (UnimplementedPlumberServerServer) TestConnection 

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

func (UnimplementedPlumberServerServer) UpdateConnection 

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

func (UnimplementedPlumberServerServer) UpdateRelay 

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

func (UnimplementedPlumberServerServer) UpdateTunnel added in v0.0.142 

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

type UnsafeForemanClientServer added in v0.0.181 

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

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

type UnsafeForemanServerServer added in v0.0.181 

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

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

type UnsafePlumberServerServer added in v0.0.181 

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

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

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"`
	// contains filtered or unexported fields
}

func (*UpdateConnectionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionRequest.ProtoReflect.Descriptor instead.

func (*UpdateConnectionRequest) GetAuth 

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

func (*UpdateConnectionRequest) GetConnectionId 

func (x *UpdateConnectionRequest) GetConnectionId() string

func (*UpdateConnectionRequest) GetOptions added in v0.0.49 

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

func (*UpdateConnectionRequest) ProtoMessage 

func (*UpdateConnectionRequest) ProtoMessage()

func (*UpdateConnectionRequest) ProtoReflect added in v0.0.181 

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

func (*UpdateConnectionRequest) Reset 

func (x *UpdateConnectionRequest) Reset()

func (*UpdateConnectionRequest) String 

func (x *UpdateConnectionRequest) String() string

type UpdateConnectionResponse 

type UpdateConnectionResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConnectionResponse) Descriptor deprecated 

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

Deprecated: Use UpdateConnectionResponse.ProtoReflect.Descriptor instead.

func (*UpdateConnectionResponse) GetStatus 

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

func (*UpdateConnectionResponse) ProtoMessage 

func (*UpdateConnectionResponse) ProtoMessage()

func (*UpdateConnectionResponse) ProtoReflect added in v0.0.181 

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

func (*UpdateConnectionResponse) Reset 

func (x *UpdateConnectionResponse) Reset()

func (*UpdateConnectionResponse) String 

func (x *UpdateConnectionResponse) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*UpdateRelayRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRelayRequest.ProtoReflect.Descriptor instead.

func (*UpdateRelayRequest) GetAuth 

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

func (*UpdateRelayRequest) GetOpts added in v0.0.49 

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

func (*UpdateRelayRequest) GetRelayId 

func (x *UpdateRelayRequest) GetRelayId() string

func (*UpdateRelayRequest) ProtoMessage 

func (*UpdateRelayRequest) ProtoMessage()

func (*UpdateRelayRequest) ProtoReflect added in v0.0.181 

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

func (*UpdateRelayRequest) Reset 

func (x *UpdateRelayRequest) Reset()

func (*UpdateRelayRequest) String 

func (x *UpdateRelayRequest) String() string

type UpdateRelayResponse 

type UpdateRelayResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRelayResponse) Descriptor deprecated 

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

Deprecated: Use UpdateRelayResponse.ProtoReflect.Descriptor instead.

func (*UpdateRelayResponse) GetStatus 

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

func (*UpdateRelayResponse) ProtoMessage 

func (*UpdateRelayResponse) ProtoMessage()

func (*UpdateRelayResponse) ProtoReflect added in v0.0.181 

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

func (*UpdateRelayResponse) Reset 

func (x *UpdateRelayResponse) Reset()

func (*UpdateRelayResponse) String 

func (x *UpdateRelayResponse) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*UpdateTunnelRequest) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use UpdateTunnelRequest.ProtoReflect.Descriptor instead.

func (*UpdateTunnelRequest) GetAuth added in v0.0.142 

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

func (*UpdateTunnelRequest) GetOpts added in v0.0.142 

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

func (*UpdateTunnelRequest) GetTunnelId added in v0.0.142 

func (x *UpdateTunnelRequest) GetTunnelId() string

func (*UpdateTunnelRequest) ProtoMessage added in v0.0.142 

func (*UpdateTunnelRequest) ProtoMessage()

func (*UpdateTunnelRequest) ProtoReflect added in v0.0.181 

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

func (*UpdateTunnelRequest) Reset added in v0.0.142 

func (x *UpdateTunnelRequest) Reset()

func (*UpdateTunnelRequest) String added in v0.0.142 

func (x *UpdateTunnelRequest) String() string

type UpdateTunnelResponse added in v0.0.142 

type UpdateTunnelResponse struct {
	Status *common.Status `protobuf:"bytes,1000,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTunnelResponse) Descriptor deprecated added in v0.0.142 

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

Deprecated: Use UpdateTunnelResponse.ProtoReflect.Descriptor instead.

func (*UpdateTunnelResponse) GetStatus added in v0.0.142 

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

func (*UpdateTunnelResponse) ProtoMessage added in v0.0.142 

func (*UpdateTunnelResponse) ProtoMessage()

func (*UpdateTunnelResponse) ProtoReflect added in v0.0.181 

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

func (*UpdateTunnelResponse) Reset added in v0.0.142 

func (x *UpdateTunnelResponse) Reset()

func (*UpdateTunnelResponse) String added in v0.0.142 

func (x *UpdateTunnelResponse) String() string

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.