Documentation
¶
Index ¶
- type 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
- type RequestMessageCallback
- type ResponseMessageCallback
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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)
Source Files
Click to show internal directories.
Click to hide internal directories.