MCPcopy
hub / github.com/lindb/lindb / Put

Method Put

pkg/queue/queue.go:59–59  ·  view source on GitHub ↗

Put puts data to the end of the queue, if puts failure return err.

(message []byte)

Source from the content-addressed store, hash-verified

57type 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.

Callers 15

TestQueue_PutFunction · 0.95
TestQueue_AckFunction · 0.95
TestQueue_SetAppendSeqFunction · 0.95
TestQueue_reopen_errFunction · 0.95
TestQueue_Put_errFunction · 0.95
TestQueue_Get_errFunction · 0.95
TestQueue_Ack_errFunction · 0.95
TestQueue_concurrentlyFunction · 0.95
TestQueue_big_loopFunction · 0.95
gcMethod · 0.65
TestMetadataDatabase_gcFunction · 0.65
putSQLLexerFunction · 0.65

Implementers 1

queuepkg/queue/queue.go

Calls

no outgoing calls

Tested by 15

TestQueue_PutFunction · 0.76
TestQueue_AckFunction · 0.76
TestQueue_SetAppendSeqFunction · 0.76
TestQueue_reopen_errFunction · 0.76
TestQueue_Put_errFunction · 0.76
TestQueue_Get_errFunction · 0.76
TestQueue_Ack_errFunction · 0.76
TestQueue_concurrentlyFunction · 0.76
TestQueue_big_loopFunction · 0.76
TestMetadataDatabase_gcFunction · 0.52
TestPartition_WriteLogFunction · 0.52
TestPartition_ReplicaLogFunction · 0.52