Documentation
¶
Index ¶
- func RegisterForwardingServer(s *grpc.Server, srv ForwardingServer)
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)
- func (m *CreateRequest) GetResponse() string
- func (m *CreateRequest) GetSpecification() *CreationSpecification
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) String() string
- func (m *CreateRequest) XXX_DiscardUnknown()
- func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateRequest) XXX_Merge(src proto.Message)
- func (m *CreateRequest) XXX_Size() int
- func (m *CreateRequest) XXX_Unmarshal(b []byte) error
- type CreateResponse
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (r *CreateResponse) EnsureValid() error
- func (m *CreateResponse) GetMessage() string
- func (m *CreateResponse) GetPrompt() string
- func (m *CreateResponse) GetSession() string
- func (*CreateResponse) ProtoMessage()
- func (m *CreateResponse) Reset()
- func (m *CreateResponse) String() string
- func (m *CreateResponse) XXX_DiscardUnknown()
- func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateResponse) XXX_Merge(src proto.Message)
- func (m *CreateResponse) XXX_Size() int
- func (m *CreateResponse) XXX_Unmarshal(b []byte) error
- type CreationSpecification
- func (*CreationSpecification) Descriptor() ([]byte, []int)
- func (m *CreationSpecification) GetConfiguration() *forwarding.Configuration
- func (m *CreationSpecification) GetConfigurationDestination() *forwarding.Configuration
- func (m *CreationSpecification) GetConfigurationSource() *forwarding.Configuration
- func (m *CreationSpecification) GetDestination() *url.URL
- func (m *CreationSpecification) GetLabels() map[string]string
- func (m *CreationSpecification) GetName() string
- func (m *CreationSpecification) GetPaused() bool
- func (m *CreationSpecification) GetSource() *url.URL
- func (*CreationSpecification) ProtoMessage()
- func (m *CreationSpecification) Reset()
- func (m *CreationSpecification) String() string
- func (m *CreationSpecification) XXX_DiscardUnknown()
- func (m *CreationSpecification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreationSpecification) XXX_Merge(src proto.Message)
- func (m *CreationSpecification) XXX_Size() int
- func (m *CreationSpecification) XXX_Unmarshal(b []byte) error
- type ForwardingClient
- type ForwardingServer
- type Forwarding_CreateClient
- type Forwarding_CreateServer
- type Forwarding_PauseClient
- type Forwarding_PauseServer
- type Forwarding_ResumeClient
- type Forwarding_ResumeServer
- type Forwarding_TerminateClient
- type Forwarding_TerminateServer
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetPreviousStateIndex() uint64
- func (m *ListRequest) GetSelection() *selection.Selection
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)
- func (r *ListResponse) EnsureValid() error
- func (m *ListResponse) GetSessionStates() []*forwarding.State
- func (m *ListResponse) GetStateIndex() uint64
- func (*ListResponse) ProtoMessage()
- func (m *ListResponse) Reset()
- func (m *ListResponse) String() string
- func (m *ListResponse) XXX_DiscardUnknown()
- func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListResponse) XXX_Merge(src proto.Message)
- func (m *ListResponse) XXX_Size() int
- func (m *ListResponse) XXX_Unmarshal(b []byte) error
- type PauseRequest
- func (*PauseRequest) Descriptor() ([]byte, []int)
- func (m *PauseRequest) GetSelection() *selection.Selection
- func (*PauseRequest) ProtoMessage()
- func (m *PauseRequest) Reset()
- func (m *PauseRequest) String() string
- func (m *PauseRequest) XXX_DiscardUnknown()
- func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PauseRequest) XXX_Merge(src proto.Message)
- func (m *PauseRequest) XXX_Size() int
- func (m *PauseRequest) XXX_Unmarshal(b []byte) error
- type PauseResponse
- func (*PauseResponse) Descriptor() ([]byte, []int)
- func (r *PauseResponse) EnsureValid() error
- func (m *PauseResponse) GetMessage() string
- func (*PauseResponse) ProtoMessage()
- func (m *PauseResponse) Reset()
- func (m *PauseResponse) String() string
- func (m *PauseResponse) XXX_DiscardUnknown()
- func (m *PauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PauseResponse) XXX_Merge(src proto.Message)
- func (m *PauseResponse) XXX_Size() int
- func (m *PauseResponse) XXX_Unmarshal(b []byte) error
- type ResumeRequest
- func (*ResumeRequest) Descriptor() ([]byte, []int)
- func (m *ResumeRequest) GetResponse() string
- func (m *ResumeRequest) GetSelection() *selection.Selection
- func (*ResumeRequest) ProtoMessage()
- func (m *ResumeRequest) Reset()
- func (m *ResumeRequest) String() string
- func (m *ResumeRequest) XXX_DiscardUnknown()
- func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResumeRequest) XXX_Merge(src proto.Message)
- func (m *ResumeRequest) XXX_Size() int
- func (m *ResumeRequest) XXX_Unmarshal(b []byte) error
- type ResumeResponse
- func (*ResumeResponse) Descriptor() ([]byte, []int)
- func (r *ResumeResponse) EnsureValid() error
- func (m *ResumeResponse) GetMessage() string
- func (m *ResumeResponse) GetPrompt() string
- func (*ResumeResponse) ProtoMessage()
- func (m *ResumeResponse) Reset()
- func (m *ResumeResponse) String() string
- func (m *ResumeResponse) XXX_DiscardUnknown()
- func (m *ResumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResumeResponse) XXX_Merge(src proto.Message)
- func (m *ResumeResponse) XXX_Size() int
- func (m *ResumeResponse) XXX_Unmarshal(b []byte) error
- type Server
- func (s *Server) Create(stream Forwarding_CreateServer) error
- func (s *Server) List(_ context.Context, request *ListRequest) (*ListResponse, error)
- func (s *Server) Pause(stream Forwarding_PauseServer) error
- func (s *Server) Resume(stream Forwarding_ResumeServer) error
- func (s *Server) Terminate(stream Forwarding_TerminateServer) error
- type TerminateRequest
- func (*TerminateRequest) Descriptor() ([]byte, []int)
- func (m *TerminateRequest) GetSelection() *selection.Selection
- func (*TerminateRequest) ProtoMessage()
- func (m *TerminateRequest) Reset()
- func (m *TerminateRequest) String() string
- func (m *TerminateRequest) XXX_DiscardUnknown()
- func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TerminateRequest) XXX_Merge(src proto.Message)
- func (m *TerminateRequest) XXX_Size() int
- func (m *TerminateRequest) XXX_Unmarshal(b []byte) error
- type TerminateResponse
- func (*TerminateResponse) Descriptor() ([]byte, []int)
- func (r *TerminateResponse) EnsureValid() error
- func (m *TerminateResponse) GetMessage() string
- func (*TerminateResponse) ProtoMessage()
- func (m *TerminateResponse) Reset()
- func (m *TerminateResponse) String() string
- func (m *TerminateResponse) XXX_DiscardUnknown()
- func (m *TerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TerminateResponse) XXX_Merge(src proto.Message)
- func (m *TerminateResponse) XXX_Size() int
- func (m *TerminateResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedForwardingServer
- func (*UnimplementedForwardingServer) Create(srv Forwarding_CreateServer) error
- func (*UnimplementedForwardingServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)
- func (*UnimplementedForwardingServer) Pause(srv Forwarding_PauseServer) error
- func (*UnimplementedForwardingServer) Resume(srv Forwarding_ResumeServer) error
- func (*UnimplementedForwardingServer) Terminate(srv Forwarding_TerminateServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterForwardingServer ¶
func RegisterForwardingServer(s *grpc.Server, srv ForwardingServer)
Types ¶
type CreateRequest ¶
type CreateRequest struct { Specification *CreationSpecification `protobuf:"bytes,1,opt,name=specification,proto3" json:"specification,omitempty"` Response string `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetResponse ¶
func (m *CreateRequest) GetResponse() string
func (*CreateRequest) GetSpecification ¶
func (m *CreateRequest) GetSpecification() *CreationSpecification
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct { Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Prompt string `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) EnsureValid ¶
func (r *CreateResponse) EnsureValid() error
EnsureValid verifies that a CreateResponse is valid.
func (*CreateResponse) GetMessage ¶
func (m *CreateResponse) GetMessage() string
func (*CreateResponse) GetPrompt ¶
func (m *CreateResponse) GetPrompt() string
func (*CreateResponse) GetSession ¶
func (m *CreateResponse) GetSession() string
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type CreationSpecification ¶
type CreationSpecification struct { // Source is the source endpoint URL for the session. Source *url.URL `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // Destination is the destination endpoint URL for the session. Destination *url.URL `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"` // Configuration is the base session configuration. It is the result of // merging the global configuration (unless disabled), any manually // specified configuration file, and any command line configuration // parameters. Configuration *forwarding.Configuration `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"` // ConfigurationSource is the source-specific session configuration. It is // determined based on command line configuration parameters. ConfigurationSource *forwarding.Configuration `protobuf:"bytes,4,opt,name=configurationSource,proto3" json:"configurationSource,omitempty"` // ConfigurationDestination is the destination-specific session // configuration. It is determined based on command line configuration // parameters. ConfigurationDestination *forwarding.Configuration `protobuf:"bytes,5,opt,name=configurationDestination,proto3" json:"configurationDestination,omitempty"` // Name is the name for the session object. Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // Labels are the labels for the session object. Labels map[string]string `` /* 153-byte string literal not displayed */ // Paused indicates whether or not to create the session pre-paused. Paused bool `protobuf:"varint,8,opt,name=paused,proto3" json:"paused,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreationSpecification) Descriptor ¶
func (*CreationSpecification) Descriptor() ([]byte, []int)
func (*CreationSpecification) GetConfiguration ¶
func (m *CreationSpecification) GetConfiguration() *forwarding.Configuration
func (*CreationSpecification) GetConfigurationDestination ¶
func (m *CreationSpecification) GetConfigurationDestination() *forwarding.Configuration
func (*CreationSpecification) GetConfigurationSource ¶
func (m *CreationSpecification) GetConfigurationSource() *forwarding.Configuration
func (*CreationSpecification) GetDestination ¶
func (m *CreationSpecification) GetDestination() *url.URL
func (*CreationSpecification) GetLabels ¶
func (m *CreationSpecification) GetLabels() map[string]string
func (*CreationSpecification) GetName ¶
func (m *CreationSpecification) GetName() string
func (*CreationSpecification) GetPaused ¶
func (m *CreationSpecification) GetPaused() bool
func (*CreationSpecification) GetSource ¶
func (m *CreationSpecification) GetSource() *url.URL
func (*CreationSpecification) ProtoMessage ¶
func (*CreationSpecification) ProtoMessage()
func (*CreationSpecification) Reset ¶
func (m *CreationSpecification) Reset()
func (*CreationSpecification) String ¶
func (m *CreationSpecification) String() string
func (*CreationSpecification) XXX_DiscardUnknown ¶
func (m *CreationSpecification) XXX_DiscardUnknown()
func (*CreationSpecification) XXX_Marshal ¶
func (m *CreationSpecification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreationSpecification) XXX_Merge ¶
func (m *CreationSpecification) XXX_Merge(src proto.Message)
func (*CreationSpecification) XXX_Size ¶
func (m *CreationSpecification) XXX_Size() int
func (*CreationSpecification) XXX_Unmarshal ¶
func (m *CreationSpecification) XXX_Unmarshal(b []byte) error
type ForwardingClient ¶
type ForwardingClient interface { Create(ctx context.Context, opts ...grpc.CallOption) (Forwarding_CreateClient, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Pause(ctx context.Context, opts ...grpc.CallOption) (Forwarding_PauseClient, error) Resume(ctx context.Context, opts ...grpc.CallOption) (Forwarding_ResumeClient, error) Terminate(ctx context.Context, opts ...grpc.CallOption) (Forwarding_TerminateClient, error) }
ForwardingClient is the client API for Forwarding service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewForwardingClient ¶
func NewForwardingClient(cc *grpc.ClientConn) ForwardingClient
type ForwardingServer ¶
type ForwardingServer interface { Create(Forwarding_CreateServer) error List(context.Context, *ListRequest) (*ListResponse, error) Pause(Forwarding_PauseServer) error Resume(Forwarding_ResumeServer) error Terminate(Forwarding_TerminateServer) error }
ForwardingServer is the server API for Forwarding service.
type Forwarding_CreateClient ¶
type Forwarding_CreateClient interface { Send(*CreateRequest) error Recv() (*CreateResponse, error) grpc.ClientStream }
type Forwarding_CreateServer ¶
type Forwarding_CreateServer interface { Send(*CreateResponse) error Recv() (*CreateRequest, error) grpc.ServerStream }
type Forwarding_PauseClient ¶
type Forwarding_PauseClient interface { Send(*PauseRequest) error Recv() (*PauseResponse, error) grpc.ClientStream }
type Forwarding_PauseServer ¶
type Forwarding_PauseServer interface { Send(*PauseResponse) error Recv() (*PauseRequest, error) grpc.ServerStream }
type Forwarding_ResumeClient ¶
type Forwarding_ResumeClient interface { Send(*ResumeRequest) error Recv() (*ResumeResponse, error) grpc.ClientStream }
type Forwarding_ResumeServer ¶
type Forwarding_ResumeServer interface { Send(*ResumeResponse) error Recv() (*ResumeRequest, error) grpc.ServerStream }
type Forwarding_TerminateClient ¶
type Forwarding_TerminateClient interface { Send(*TerminateRequest) error Recv() (*TerminateResponse, error) grpc.ClientStream }
type Forwarding_TerminateServer ¶
type Forwarding_TerminateServer interface { Send(*TerminateResponse) error Recv() (*TerminateRequest, error) grpc.ServerStream }
type ListRequest ¶
type ListRequest struct { Selection *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"` PreviousStateIndex uint64 `protobuf:"varint,2,opt,name=previousStateIndex,proto3" json:"previousStateIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetPreviousStateIndex ¶
func (m *ListRequest) GetPreviousStateIndex() uint64
func (*ListRequest) GetSelection ¶
func (m *ListRequest) GetSelection() *selection.Selection
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type ListResponse ¶
type ListResponse struct { StateIndex uint64 `protobuf:"varint,1,opt,name=stateIndex,proto3" json:"stateIndex,omitempty"` SessionStates []*forwarding.State `protobuf:"bytes,2,rep,name=sessionStates,proto3" json:"sessionStates,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListResponse) Descriptor ¶
func (*ListResponse) Descriptor() ([]byte, []int)
func (*ListResponse) EnsureValid ¶
func (r *ListResponse) EnsureValid() error
ensureValid verifies that a ListResponse is valid.
func (*ListResponse) GetSessionStates ¶
func (m *ListResponse) GetSessionStates() []*forwarding.State
func (*ListResponse) GetStateIndex ¶
func (m *ListResponse) GetStateIndex() uint64
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) Reset ¶
func (m *ListResponse) Reset()
func (*ListResponse) String ¶
func (m *ListResponse) String() string
func (*ListResponse) XXX_DiscardUnknown ¶
func (m *ListResponse) XXX_DiscardUnknown()
func (*ListResponse) XXX_Marshal ¶
func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListResponse) XXX_Merge ¶
func (m *ListResponse) XXX_Merge(src proto.Message)
func (*ListResponse) XXX_Size ¶
func (m *ListResponse) XXX_Size() int
func (*ListResponse) XXX_Unmarshal ¶
func (m *ListResponse) XXX_Unmarshal(b []byte) error
type PauseRequest ¶
type PauseRequest struct { Selection *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PauseRequest) Descriptor ¶
func (*PauseRequest) Descriptor() ([]byte, []int)
func (*PauseRequest) GetSelection ¶
func (m *PauseRequest) GetSelection() *selection.Selection
func (*PauseRequest) ProtoMessage ¶
func (*PauseRequest) ProtoMessage()
func (*PauseRequest) Reset ¶
func (m *PauseRequest) Reset()
func (*PauseRequest) String ¶
func (m *PauseRequest) String() string
func (*PauseRequest) XXX_DiscardUnknown ¶
func (m *PauseRequest) XXX_DiscardUnknown()
func (*PauseRequest) XXX_Marshal ¶
func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseRequest) XXX_Merge ¶
func (m *PauseRequest) XXX_Merge(src proto.Message)
func (*PauseRequest) XXX_Size ¶
func (m *PauseRequest) XXX_Size() int
func (*PauseRequest) XXX_Unmarshal ¶
func (m *PauseRequest) XXX_Unmarshal(b []byte) error
type PauseResponse ¶
type PauseResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PauseResponse) Descriptor ¶
func (*PauseResponse) Descriptor() ([]byte, []int)
func (*PauseResponse) EnsureValid ¶
func (r *PauseResponse) EnsureValid() error
EnsureValid verifies that a PauseResponse is valid.
func (*PauseResponse) GetMessage ¶
func (m *PauseResponse) GetMessage() string
func (*PauseResponse) ProtoMessage ¶
func (*PauseResponse) ProtoMessage()
func (*PauseResponse) Reset ¶
func (m *PauseResponse) Reset()
func (*PauseResponse) String ¶
func (m *PauseResponse) String() string
func (*PauseResponse) XXX_DiscardUnknown ¶
func (m *PauseResponse) XXX_DiscardUnknown()
func (*PauseResponse) XXX_Marshal ¶
func (m *PauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PauseResponse) XXX_Merge ¶
func (m *PauseResponse) XXX_Merge(src proto.Message)
func (*PauseResponse) XXX_Size ¶
func (m *PauseResponse) XXX_Size() int
func (*PauseResponse) XXX_Unmarshal ¶
func (m *PauseResponse) XXX_Unmarshal(b []byte) error
type ResumeRequest ¶
type ResumeRequest struct { Selection *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"` Response string `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResumeRequest) Descriptor ¶
func (*ResumeRequest) Descriptor() ([]byte, []int)
func (*ResumeRequest) GetResponse ¶
func (m *ResumeRequest) GetResponse() string
func (*ResumeRequest) GetSelection ¶
func (m *ResumeRequest) GetSelection() *selection.Selection
func (*ResumeRequest) ProtoMessage ¶
func (*ResumeRequest) ProtoMessage()
func (*ResumeRequest) Reset ¶
func (m *ResumeRequest) Reset()
func (*ResumeRequest) String ¶
func (m *ResumeRequest) String() string
func (*ResumeRequest) XXX_DiscardUnknown ¶
func (m *ResumeRequest) XXX_DiscardUnknown()
func (*ResumeRequest) XXX_Marshal ¶
func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResumeRequest) XXX_Merge ¶
func (m *ResumeRequest) XXX_Merge(src proto.Message)
func (*ResumeRequest) XXX_Size ¶
func (m *ResumeRequest) XXX_Size() int
func (*ResumeRequest) XXX_Unmarshal ¶
func (m *ResumeRequest) XXX_Unmarshal(b []byte) error
type ResumeResponse ¶
type ResumeResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Prompt string `protobuf:"bytes,2,opt,name=prompt,proto3" json:"prompt,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResumeResponse) Descriptor ¶
func (*ResumeResponse) Descriptor() ([]byte, []int)
func (*ResumeResponse) EnsureValid ¶
func (r *ResumeResponse) EnsureValid() error
EnsureValid verifies that a ResumeResponse is valid.
func (*ResumeResponse) GetMessage ¶
func (m *ResumeResponse) GetMessage() string
func (*ResumeResponse) GetPrompt ¶
func (m *ResumeResponse) GetPrompt() string
func (*ResumeResponse) ProtoMessage ¶
func (*ResumeResponse) ProtoMessage()
func (*ResumeResponse) Reset ¶
func (m *ResumeResponse) Reset()
func (*ResumeResponse) String ¶
func (m *ResumeResponse) String() string
func (*ResumeResponse) XXX_DiscardUnknown ¶
func (m *ResumeResponse) XXX_DiscardUnknown()
func (*ResumeResponse) XXX_Marshal ¶
func (m *ResumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResumeResponse) XXX_Merge ¶
func (m *ResumeResponse) XXX_Merge(src proto.Message)
func (*ResumeResponse) XXX_Size ¶
func (m *ResumeResponse) XXX_Size() int
func (*ResumeResponse) XXX_Unmarshal ¶
func (m *ResumeResponse) XXX_Unmarshal(b []byte) error
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server provides an implementation of the Forwarding service.
func NewServer ¶
func NewServer(manager *forwarding.Manager) *Server
NewServer creates a new session server.
func (*Server) Create ¶
func (s *Server) Create(stream Forwarding_CreateServer) error
Create creates a new session.
func (*Server) List ¶
func (s *Server) List(_ context.Context, request *ListRequest) (*ListResponse, error)
List lists existing sessions.
func (*Server) Pause ¶
func (s *Server) Pause(stream Forwarding_PauseServer) error
Pause pauses existing sessions.
func (*Server) Resume ¶
func (s *Server) Resume(stream Forwarding_ResumeServer) error
Resume resumes existing sessions.
func (*Server) Terminate ¶
func (s *Server) Terminate(stream Forwarding_TerminateServer) error
Terminate terminates existing sessions.
type TerminateRequest ¶
type TerminateRequest struct { Selection *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TerminateRequest) Descriptor ¶
func (*TerminateRequest) Descriptor() ([]byte, []int)
func (*TerminateRequest) GetSelection ¶
func (m *TerminateRequest) GetSelection() *selection.Selection
func (*TerminateRequest) ProtoMessage ¶
func (*TerminateRequest) ProtoMessage()
func (*TerminateRequest) Reset ¶
func (m *TerminateRequest) Reset()
func (*TerminateRequest) String ¶
func (m *TerminateRequest) String() string
func (*TerminateRequest) XXX_DiscardUnknown ¶
func (m *TerminateRequest) XXX_DiscardUnknown()
func (*TerminateRequest) XXX_Marshal ¶
func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TerminateRequest) XXX_Merge ¶
func (m *TerminateRequest) XXX_Merge(src proto.Message)
func (*TerminateRequest) XXX_Size ¶
func (m *TerminateRequest) XXX_Size() int
func (*TerminateRequest) XXX_Unmarshal ¶
func (m *TerminateRequest) XXX_Unmarshal(b []byte) error
type TerminateResponse ¶
type TerminateResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TerminateResponse) Descriptor ¶
func (*TerminateResponse) Descriptor() ([]byte, []int)
func (*TerminateResponse) EnsureValid ¶
func (r *TerminateResponse) EnsureValid() error
EnsureValid verifies that a TerminateResponse is valid.
func (*TerminateResponse) GetMessage ¶
func (m *TerminateResponse) GetMessage() string
func (*TerminateResponse) ProtoMessage ¶
func (*TerminateResponse) ProtoMessage()
func (*TerminateResponse) Reset ¶
func (m *TerminateResponse) Reset()
func (*TerminateResponse) String ¶
func (m *TerminateResponse) String() string
func (*TerminateResponse) XXX_DiscardUnknown ¶
func (m *TerminateResponse) XXX_DiscardUnknown()
func (*TerminateResponse) XXX_Marshal ¶
func (m *TerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TerminateResponse) XXX_Merge ¶
func (m *TerminateResponse) XXX_Merge(src proto.Message)
func (*TerminateResponse) XXX_Size ¶
func (m *TerminateResponse) XXX_Size() int
func (*TerminateResponse) XXX_Unmarshal ¶
func (m *TerminateResponse) XXX_Unmarshal(b []byte) error
type UnimplementedForwardingServer ¶ added in v0.10.1
type UnimplementedForwardingServer struct { }
UnimplementedForwardingServer can be embedded to have forward compatible implementations.
func (*UnimplementedForwardingServer) Create ¶ added in v0.10.1
func (*UnimplementedForwardingServer) Create(srv Forwarding_CreateServer) error
func (*UnimplementedForwardingServer) List ¶ added in v0.10.1
func (*UnimplementedForwardingServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)
func (*UnimplementedForwardingServer) Pause ¶ added in v0.10.1
func (*UnimplementedForwardingServer) Pause(srv Forwarding_PauseServer) error
func (*UnimplementedForwardingServer) Resume ¶ added in v0.10.1
func (*UnimplementedForwardingServer) Resume(srv Forwarding_ResumeServer) error
func (*UnimplementedForwardingServer) Terminate ¶ added in v0.10.1
func (*UnimplementedForwardingServer) Terminate(srv Forwarding_TerminateServer) error