README
¶
sdk
BoltMQ sdk.
Documentation
¶
Overview ¶
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
const ( // Founded FOUND common.PullStatus = common.FOUND // No new message can be pull NO_NEW_MSG // Filtering results can not match NO_MATCHED_MSG // Illegal offset，may be too big or too small OFFSET_ILLEGAL )
const ( SEND_OK common.ResultStatus = common.SEND_OK FLUSH_DISK_TIMEOUT FLUSH_SLAVE_TIMEOUT SLAVE_NOT_AVAILABLE )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageListener ¶
type MessageListener interface{}
type Producer ¶
type Producer interface {
NameSrvAddrs(addrs []string)
InstanceName(instanceName string)
Send(msg *message.Message) (*Result, error)
SendOneWay(msg *message.Message) error
SendCallBack(msg *message.Message, callback Callback) error
Start() error
Stop()
}
func NewProduer ¶
type PullConsumer ¶
type PullConsumer interface {
NameSrvAddrs(addrs []string)
FetchSubscribeMessageQueues(topic string) []*message.MessageQueue
Pull(mq *message.MessageQueue, subExpression string, offset int64, maxNums int) (*PullResult, error)
Start()
Stop()
}
func NewPullConsumer ¶
func NewPullConsumer() PullConsumer
type PullResult ¶
type PullResult = common.PullResult
type PushConsumer ¶
type PushConsumer interface {
NameSrvAddrs(addrs []string)
SetConsumeFromWhere(consumeFromWhere heartbeat.ConsumeFromWhere)
SetMessageModel(model heartbeat.MessageModel)
RegisterMessageListener(listener MessageListener)
Subscribe(topic string, subExpression string)
Start()
Stop()
}
func NewPushConsumer ¶
func NewPushConsumer() PushConsumer
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |