Documentation
¶
Index ¶
Constants ¶
View Source
const ( RetainedMessageCreated string = "retained_message_created" RetainedMessageDeleted = "retained_message_deleted" )
Variables ¶
View Source
var (
ErrRetainedMessageNotFound = errors.New("retained message not found")
)
Functions ¶
func NewMemDBStore ¶
func NewMemDBStore(mesh types.GossipServiceLayer) (*memDBStore, error)
func TenantTopicIndexer ¶
func TenantTopicIndexer() *topicIndexer
Types ¶
type ByteSliceIndexer ¶
type ByteSliceIndexer struct {
// contains filtered or unexported fields
}
func (*ByteSliceIndexer) FromArgs ¶
func (b *ByteSliceIndexer) FromArgs(opts ...interface{}) ([]byte, error)
func (*ByteSliceIndexer) FromObject ¶
func (b *ByteSliceIndexer) FromObject(obj interface{}) (bool, []byte, error)
type Store ¶
type Store interface {
Create(message *pb.RetainedMessage) error
ByTopicPattern(tenant string, pattern []byte) (pb.RetainedMessageMetadataList, error)
All() (pb.RetainedMessageMetadataList, error)
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.