Documentation
¶
Index ¶
- type AccountAuthExpired
- type AuthExpired
- type AuthRevoked
- type Authorization
- type BadHeaderMsg
- type BadQueueName
- type BadSubject
- type BadSubscription
- type BadTimeout
- type ChanArg
- type Client
- func (c Client) Close()
- func (c *Client) Publish(ctx context.Context, subject string, value interface{}) (err error)
- func (c *Client) Request(ctx context.Context, subject string, request, response interface{}) (err error)
- func (c *Client) Subscribe(subject string, handle interface{}) (Subscription, error)
- func (c *Client) Unsubscribe(sub Subscription) (err error)
- type ClientIDNotSupported
- type ClientIPNotSupported
- type ConnectionClosed
- type ConnectionDraining
- type ConnectionReconnecting
- type ConsumerConfigRequired
- type ConsumerNameRequired
- type ConsumerNotActive
- type ConsumerNotFound
- type ContextAndTimeout
- type DeliverSubjectRequired
- type Disconnected
- type DrainTimeout
- type ErrorDTO
- type HeadersNotSupported
- type InvalidArg
- type InvalidConnection
- type InvalidContext
- type InvalidDurableName
- type InvalidJSAck
- type InvalidMsg
- type InvalidStreamName
- type JetStreamBadPre
- type JetStreamNotEnabled
- type JsonParse
- type MaxMessages
- type MaxPayload
- type MsgNoReply
- type MsgNotBound
- type MsgNotFound
- type MultiStreamUnsupported
- type MultipleTLSConfigs
- type NkeyAndUser
- type NkeyButNoSigCB
- type NkeysNotSupported
- type NoContextOrTimeout
- type NoDeadlineContext
- type NoEchoNotSupported
- type NoInfoReceived
- type NoMatchingStream
- type NoResponders
- type NoServers
- type NoStreamResponse
- type NoUserCB
- type NotJSMessage
- type PullModeNotAllowed
- type PullSubscribeRequired
- type PullSubscribeToPushConsumer
- type ReconnectBufExceeded
- type SecureConnRequired
- type SecureConnWanted
- type SessionDTO
- type SlowConsumer
- type StaleConnection
- type StreamNameRequired
- type StreamNotFound
- type StreamSnapshotConfigRequired
- type SubjectMismatch
- type Subscription
- type SyncSubRequired
- type Timeout
- type TokenAlreadySet
- type TypeSubscription
- type UserButNoSigCB
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AccountAuthExpired ¶
type AccountAuthExpired struct {
// contains filtered or unexported fields
}
type AuthExpired ¶
type AuthExpired struct {
// contains filtered or unexported fields
}
type AuthRevoked ¶
type AuthRevoked struct {
// contains filtered or unexported fields
}
type Authorization ¶
type Authorization struct {
// contains filtered or unexported fields
}
type BadHeaderMsg ¶
type BadHeaderMsg struct {
// contains filtered or unexported fields
}
type BadQueueName ¶
type BadQueueName struct {
// contains filtered or unexported fields
}
type BadSubject ¶
type BadSubject struct {
// contains filtered or unexported fields
}
type BadSubscription ¶
type BadSubscription struct {
// contains filtered or unexported fields
}
type BadTimeout ¶
type BadTimeout struct {
// contains filtered or unexported fields
}
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func New ¶
func New(log *zap.SugaredLogger, url, name string, maxReconnects int) *Client
New - return new 'NATS' client for rpc and broadcast notifications
func (*Client) Publish ¶
Publish - for notify subscribers
use handle: func(context.Context,*struct)error
func (*Client) Request ¶
func (c *Client) Request(ctx context.Context, subject string, request, response interface{}) (err error)
Request - a remote procedure call is created
use handle: func(context.Context,*struct)(*struct,error)
func (*Client) Subscribe ¶
func (c *Client) Subscribe(subject string, handle interface{}) (Subscription, error)
Subscribe - subscribe handle for remote call or notify
use handle:
for rpc: func(context.Context,*struct)(*struct,error) for notify: func(context.Context,*struct)(error)
func (*Client) Unsubscribe ¶
func (c *Client) Unsubscribe(sub Subscription) (err error)
Unsubscribe - delete subscription
type ClientIDNotSupported ¶
type ClientIDNotSupported struct {
// contains filtered or unexported fields
}
type ClientIPNotSupported ¶
type ClientIPNotSupported struct {
// contains filtered or unexported fields
}
type ConnectionClosed ¶
type ConnectionClosed struct {
// contains filtered or unexported fields
}
type ConnectionDraining ¶
type ConnectionDraining struct {
// contains filtered or unexported fields
}
type ConnectionReconnecting ¶
type ConnectionReconnecting struct {
// contains filtered or unexported fields
}
type ConsumerConfigRequired ¶
type ConsumerConfigRequired struct {
// contains filtered or unexported fields
}
type ConsumerNameRequired ¶
type ConsumerNameRequired struct {
// contains filtered or unexported fields
}
type ConsumerNotActive ¶
type ConsumerNotActive struct {
// contains filtered or unexported fields
}
type ConsumerNotFound ¶
type ConsumerNotFound struct {
// contains filtered or unexported fields
}
type ContextAndTimeout ¶
type ContextAndTimeout struct {
// contains filtered or unexported fields
}
type DeliverSubjectRequired ¶
type DeliverSubjectRequired struct {
// contains filtered or unexported fields
}
type Disconnected ¶
type Disconnected struct {
// contains filtered or unexported fields
}
type DrainTimeout ¶
type DrainTimeout struct {
// contains filtered or unexported fields
}
type HeadersNotSupported ¶
type HeadersNotSupported struct {
// contains filtered or unexported fields
}
type InvalidArg ¶
type InvalidArg struct {
// contains filtered or unexported fields
}
type InvalidConnection ¶
type InvalidConnection struct {
// contains filtered or unexported fields
}
type InvalidContext ¶
type InvalidContext struct {
// contains filtered or unexported fields
}
type InvalidDurableName ¶
type InvalidDurableName struct {
// contains filtered or unexported fields
}
type InvalidJSAck ¶
type InvalidJSAck struct {
// contains filtered or unexported fields
}
type InvalidMsg ¶
type InvalidMsg struct {
// contains filtered or unexported fields
}
type InvalidStreamName ¶
type InvalidStreamName struct {
// contains filtered or unexported fields
}
type JetStreamBadPre ¶
type JetStreamBadPre struct {
// contains filtered or unexported fields
}
type JetStreamNotEnabled ¶
type JetStreamNotEnabled struct {
// contains filtered or unexported fields
}
type MaxMessages ¶
type MaxMessages struct {
// contains filtered or unexported fields
}
type MaxPayload ¶
type MaxPayload struct {
// contains filtered or unexported fields
}
type MsgNoReply ¶
type MsgNoReply struct {
// contains filtered or unexported fields
}
type MsgNotBound ¶
type MsgNotBound struct {
// contains filtered or unexported fields
}
type MsgNotFound ¶
type MsgNotFound struct {
// contains filtered or unexported fields
}
type MultiStreamUnsupported ¶
type MultiStreamUnsupported struct {
// contains filtered or unexported fields
}
type MultipleTLSConfigs ¶
type MultipleTLSConfigs struct {
// contains filtered or unexported fields
}
type NkeyAndUser ¶
type NkeyAndUser struct {
// contains filtered or unexported fields
}
type NkeyButNoSigCB ¶
type NkeyButNoSigCB struct {
// contains filtered or unexported fields
}
type NkeysNotSupported ¶
type NkeysNotSupported struct {
// contains filtered or unexported fields
}
type NoContextOrTimeout ¶
type NoContextOrTimeout struct {
// contains filtered or unexported fields
}
type NoDeadlineContext ¶
type NoDeadlineContext struct {
// contains filtered or unexported fields
}
type NoEchoNotSupported ¶
type NoEchoNotSupported struct {
// contains filtered or unexported fields
}
type NoInfoReceived ¶
type NoInfoReceived struct {
// contains filtered or unexported fields
}
type NoMatchingStream ¶
type NoMatchingStream struct {
// contains filtered or unexported fields
}
type NoResponders ¶
type NoResponders struct {
// contains filtered or unexported fields
}
type NoStreamResponse ¶
type NoStreamResponse struct {
// contains filtered or unexported fields
}
type NotJSMessage ¶
type NotJSMessage struct {
// contains filtered or unexported fields
}
type PullModeNotAllowed ¶
type PullModeNotAllowed struct {
// contains filtered or unexported fields
}
type PullSubscribeRequired ¶
type PullSubscribeRequired struct {
// contains filtered or unexported fields
}
type PullSubscribeToPushConsumer ¶
type PullSubscribeToPushConsumer struct {
// contains filtered or unexported fields
}
type ReconnectBufExceeded ¶
type ReconnectBufExceeded struct {
// contains filtered or unexported fields
}
type SecureConnRequired ¶
type SecureConnRequired struct {
// contains filtered or unexported fields
}
type SecureConnWanted ¶
type SecureConnWanted struct {
// contains filtered or unexported fields
}
type SessionDTO ¶
type SlowConsumer ¶
type SlowConsumer struct {
// contains filtered or unexported fields
}
type StaleConnection ¶
type StaleConnection struct {
// contains filtered or unexported fields
}
type StreamNameRequired ¶
type StreamNameRequired struct {
// contains filtered or unexported fields
}
type StreamNotFound ¶
type StreamNotFound struct {
// contains filtered or unexported fields
}
type StreamSnapshotConfigRequired ¶
type StreamSnapshotConfigRequired struct {
// contains filtered or unexported fields
}
type SubjectMismatch ¶
type SubjectMismatch struct {
// contains filtered or unexported fields
}
type Subscription ¶
type Subscription interface {
GetSubject() string
}
type SyncSubRequired ¶
type SyncSubRequired struct {
// contains filtered or unexported fields
}
type TokenAlreadySet ¶
type TokenAlreadySet struct {
// contains filtered or unexported fields
}
type TypeSubscription ¶
type TypeSubscription struct {
// contains filtered or unexported fields
}
type UserButNoSigCB ¶
type UserButNoSigCB struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.