proto

package

v0.7.12 Latest Latest Go to latest Published: Nov 29, 2015 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/modulesio/isolator

Links

Open Source Insights

Documentation ¶

Index ¶

func Marshal(value interface{}) ([]byte, error)
func Register()
func Unmarshal(buf []byte) (interface{}, error)
type Channel
type Conn
- func Accept(listener net.Listener, config *ssh.ServerConfig) (*Conn, error)
- func Connect(address string, identityPath string, version string) (*Conn, error)
type EndOfSources
type FileAdded
type FilePatched
type FileRemoved
type LogEntry
type MD5Hash
type SourceFile
type Target

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Marshal ¶

func Marshal(value interface{}) ([]byte, error)

func Register ¶

func Register()

func Unmarshal ¶

func Unmarshal(buf []byte) (interface{}, error)

Types ¶

type Channel ¶

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

func (*Channel) Abort ¶

func (ch *Channel) Abort() error

func (*Channel) AwaitEOF ¶

func (ch *Channel) AwaitEOF() error

Close write end if not closed, blocks until peer has closed their end

func (*Channel) BytesWritten ¶

func (c *Channel) BytesWritten() int64

func (*Channel) CloseWrite ¶

func (ch *Channel) CloseWrite() error

func (*Channel) Receive ¶

func (ch *Channel) Receive() (interface{}, error)

func (*Channel) Send ¶

func (ch *Channel) Send(graal interface{}) error

type Conn ¶

type Conn struct {
	Conn ssh.Conn

	Chans <-chan ssh.NewChannel
	Reqs  <-chan *ssh.Request

	Permissions *ssh.Permissions
	// contains filtered or unexported fields
}

func Accept ¶

func Accept(listener net.Listener, config *ssh.ServerConfig) (*Conn, error)

func Connect ¶

func Connect(address string, identityPath string, version string) (*Conn, error)

Connect tries to connect to a butler-proto server

func (*Conn) Blog ¶

func (c *Conn) Blog(format string, args ...interface{}) error

func (*Conn) Close ¶

func (c *Conn) Close() error

func (*Conn) OpenChannel ¶

func (c *Conn) OpenChannel(chType string, payload interface{}) (*Channel, error)

func (*Conn) RemoteAddr ¶

func (c *Conn) RemoteAddr() net.Addr

func (*Conn) SendRequest ¶

func (c *Conn) SendRequest(name string, wantReply bool, payload interface{}) (bool, interface{}, error)

func (*Conn) SessionID ¶

func (c *Conn) SessionID() string

type EndOfSources ¶

type EndOfSources struct{}

type FileAdded ¶

type FileAdded struct {
	Path string
}

type FilePatched ¶

type FilePatched struct {
	Path    string
	ApplyTo string
}

type FileRemoved ¶

type FileRemoved struct {
	Path string
}

type LogEntry ¶

type LogEntry struct {
	Message string
}

type MD5Hash ¶

type MD5Hash struct {
	Hash []byte
}

type SourceFile ¶

type SourceFile struct {
	Path string
	Size uint64
}

type Target ¶

type Target struct {
	RepoSpec string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL