Function NewMessage

watch_manager.go:73–90

(bucketName core.BucketName, key string, value []byte, flag DataFlag, timestamp uint64, options ...MessageOptions)

}

func NewMessage(bucketName core.BucketName, key string, value []byte, flag DataFlag, timestamp uint64, options ...MessageOptions) *Message {
	var priority MessagePriority
	// default priority is medium
	priority = MessagePriorityMedium

	if len(options) > 0 {
		priority = options[0].Priority
	}

	return &Message{
		BucketName: bucketName,
		Key:        key,
		Value:      value,
		Flag:       flag,
		Timestamp:  timestamp,
		priority:   priority,
	}
}

func NewWatchOptions() *WatchOptions {
	return &WatchOptions{