origin

Documentation

Index

• Constants
• Variables
• type Config
• type Connector
  • func New(config *Config) *Connector
  • func (cr *Connector) Close() error
  • func (cr *Connector) Connect(ctx context.Context) func(context.Context, io.Reader, io.WriteCloser) error
  • func (cr *Connector) CreateInstance(ctx context.Context, config service.InstanceConfig, state []byte) (service.Instance, error)
  • func (cr *Connector) Discoverable(context.Context) bool
  • func (cr *Connector) Properties() service.Properties

Constants

const (
	DefaultMaxConns = 3
	DefaultBufSize  = 32768
)

Variables

var DefaultConfig = Config{
	MaxConns: DefaultMaxConns,
	BufSize:  DefaultBufSize,
}

Types

type Config

type Config struct {
	MaxConns int
	BufSize  int
}

type Connector

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

func New

func New(config *Config) *Connector

New Connector instance for serving one (and only one) program instance.

func (*Connector) Close

func (cr *Connector) Close() error

Close causes currently blocked and future Connect calls to return nil. Established connections will not be closed.

func (*Connector) Connect

func (cr *Connector) Connect(ctx context.Context) func(context.Context, io.Reader, io.WriteCloser) error

Connect allocates a new I/O stream. The returned function is to be used to transfer data between a connection and the program instance. If it's non-nil, a connection was established.

func (*Connector) CreateInstance

func (cr *Connector) CreateInstance(ctx context.Context, config service.InstanceConfig, state []byte) (service.Instance, error)

func (*Connector) Discoverable

func (cr *Connector) Discoverable(context.Context) bool

func (*Connector) Properties

func (cr *Connector) Properties() service.Properties