Documentation
¶
Index ¶
- Constants
- func CreateResource(m *mesheryv1alpha1.Broker, scheme *runtime.Scheme) *appsv1.Deployment
- func ErrConnect(err interface{}) error
- func ErrEncodedConn(err error) error
- func ErrPublish(err interface{}) error
- func ErrPublishRequest(err error) error
- func ErrQueueSubscribe(err interface{}) error
- func GetResource(m *mesheryv1alpha1.Broker) runtime.Object
- type Nats
Constants ¶
const ( ErrConnectCode = "11000" ErrEncodedConnCode = "11000" ErrPublishCode = "11001" ErrPublishRequestCode = "11001" ErrQueueSubscribeCode = "11001" )
Variables ¶
This section is empty.
Functions ¶
func CreateResource ¶
func CreateResource(m *mesheryv1alpha1.Broker, scheme *runtime.Scheme) *appsv1.Deployment
CreateDeployment returns a meshsync Deployment object
func ErrConnect ¶
func ErrConnect(err interface{}) error
func ErrEncodedConn ¶
func ErrPublish ¶
func ErrPublish(err interface{}) error
func ErrPublishRequest ¶
func ErrQueueSubscribe ¶
func ErrQueueSubscribe(err interface{}) error
func GetResource ¶
func GetResource(m *mesheryv1alpha1.Broker) runtime.Object
Types ¶
type Nats ¶
type Nats struct {
// contains filtered or unexported fields
}
Nats will implement Nats subscribe and publish functionality
func (*Nats) PublishWithCallback ¶
PublishWithCallback - will implement the request-reply mechanisms Arguments: request - the subject to which publish a request reply - this string will be used by the replier to publish replies message - message send by the requestor to replier TODO Ques: After this the requestor have to subscribe to the reply subject
func (*Nats) Subscribe ¶
Subscribe - for subscribing messages TODO Ques: Do we want to unsubscribe TODO will the method-user just subsribe, how will it handle the received messages?
func (*Nats) SubscribeWithHandler ¶
SubscribeWithHandler - for handling request-reply protocol request is the subject to which the this thing is listening when there will be a request
Source Files