Put puts data to the end of the queue, if puts failure return err.
(message []byte)
| 57 | type Queue interface { |
| 58 | // Put puts data to the end of the queue, if puts failure return err. |
| 59 | Put(message []byte) error |
| 60 | // Get gets the message data at specific index. |
| 61 | Get(sequence int64) (message []byte, err error) |
| 62 | // AppendedSeq returns the written sequence which stands for the latest write barrier. |
no outgoing calls