amp_control

Documentation

Index

• Constants
• Variables
• func RegisterServer(server *protocols.Server, handler Handler) error
• type Client
  • func NewClient(client protocols.Client) (*Client, error)
  • func NewClientFor(server_addr string) (*Client, error)
  • func (client *Client) RedirectStream(oldHost string, oldPort int, newHost string, newPort int) error
• type Handler
• type PauseStream
• type RedirectStream
• type ResumeStream

Constants

const (
	CodeRedirectStream = protocols.Code(17 + iota)
	CodePauseStream
	CodeResumeStream
)

Variables

var (
	Protocol     *ampControlProtocol
	MiniProtocol = protocols.NewMiniProtocol(Protocol)
)

Functions

func RegisterServer

func RegisterServer(server *protocols.Server, handler Handler) error

Types

type Client

type Client struct {
	protocols.Client
}

func NewClient

func NewClient(client protocols.Client) (*Client, error)

func NewClientFor

func NewClientFor(server_addr string) (*Client, error)

func (*Client) RedirectStream

func (client *Client) RedirectStream(oldHost string, oldPort int, newHost string, newPort int) error

type Handler

type Handler interface {
	StopServer()
	RedirectStream(val *RedirectStream) error
	PauseStream(val *PauseStream) error
	ResumeStream(val *ResumeStream) error
}

type PauseStream

type PauseStream struct {
	amp.ClientDescription
}

type RedirectStream

type RedirectStream struct {
	OldClient amp.ClientDescription
	NewClient amp.ClientDescription
}

type ResumeStream

type ResumeStream struct {
	amp.ClientDescription
}