portal

Documentation

Index

• type PlainPortal
  • func NewPortal(s stack.Stack) PlainPortal
  • func (n PlainPortal) Get(request *messages.MessageWrapper, timeout time.Duration) (*messages.MessageWrapper, error)
  • func (n PlainPortal) GetAsync(request *messages.MessageWrapper, callback ResponseMessageCallback)
  • func (p PlainPortal) GetAsyncWithTimeout(request *messages.MessageWrapper, timeout time.Duration, ...)
  • func (p PlainPortal) Produce(data *messages.MessageWrapper)
  • func (n PlainPortal) Serve(prefix *name.Name, callback RequestMessageCallback)
• type Portal
• type PortalError
  • func (e PortalError) Error() string
• type RequestMessageCallback
• type ResponseMessageCallback
• type SecurePortal
  • func NewSecurePortal(s stack.Stack) SecurePortal
  • func (n SecurePortal) Connect(prefix *name.Name)
  • func (n SecurePortal) Get(request *messages.MessageWrapper, timeout time.Duration) (*messages.MessageWrapper, error)
  • func (n SecurePortal) GetAsync(request *messages.MessageWrapper, callback ResponseMessageCallback)
  • func (p SecurePortal) GetAsyncWithTimeout(request *messages.MessageWrapper, timeout time.Duration, ...)
  • func (p SecurePortal) Produce(data *messages.MessageWrapper)
  • func (n SecurePortal) Serve(prefix *name.Name, callback RequestMessageCallback)

Types

type PlainPortal

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

func NewPortal

func NewPortal(s stack.Stack) PlainPortal

func (PlainPortal) Get

func (n PlainPortal) Get(request *messages.MessageWrapper, timeout time.Duration) (*messages.MessageWrapper, error)

func (PlainPortal) GetAsync

func (n PlainPortal) GetAsync(request *messages.MessageWrapper, callback ResponseMessageCallback)

func (PlainPortal) GetAsyncWithTimeout

func (p PlainPortal) GetAsyncWithTimeout(request *messages.MessageWrapper, timeout time.Duration, callback ResponseMessageCallback)

func (PlainPortal) Produce

func (p PlainPortal) Produce(data *messages.MessageWrapper)

func (PlainPortal) Serve

func (n PlainPortal) Serve(prefix *name.Name, callback RequestMessageCallback)

type Portal

type Portal interface {
	Get(request *messages.MessageWrapper, timeout time.Duration) (*messages.MessageWrapper, error)
	GetAsync(request *messages.MessageWrapper, callback ResponseMessageCallback)
	GetAsyncWithTimeout(request *messages.MessageWrapper, timeout time.Duration, callback ResponseMessageCallback)
	Serve(prefix *name.Name, callback RequestMessageCallback)
	Produce(data *messages.MessageWrapper)
}

type PortalError

type PortalError struct {
	Arg  int
	Prob string
}

func (PortalError) Error

func (e PortalError) Error() string

type RequestMessageCallback

type RequestMessageCallback func(*messages.MessageWrapper) *messages.MessageWrapper

type ResponseMessageCallback

type ResponseMessageCallback func(*messages.MessageWrapper)

type SecurePortal

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

func NewSecurePortal

func NewSecurePortal(s stack.Stack) SecurePortal

func (SecurePortal) Connect

func (n SecurePortal) Connect(prefix *name.Name)

func (SecurePortal) Get

func (n SecurePortal) Get(request *messages.MessageWrapper, timeout time.Duration) (*messages.MessageWrapper, error)

func (SecurePortal) GetAsync

func (n SecurePortal) GetAsync(request *messages.MessageWrapper, callback ResponseMessageCallback)

func (SecurePortal) GetAsyncWithTimeout

func (p SecurePortal) GetAsyncWithTimeout(request *messages.MessageWrapper, timeout time.Duration, callback ResponseMessageCallback)

func (SecurePortal) Produce

func (p SecurePortal) Produce(data *messages.MessageWrapper)

func (SecurePortal) Serve

func (n SecurePortal) Serve(prefix *name.Name, callback RequestMessageCallback)